From 8f7500f718bdb49a1c466e15a38451442e63d53b Mon Sep 17 00:00:00 2001 From: 0oshowero0 Date: Sat, 28 Mar 2026 11:24:43 +0800 Subject: [PATCH 1/2] add master server port during init Signed-off-by: 0oshowero0 --- transfer_queue/interface.py | 31 ++++++++++++++++++++++++------- 1 file changed, 24 insertions(+), 7 deletions(-) diff --git a/transfer_queue/interface.py b/transfer_queue/interface.py index 14fcd22..a49ffbd 100644 --- a/transfer_queue/interface.py +++ b/transfer_queue/interface.py @@ -111,20 +111,36 @@ def _maybe_create_transferqueue_storage(conf: DictConfig) -> DictConfig: else: raise RuntimeError(f"Failed to kill existing mooncake_master processes (exit code: {result}).") - raw_address = conf.backend.MooncakeStore.metadata_server - if "://" not in raw_address: - raw_address = "//" + raw_address + # process metadata_server + metadata_server_raw_address = conf.backend.MooncakeStore.metadata_server + if "://" not in metadata_server_raw_address: + metadata_server_raw_address = "//" + metadata_server_raw_address - parsed = urlparse(raw_address) + metadata_server_parsed = urlparse(metadata_server_raw_address) - if not parsed.hostname or parsed.port is None: + if not metadata_server_parsed.hostname or metadata_server_parsed.port is None: raise ValueError( f"Invalid metadata_server '{conf.backend.MooncakeStore.metadata_server}'. " f"Host and port are required (e.g., host:port)." ) - metadata_server_host = parsed.hostname - metadata_server_port = str(parsed.port) + metadata_server_host = metadata_server_parsed.hostname + metadata_server_port = str(metadata_server_parsed.port) + + # process master_server + master_server_raw_address = conf.backend.MooncakeStore.master_server_address + if "://" not in master_server_raw_address: + master_server_raw_address = "//" + master_server_raw_address + + master_server_parsed = urlparse(master_server_raw_address) + + if not master_server_parsed.hostname or master_server_parsed.port is None: + raise ValueError( + f"Invalid master_server '{conf.backend.MooncakeStore.master_server_address}'. " + f"Host and port are required (e.g., host:port)." + ) + + master_server_port = str(master_server_parsed.port) cmd = [ "mooncake_master", @@ -136,6 +152,7 @@ def _maybe_create_transferqueue_storage(conf: DictConfig) -> DictConfig: "--allow_evict_soft_pinned_objects=false", f"--http_metadata_server_host={metadata_server_host}", f"--http_metadata_server_port={metadata_server_port}", + f"--rpc_port={master_server_port}", ] log_file_path = "/tmp/mooncake_master.log" From 636d2f02b28407b2b0e656ea60b5a1f351c8a736 Mon Sep 17 00:00:00 2001 From: 0oshowero0 Date: Sat, 28 Mar 2026 11:44:49 +0800 Subject: [PATCH 2/2] fix Signed-off-by: 0oshowero0 --- transfer_queue/interface.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/transfer_queue/interface.py b/transfer_queue/interface.py index a49ffbd..7e1e23a 100644 --- a/transfer_queue/interface.py +++ b/transfer_queue/interface.py @@ -136,7 +136,7 @@ def _maybe_create_transferqueue_storage(conf: DictConfig) -> DictConfig: if not master_server_parsed.hostname or master_server_parsed.port is None: raise ValueError( - f"Invalid master_server '{conf.backend.MooncakeStore.master_server_address}'. " + f"Invalid master_server_address '{conf.backend.MooncakeStore.master_server_address}'. " f"Host and port are required (e.g., host:port)." )