MCPcopy Create free account
hub / github.com/ModelEngine-Group/flexai / handle_message

Function handle_message

GPU-Virtual-Service/gpu-remoting/monitor.py:262–280  ·  view source on GitHub ↗
(conn, data, addr)

Source from the content-addressed store, hash-verified

260 update_gpu_info()
261 handle_new_job(data)
262 else:
263 logging.info(f"Unknown message from server")
264
265
266def 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
280def handle_server_tcp(conn, addr):
281 logging.info(f"Accepted connection from {addr}")
282 while True:
283 data = conn.recv(1024).decode()

Callers 2

handle_serverFunction · 0.70
handle_server_tcpFunction · 0.70

Calls 3

update_gpu_infoFunction · 0.85
reduce_gpu_jobFunction · 0.85
handle_new_jobFunction · 0.85

Tested by

no test coverage detected