Fix close an already reset connection

2026-02-12 16:10:57 +00:00 · 2019-12-24 16:19:49 +08:00
parent c35cb8318a
commit 8f52315816
1 changed files with 5 additions and 1 deletions
--- a/libp2p/network/connection/raw_connection.py
+++ b/libp2p/network/connection/raw_connection.py
@ -55,4 +55,8 @@ class RawConnection(IRawConnection):
        self.writer.close()
        if sys.version_info < (3, 7):
            return
-        await self.writer.wait_closed()
+        try:
+            await self.writer.wait_closed()
+        # In case the connection is already reset.
+        except (ConnectionResetError, RawConnError):
+            return