anycall/connectionpool.py
def open(self, packet_received):
        """
        Opens the port.
        
        :param packet_received: Callback which is invoked when we received a packet.
          Is passed the peer, typename, and data.

        :returns: Deferred that callbacks when we are ready to receive.
        """
        def port_open(listeningport):
            self._listeningport = listeningport
            self.ownid = self.ownid_factory(listeningport)
            logger.debug("Port opened. Own-ID:%s" % self.ownid)
            return None
        
        logger.debug("Opening connection pool")
        
        self.packet_received = packet_received
        d = self.stream_server_endpoint.listen(PoolFactory(self, self._typenames))
        d.addCallback(port_open)
        return d
def open(self, packet_received):
        """
        Opens the port.
        
        :param packet_received: Callback which is invoked when we received a packet.
          Is passed the peer, typename, and data.

        :returns: Deferred that callbacks when we are ready to receive.
        """
        def port_open(listeningport):
            self._listeningport = listeningport
            self.ownid = self.ownid_factory(listeningport)
            logger.debug("Port opened. Own-ID:%s" % self.ownid)
            return None
        
        logger.debug("Opening connection pool")
        
        self.packet_received = packet_received
        d = self.stream_server_endpoint.listen(PoolFactory(self, self._typenames))
        d.addCallback(port_open)
        return d
Opens the port.
        
        :param packet_received: Callback which is invoked when we received a packet.
          Is passed the peer, typename, and data.

        :returns: Deferred that callbacks when we are ready to receive.