Commit ac93356a by Owo Sugiana

Bug fixed di Windows terkait socket.MSG_DONTWAIT

1 parent 2cc21a91
...@@ -8,6 +8,7 @@ class Client(Connection): ...@@ -8,6 +8,7 @@ class Client(Connection):
Connection.__init__(self, conf) Connection.__init__(self, conf)
self.address = (conf['ip'], conf['port']) self.address = (conf['ip'], conf['port'])
self.request = socket.socket(socket.AF_INET, socket.SOCK_STREAM) self.request = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.request.setblocking(True)
def connect(self): def connect(self):
self.request.connect(self.address) self.request.connect(self.address)
......
...@@ -75,8 +75,7 @@ class Connection: ...@@ -75,8 +75,7 @@ class Connection:
def receive_raw(self): def receive_raw(self):
try: try:
ready, _, _ = select.select([self.request], [], [], 5) ready, _, _ = select.select([self.request], [], [], 5)
raw = ready and self.request.recv( raw = ready and self.request.recv(self.get_receive_size()) or ''
self.get_receive_size(), socket.MSG_DONTWAIT) or ''
if raw: if raw:
self.on_receive_raw(raw) self.on_receive_raw(raw)
return raw return raw
......
Markdown is supported
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!