StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Handle StreamClosed in identify protocol handler

Browse Source
This commit is contained in:
NIC619 2019-11-12 18:07:30 +08:00
parent 56d3e50267
commit c4f9ce6bb3
No known key found for this signature in database
GPG Key ID: 570C35F5C2D51B17
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
libp2p/identity/identify/protocol.py
View File

@ -3,6 +3,7 @@ import logging
from multiaddr import Multiaddr from multiaddr import Multiaddr
from libp2p.host.host_interface import IHost from libp2p.host.host_interface import IHost
from libp2p.network.stream.exceptions import StreamClosed
from libp2p.network.stream.net_stream_interface import INetStream from libp2p.network.stream.net_stream_interface import INetStream
from libp2p.typing import StreamHandlerFn, TProtocol from libp2p.typing import StreamHandlerFn, TProtocol
@ -43,7 +44,11 @@ def identify_handler_for(host: IHost) -> StreamHandlerFn:
protobuf = _mk_identify_protobuf(host) protobuf = _mk_identify_protobuf(host)
response = protobuf.SerializeToString() response = protobuf.SerializeToString()
try:
await stream.write(response) await stream.write(response)
except StreamClosed:
logger.debug("Fail to respond to %s request: stream closed", ID)
else:
await stream.close() await stream.close()
logger.debug("successfully handled request for %s from %s", ID, peer_id) logger.debug("successfully handled request for %s from %s", ID, peer_id)