From 25fc33b7e5303d941d9bc7721da2a112c6036f04 Mon Sep 17 00:00:00 2001 From: Black Swan Date: Sun, 8 Dec 2024 05:20:18 +0200 Subject: [PATCH] enhance worker connection failure logging (#403) * log core number and multiaddr upon worker connection failure * adjust tag name --------- Co-authored-by: Cassandra Heart <7929478+CassOnMars@users.noreply.github.com> --- node/consensus/data/data_clock_consensus_engine.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/node/consensus/data/data_clock_consensus_engine.go b/node/consensus/data/data_clock_consensus_engine.go index 66a8804..b773c1c 100644 --- a/node/consensus/data/data_clock_consensus_engine.go +++ b/node/consensus/data/data_clock_consensus_engine.go @@ -940,7 +940,8 @@ func (e *DataClockConsensusEngine) createParallelDataClientsFromList() ( clients := make([]protobufs.DataIPCServiceClient, parallelism) for i := 0; i < parallelism; i++ { - ma, err := multiaddr.NewMultiaddr(e.config.Engine.DataWorkerMultiaddrs[i]) + wma := e.config.Engine.DataWorkerMultiaddrs[i] + ma, err := multiaddr.NewMultiaddr(wma) if err != nil { panic(err) } @@ -966,7 +967,7 @@ func (e *DataClockConsensusEngine) createParallelDataClientsFromList() ( grpc.WithBlock(), ) if err != nil { - e.logger.Error("could not dial", zap.Error(err)) + e.logger.Error("could not dial", zap.Int("core", i), zap.String("worker_multiaddr", wma), zap.Error(err)) continue }