diff --git a/apps/em/cd.py b/apps/em/cd.py index cfa76a31..88714562 100644 --- a/apps/em/cd.py +++ b/apps/em/cd.py @@ -148,6 +148,15 @@ def get_tyy_data(*args): sc.settimeout(5) # 设置超时 sc.connect((host, port)) sc_all[f"{host}_{port}"] = sc + else: + # 清空接收缓冲区 + sc.settimeout(0.1) # 设置短暂超时 + try: + while True: + sc.recv(1024) + except (socket.timeout, BlockingIOError): + pass + sc.settimeout(5) # 恢复原超时设置 sc.sendall(b"R") except BrokenPipeError: if retry > 0: