Commit 834ec7b4 authored by root's avatar root
Browse files

fixed introduced bug that prevented to send messages from many to one

parent 39e6401f
......@@ -67,7 +67,7 @@ class One2ManyBiProxy(multiprocessing.Process):
del self.active_endpoints[one_addr]
else:
try:
self.sink.sendto(many_data, one_addr)
self.source.sendto(many_data, one_addr)
except BlockingIOError:
continue
elif sock.getsockname()[1] == self.one_port:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment