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)