|
@@ -306,6 +306,8 @@ class DecentralizedAverager(mp.Process, ServicerBase):
|
|
|
|
|
|
while True:
|
|
|
await pipe_semaphore.acquire()
|
|
|
+ if not self._inner_pipe.poll():
|
|
|
+ continue
|
|
|
try:
|
|
|
method, args, kwargs = self._inner_pipe.recv()
|
|
|
except (OSError, ConnectionError, RuntimeError) as e:
|