Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions lightllm/server/api_http.py
Original file line number Diff line number Diff line change
Expand Up @@ -300,7 +300,7 @@ async def register_and_keep_alive(websocket: WebSocket):
client_ip, client_port = websocket.client
logger.info(f"Client connected from IP: {client_ip}, Port: {client_port}")
regist_json = json.loads(await websocket.receive_text())
logger.info(f"recieved regist_json {regist_json}")
logger.info(f"received regist_json {regist_json}")
await g_objs.httpserver_manager.register_pd(regist_json, websocket)

try:
Expand Down Expand Up @@ -329,7 +329,7 @@ async def kv_move_status(websocket: WebSocket):
# 等待接收消息,设置超时为10秒
data = await websocket.receive_bytes()
upkv_status = pickle.loads(data)
logger.info(f"recieved upkv_status {upkv_status} from {(client_ip, client_port)}")
logger.info(f"received upkv_status {upkv_status} from {(client_ip, client_port)}")
await g_objs.httpserver_manager.update_req_status(upkv_status)
except (WebSocketDisconnect, Exception, RuntimeError) as e:
logger.error(f"kv_move_status client {(client_ip, client_port)} has error {str(e)}")
Expand Down
2 changes: 1 addition & 1 deletion lightllm/server/config_server/api_http.py
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ async def websocket_endpoint(websocket: WebSocket):
client_ip, client_port = websocket.client
logger.info(f"ws connected from IP: {client_ip}, Port: {client_port}")
registered_pd_master_obj: PD_Master_Obj = pickle.loads(await websocket.receive_bytes())
logger.info(f"recieved registered_pd_master_obj {registered_pd_master_obj}")
logger.info(f"received registered_pd_master_obj {registered_pd_master_obj}")
with registered_pd_master_obj_lock:
registered_pd_master_objs[registered_pd_master_obj.node_id] = registered_pd_master_obj

Expand Down
2 changes: 1 addition & 1 deletion lightllm/server/httpserver/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -415,7 +415,7 @@ async def _log_req_header(self, request_headers, group_request_id: int):

format_in_time = datetime.datetime.fromtimestamp(time.time()).strftime("%Y-%m-%d %H:%M:%S")
logger.info(
f"recieved req X-Request-Id:{x_request_id} "
f"received req X-Request-Id:{x_request_id} "
f"X-Session-Id:{x_session_id} start_time:{format_in_time} "
f"lightllm_req_id:{group_request_id} "
)
Expand Down
2 changes: 1 addition & 1 deletion lightllm/server/httpserver_for_pd_master/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -137,7 +137,7 @@ async def _log_req_header(self, request: Request, group_request_id: int):
x_session_id = request.headers.get("X-Session-Id", "")
format_in_time = datetime.datetime.fromtimestamp(time.time()).strftime("%Y-%m-%d %H:%M:%S")
logger.info(
f"recieved req X-Request-Id:{x_request_id} "
f"received req X-Request-Id:{x_request_id} "
f"X-Session-Id:{x_session_id} start_time:{format_in_time} "
f"lightllm_req_id:{group_request_id} "
)
Expand Down