Method _batch_coop_settle

raiden/api/python.py:908–985

(
        self,
        channels_to_settle: List[NettingChannelState],
        retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
    )

        )

    def _batch_coop_settle(
        self,
        channels_to_settle: List[NettingChannelState],
        retry_timeout: NetworkTimeout = DEFAULT_RETRY_TIMEOUT,
    ) -> List[NettingChannelState]:
        pfs_proxy = self.raiden.pfs_proxy
        coop_settle_state_changes: List[StateChange] = []
        to_coop_settle = set()
        for channel_state in channels_to_settle:
            recipient_address = channel_state.partner_state.address
            try:
                metadata = pfs_proxy.query_address_metadata(recipient_address)
            except ServiceRequestFailed:
                log.error(
                    "Partner is offline, coop settle not possible", address=recipient_address
                )
                continue
            to_coop_settle.add(channel_state.canonical_identifier)
            coop_settle_state_changes.append(
                ActionChannelCoopSettle(
                    canonical_identifier=channel_state.canonical_identifier,
                    recipient_metadata=metadata,
                )
            )

        greenlets = set(self.raiden.handle_state_changes(coop_settle_state_changes))
        gevent.joinall(greenlets, raise_error=True)

        # we need to get a new list of channel state objects since the ones we
        # have may have become stale
        ids = frozenset(ch.canonical_identifier for ch in channels_to_settle)
        chain_state = views.state_from_raiden(self.raiden)
        channels_to_settle = [
            ch for ch in views.list_all_channelstate(chain_state) if ch.canonical_identifier in ids
        ]

        channels_to_conditions = {}
        for channel_state in channels_to_settle:
            if channel_state.canonical_identifier not in to_coop_settle:
                continue
            # FIXME is there a race condition when we "get" the total-withdraw-values after they
            # have been determined by the state machine?
            # --> because the initiated_coop_settle is removed at some point if it expired
            # --> also this only works because the initiated_coop_settle is directly set upon
            #       handling the ActionChannelCoopSettle. If that wasn't the case,
            #       we first would have to wait several state-machine iterations
            #       until the coop-settle-state existed on the channel-state
            # If this is a problem, the calculation of the max-withdraw amounts
            # would have to be done HERE and included in the ActionChannelCoopSettle,
            # so that we know them before feeding the action into the state machine
            # and can await them easily here...

            # Initiating a cooop settle for this channel did not succeed
            # (e.g. due to pending locks or withdraws) so don't wait on it.
            # The channel will be closed later in a non-coop manner.
            if channel_state.our_state.initiated_coop_settle is None:
                continue