From 14f13ed6905c1bdacc9da12cc0c56bedfeb9e71e Mon Sep 17 00:00:00 2001 From: Robert Shaw Date: Sat, 19 Jul 2025 16:27:38 +0000 Subject: [PATCH] added debug logging Signed-off-by: Robert Shaw --- .../distributed/kv_transfer/kv_connector/v1/nixl_connector.py | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py index 0c5986bfafaa0..15dedcb48404e 100644 --- a/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py +++ b/vllm/distributed/kv_transfer/kv_connector/v1/nixl_connector.py @@ -874,6 +874,8 @@ class NixlConnectorWorker: Returns: set of req_ids that have all done xfers """ + current_time = time.perf_counter() + done_req_ids: set[str] = set() for req_id, handles in list(transfers.items()): in_progress = False @@ -881,6 +883,8 @@ class NixlConnectorWorker: xfer_state = self.nixl_wrapper.check_xfer_state(handle) if xfer_state == "DONE": self.nixl_wrapper.release_xfer_handle(handle) + logger.debug("[nixl] req_id: %s transfer time: %s", + req_id, current_time - _xfer_stime) elif xfer_state == "PROC": in_progress = True continue