@handler("connect", channel="source")
    def _on_source_connect(self, sock, host, port):

        bind = 0
        channel = uuid()

        client = TCPClient(bind, channel=channel)
        client.register(self)

        self.addHandler(
            handler("disconnected", channel=channel)(_on_target_disconnected)
        )

        self.addHandler(
            handler("ready", channel=channel)(_on_target_ready)
        )

        self.addHandler(
            handler("read", channel=channel)(_on_target_read)
        )

        self._clients[sock] = client
        self._sockets[client.channel] = sock
Send the signum signal to the process
dataset/ETHPy150Open circuits/circuits/examples/portforward.py/PortForwarder._on_source_connect--crossover with--dataset/ETHPy150Open circus-tent/circus/circus/watcher.py/Watcher.send_signal_process