(conn, data, addr)
| 260 | update_gpu_info() |
| 261 | handle_new_job(data) |
| 262 | else: |
| 263 | logging.info(f"Unknown message from server") |
| 264 | |
| 265 | |
| 266 | def handle_server(conn): |
| 267 | logging.info(f"Accepted connection from server") |
| 268 | while True: |
| 269 | data = conn.recv(1024).decode() |
| 270 | if not data: |
| 271 | break |
| 272 | logging.debug(f"Received message from server: {data}") |
| 273 | handle_message(conn, data) |
| 274 | logging.info(f"Connection from server closed") |
| 275 | conn.close() |
| 276 | |
| 277 | |
| 278 | |
| 279 | |
| 280 | def handle_server_tcp(conn, addr): |
| 281 | logging.info(f"Accepted connection from {addr}") |
| 282 | while True: |
| 283 | data = conn.recv(1024).decode() |
no test coverage detected