use recv buffer 64
This commit is contained in:
+2
-1
@@ -101,11 +101,12 @@ class NetworkBackend(ABackend):
|
|||||||
sock = self.find_by_name(name)
|
sock = self.find_by_name(name)
|
||||||
if mask & selectors.EVENT_READ:
|
if mask & selectors.EVENT_READ:
|
||||||
timestamp = time.time()
|
timestamp = time.time()
|
||||||
data = key.fileobj.recv(16)
|
data = key.fileobj.recv(64)
|
||||||
sock['xcvr'].on_recv(MsgContainer(name, timestamp, data))
|
sock['xcvr'].on_recv(MsgContainer(name, timestamp, data))
|
||||||
if mask & selectors.EVENT_WRITE:
|
if mask & selectors.EVENT_WRITE:
|
||||||
data = sock['queue'].get()
|
data = sock['queue'].get()
|
||||||
key.fileobj.send(data)
|
key.fileobj.send(data)
|
||||||
|
print(f"Send: {sock['name']}: {data}")
|
||||||
if sock['queue'].empty():
|
if sock['queue'].empty():
|
||||||
self.sel.modify(sock['sock'], selectors.EVENT_READ, None)
|
self.sel.modify(sock['sock'], selectors.EVENT_READ, None)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user