sui_feng/AzurLaneAutoScript
1
0
Fork 0
mirror of https://gitee.com/sui-feng-cb/AzurLaneAutoScript1 synced 2026-03-12 02:48:23 +08:00
Code Activity

Merge branch 'master' into dev

Browse Source
This commit is contained in:
LmeSzinc
2022-09-03 14:59:36 +08:00
parent 12c68155c5 bb6898266f
commit d8f4986d64
15 changed files with 259 additions and 35 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
module/device/connection.py
View File

@@ -293,7 +293,7 @@ class Connection(ConnectionAttr):
raise AdbTimeout('reverse server accept timeout')
# Server receive data
data = recv_all(conn, chunk_size=chunk_size)
data = recv_all(conn, chunk_size=chunk_size, recv_interval=0.001)
# Server close connection
conn.close()

5
module/device/method/utils.py
View File

@@ -38,11 +38,12 @@ def random_port(port_range):
return new_port
def recv_all(stream, chunk_size=4096) -> bytes:
def recv_all(stream, chunk_size=4096, recv_interval=0.000) -> bytes:
"""
Args:
stream:
chunk_size:
recv_interval (float): Default to 0.000, use 0.001 if receiving as server
Returns:
bytes:
@@ -61,7 +62,7 @@ def recv_all(stream, chunk_size=4096) -> bytes:
if chunk:
fragments.append(chunk)
# See https://stackoverflow.com/questions/23837827/python-server-program-has-high-cpu-usage/41749820#41749820
time.sleep(0.001)
time.sleep(recv_interval)
else:
break
return remove_shell_warning(b''.join(fragments))