|
@@ -152,9 +152,7 @@ class ConnHandler(ConnHandlerBase):
|
|
"""
|
|
"""
|
|
if block_size == None:
|
|
if block_size == None:
|
|
block_size = self.block_size
|
|
block_size = self.block_size
|
|
-
|
|
+ data_received = await self.socket.recv(block_size=block_size)
|
|
-
|
|
|
|
- data_received = await super().recv(block_size=block_size)
|
|
|
|
data_decoded = data_received.decode("utf-8")
|
|
data_decoded = data_received.decode("utf-8")
|
|
return data_decoded
|
|
return data_decoded
|
|
|
|
|
|
@@ -167,11 +165,13 @@ class ConnHandler(ConnHandlerBase):
|
|
lschat.info("server:"+log_msg)
|
|
lschat.info("server:"+log_msg)
|
|
else:
|
|
else:
|
|
lschat.info("Server:"+data)
|
|
lschat.info("Server:"+data)
|
|
-
|
|
|
|
-
|
|
|
|
data_encoded = bytes(data, "utf-8")
|
|
data_encoded = bytes(data, "utf-8")
|
|
- send_status = await super().send(data_encoded)
|
|
+ try:
|
|
- return send_status
|
|
+ await self.socket.send(data_encoded)
|
|
|
|
+ return True
|
|
|
|
+ except Exception as e:
|
|
|
|
+ lch.error(e, exc_info=True)
|
|
|
|
+ return False
|
|
|
|
|
|
|
|
|
|
class ConnHandlerEcho(ConnHandler):
|
|
class ConnHandlerEcho(ConnHandler):
|