fix: broadcast listener default

This commit is contained in:
Cassandra Heart 2025-10-06 18:34:45 -05:00
parent daf10a648d
commit bd5ebf9a5d
No known key found for this signature in database
GPG Key ID: 371083BFA6C240AA

View File

@ -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")
}