diff --git a/third_party/vllm/vllm/distributed/kv_transfer/kv_connector/v1/mooncake/mooncake_connector.py b/third_party/vllm/vllm/distributed/kv_transfer/kv_connector/v1/mooncake/mooncake_connector.py index 7f234bc..a7abde2 100644 --- a/third_party/vllm/vllm/distributed/kv_transfer/kv_connector/v1/mooncake/mooncake_connector.py +++ b/third_party/vllm/vllm/distributed/kv_transfer/kv_connector/v1/mooncake/mooncake_connector.py @@ -422,6 +422,12 @@ class MooncakeConnectorScheduler: get_block_hash(k).hex() for k in removed_keys } self._known_hash_keys = current_keys.copy() + logger.info("hash_table_sync: +%d -%d (total known=%d)", + len(new_keys), len(removed_keys), len(self._known_hash_keys)) + else: + if not hasattr(self, '_bp_warned'): + logger.warning("_block_pool is None, hash table sync disabled") + self._bp_warned = True if not self.is_kv_consumer: for req_id, (req, block_ids) in self._reqs_need_send.items():