From 3554015b0e000fb078cf6bde82cb648b87bfb74f Mon Sep 17 00:00:00 2001 From: licunlong Date: Tue, 9 Sep 2025 09:48:12 +0800 Subject: [PATCH] [p2pstore] allow topologyMatrix to be empty (#807) when install tcp transport, nicPriorityMatrix is "". set args[0] to nil so that tcp transport can be installed --- mooncake-p2p-store/src/p2pstore/transfer_engine.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/mooncake-p2p-store/src/p2pstore/transfer_engine.go b/mooncake-p2p-store/src/p2pstore/transfer_engine.go index 00cdea31..91e1dd28 100644 --- a/mooncake-p2p-store/src/p2pstore/transfer_engine.go +++ b/mooncake-p2p-store/src/p2pstore/transfer_engine.go @@ -58,7 +58,11 @@ func (engine *TransferEngine) installTransport(protocol string, topologyMatrix s defer C.free(unsafe.Pointer(protocolCStr)) defer C.free(unsafe.Pointer(topologyMatrixCStr)) var args [2]unsafe.Pointer - args[0] = unsafe.Pointer(topologyMatrixCStr) + if len(topologyMatrix) == 0 { + args[0] = nil + } else { + args[0] = unsafe.Pointer(topologyMatrixCStr) + } args[1] = nil xport := C.installTransport(engine.engine, protocolCStr, &args[0]) if xport == nil {