[P/D] Mooncake connector support more protocols (#30133)

Signed-off-by: LCAIZJ <leichao139636@163.com>
This commit is contained in:
Chao Lei 2025-12-24 10:24:07 +08:00 committed by GitHub
parent 538e830caa
commit 8b59753cdb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -408,7 +408,13 @@ class MooncakeConnectorWorker:
self.engine = TransferEngine()
self.hostname = get_ip()
ret_value = self.engine.initialize(self.hostname, "P2PHANDSHAKE", "rdma", "")
protocol = self.vllm_config.kv_transfer_config.kv_connector_extra_config.get( # type: ignore[union-attr]
"mooncake_protocol", "rdma"
)
logger.info(
"The Mooncake Transfer Engine is using %s as its protocol.", protocol
)
ret_value = self.engine.initialize(self.hostname, "P2PHANDSHAKE", protocol, "")
if ret_value != 0:
raise RuntimeError("Mooncake Transfer Engine initialization failed.")