Method _pump

scripts/egress_proxy.py:53–74

(a: socket.socket, b: socket.socket)

    @staticmethod
    def _pump(a: socket.socket, b: socket.socket) -> None:
        a.setblocking(False)
        b.setblocking(False)
        try:
            while True:
                r, _, _ = select.select([a, b], [], [], 60)
                if not r:
                    return
                for src in r:
                    dst = b if src is a else a
                    data = src.recv(65536)
                    if not data:
                        return
                    dst.sendall(data)
        except OSError:
            pass
        finally:
            for s in (a, b):
                try:
                    s.close()
                except OSError:
                    pass

    def log_message(self, format, *args):  # noqa: A002 — base sig
        pass