From bd5ebf9a5da1455c1fd62d177185daef4d9c9a25 Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Mon, 6 Oct 2025 18:34:45 -0500 Subject: [PATCH] fix: broadcast listener default --- node/worker/manager.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/node/worker/manager.go b/node/worker/manager.go index 0d78c5a..d79db3e 100644 --- a/node/worker/manager.go +++ b/node/worker/manager.go @@ -6,6 +6,7 @@ import ( "fmt" "os" "os/exec" + "strings" "sync" "time" @@ -553,6 +554,10 @@ func (w *WorkerManager) getMultiaddrOfWorker(coreId uint) ( rpcMultiaddr = w.config.Engine.DataWorkerStreamMultiaddrs[coreId-1] } + rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0.0.0.0/", "/127.0.0.1/", 1) + rpcMultiaddr = strings.Replace(rpcMultiaddr, "/0:0:0:0:0:0:0:0/", "/::1/", 1) + rpcMultiaddr = strings.Replace(rpcMultiaddr, "/::/", "/::1/", 1) + ma, err := multiaddr.StringCast(rpcMultiaddr) return ma, errors.Wrap(err, "get multiaddr of worker") } @@ -651,6 +656,7 @@ func (w *WorkerManager) getIPCOfWorker(coreId uint) ( grpc.WithTransportCredentials(creds), ) if err != nil { + return nil, errors.Wrap(err, "get ipc of worker") }