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
def open ( self , packet_received ) : 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.
Opens the port . : param packet_received : Callback which is invoked when we received a packet . Is passed the peer typename and data .