Skip to content

Commit d0f8c2d

Browse files
committed
hivemind/dht/dht.py: handle BlockingIOError and EOFError while waiting for msg on _inner_pipe.rev()
for `method, args, kwargs = self._inner_pipe.recv()` exceptions being caught don't handle `BlockingIOError` and `EOFError`. This is important to be included in the list of exceptions being handled because sometimes the resources aren't available. Signed-off-by: 0xnightwind <[email protected]>
1 parent 4d5c414 commit d0f8c2d

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

hivemind/dht/dht.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@ async def _run():
126126
continue
127127
try:
128128
method, args, kwargs = self._inner_pipe.recv()
129-
except (OSError, ConnectionError, RuntimeError) as e:
129+
except (OSError, ConnectionError, RuntimeError, BlockingIOError, EOFError) as e:
130130
logger.exception(e)
131131
await asyncio.sleep(self._node.protocol.wait_timeout)
132132
continue

0 commit comments

Comments
 (0)