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)
Called when a remote worker connection has been found. Finishes setting
        up the protocol object.