coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 10:27:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

force TCP for stream multiaddr

Browse Source
This commit is contained in:
Black Swan 2025-12-11 03:15:01 +02:00
parent 0425b38fa2
commit c77fd88ca2
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
node/main.go
View File

@ -521,6 +521,13 @@ func main() {
rpcMultiaddr = nodeConfig.Engine.DataWorkerStreamMultiaddrs[*core-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)
// force TCP as stream is not supported over UDP/QUIC
rpcMultiaddr = strings.Replace(rpcMultiaddr, "/quic-v1", "", 1)
rpcMultiaddr = strings.Replace(rpcMultiaddr, "udp", "tcp", 1)
dataWorkerNode, err := app.NewDataWorkerNode(
logger,
nodeConfig,

3
node/worker/manager.go
View File

@ -817,6 +817,9 @@ func (w *WorkerManager) getMultiaddrOfWorker(coreId uint) (
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)
// force TCP as stream is not supported over UDP/QUIC
rpcMultiaddr = strings.Replace(rpcMultiaddr, "/quic-v1", "", 1)
rpcMultiaddr = strings.Replace(rpcMultiaddr, "udp", "tcp", 1)
ma, err := multiaddr.StringCast(rpcMultiaddr)
return ma, errors.Wrap(err, "get multiaddr of worker")