highfive/master.py
def connection_made(self, transport):
        """
        Called when a remote worker connection has been found. Finishes setting
        up the protocol object.
        """

        if self._manager.is_closed():
            logger.debug("worker tried to connect while manager was closed")
            return

        logger.debug("new worker connected")

        self._transport = transport
        self._buffer = bytearray()
        self._worker = Worker(self._transport, self._manager)
        self._workers.add(self._worker)
def connection_made(self, transport):
        """
        Called when a remote worker connection has been found. Finishes setting
        up the protocol object.
        """

        if self._manager.is_closed():
            logger.debug("worker tried to connect while manager was closed")
            return

        logger.debug("new worker connected")

        self._transport = transport
        self._buffer = bytearray()
        self._worker = Worker(self._transport, self._manager)
        self._workers.add(self._worker)
def connection_made ( self , transport ) : if self . _manager . is_closed ( ) : logger . debug ( "worker tried to connect while manager was closed" ) return logger . debug ( "new worker connected" ) self . _transport = transport self . _buffer = bytearray ( ) self . _worker = Worker ( self . _transport , self . _manager ) self . _workers . add ( self . _worker )
Called when a remote worker connection has been found. Finishes setting
        up the protocol object.
Called when a remote worker connection has been found . Finishes setting up the protocol object .