norohind/AudioControl
0
0
Fork 0
mirror of https://github.com/norohind/AudioControl.git synced 2025-04-20 16:47:37 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

Net: handle force close conn (RST?)

Browse Source
This commit is contained in:
norohind 2022-11-13 19:35:38 +03:00
parent 6de07b89fa
commit 89c67e872c
Signed by: norohind
GPG Key ID: 01C3BECC26FB59E1
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
NetworkTransport.py
View File

@ -53,14 +53,21 @@ class NetworkTransport(TransportABC):
conn.close()
def _on_socket_receive(self, conn: socket.socket, mask: int):
data = conn.recv(1000)
if not data:
self._close_conn(conn)
return
try:
data = conn.recv(1000)
for data_part in data.split(b'\n'):
if len(data_part) != 0:
self._handle_received_event(data_part, conn)
except ConnectionResetError:
logger.opt(exception=True).warning(f'Closing connection due to RST?')
self._close_conn(conn)
else:
if not data:
self._close_conn(conn)
return
for data_part in data.split(b'\n'):
if len(data_part) != 0:
self._handle_received_event(data_part, conn)
def _handle_received_event(self, data: bytes, conn: socket.socket):
try: