From 268d0d6993bd181237b0fec397ce4bdb46adf011 Mon Sep 17 00:00:00 2001
From: CHAMPION923 <1056156912@qq.com>
Date: Wed, 4 Jun 2025 09:47:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=96=E6=B6=88Tcp=E6=9C=8D=E5=8A=A1?=
 =?UTF-8?q?=E9=98=BB=E5=A1=9E=E5=BC=8F=E6=8E=A5=E6=94=B6=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lib/tcp/tcp_server.py | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/lib/tcp/tcp_server.py b/lib/tcp/tcp_server.py
index 9a8667c..aa0606e 100644
--- a/lib/tcp/tcp_server.py
+++ b/lib/tcp/tcp_server.py
@@ -1,5 +1,7 @@
 import socket
 
+from open3d import re
+
 
 class TcpServer:
     def __init__(self, host="0.0.0.0", port=65444) -> None:
@@ -12,11 +14,15 @@ class TcpServer:
 
     def accept_client(self):
         self.conn, self.addr = self.sock.accept()
+        self.conn.setblocking(False)
         print(f"Connected by {self.addr}")
 
     def recv_data(self, bufsize=4096):
-        data = self.conn.recv(bufsize)
-        return data
+        try:
+            data = self.conn.recv(bufsize)
+            return data
+        except BlockingIOError:
+            return ""
 
     def send_data(self, data: bytes):
         self.conn.sendall(data)