@defer.inlineCallbacks
    def reserveCommitConfirmed(self, header, connection_id):

        log.msg('', system=LOG_SYSTEM)
        log.msg((connection_id, header.provider_nsa) % 'ReserveCommit Confirmed for sub connection %s. NSA %s ', system=LOG_SYSTEM)

        sub_connection = yield self.getSubConnection(header.provider_nsa, connection_id)
        sub_connection.reservation_state = state.RESERVE_START
        yield sub_connection.save()

        conn = yield self.getConnectionByKey(sub_connection.service_connection_id)
        sub_conns = yield self.getSubConnectionsByConnectionKey(conn.id)

        # if we get responses very close, multiple requests can trigger this, so we check main state as well
        if all( [ sc.reservation_state == state.RESERVE_START for sc in sub_conns ] ) and conn.reservation_state != state.RESERVE_START:
            yield state.reserved(conn)
            header = nsa.NSIHeader(conn.requester_nsa, self.nsa_.urn())
            self.parent_requester.reserveCommitConfirmed(header, conn.connection_id)
            self.plugin.connectionCreated(conn)
dataset/ETHPy150Open NORDUnet/opennsa/opennsa/aggregator.py/Aggregator.reserveCommitConfirmed/swapped operands of `%`