We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
TCPListener.listen()
1 parent e076a03 commit bb21af7Copy full SHA for bb21af7
libp2p/transport/tcp/tcp.py
@@ -63,8 +63,14 @@ async def serve_tcp(
63
await trio.serve_tcp(handler, port, host=host, task_status=task_status)
64
65
async def handler(stream: trio.SocketStream) -> None:
66
- tcp_stream = TrioTCPStream(stream)
67
- await self.handler(tcp_stream)
+ remote_host : str = ""
+ remote_port : int = 0
68
+ try:
69
+ tcp_stream = TrioTCPStream(stream)
70
+ remote_host,remote_port = tcp_stream.get_remote_address()
71
+ await self.handler(tcp_stream)
72
+ except Exception as e:
73
+ logger.error(f"Connection from {remote_host}:{remote_port} failed.")
74
75
listeners = await nursery.start(
76
serve_tcp,
0 commit comments