add log for kad connect.

pkg/node/node.go

@@ -758,43 +758,57 @@ func NewBee(addr string, publicKey *ecdsa.PublicKey, signer crypto.Signer, netwo
 		}
 
 		debugAPIService.MustRegisterMetrics(pushSyncProtocol.Metrics()...)
+		logger.Debugf("pushSyncProtocol register")
 		debugAPIService.MustRegisterMetrics(pusherService.Metrics()...)
+		logger.Debugf("pusherService register")
 		debugAPIService.MustRegisterMetrics(pullSyncProtocol.Metrics()...)
+		logger.Debugf("pullSyncProtocol register")
 		debugAPIService.MustRegisterMetrics(pullStorage.Metrics()...)
+		logger.Debugf("pullStorage register")
 		debugAPIService.MustRegisterMetrics(retrieve.Metrics()...)
+		logger.Debugf("retrieve register")
 		debugAPIService.MustRegisterMetrics(lightNodes.Metrics()...)
+		logger.Debugf("lightNodes register")
 		debugAPIService.MustRegisterMetrics(hive.Metrics()...)
+		logger.Debugf("hive register")
 
 		if bs, ok := batchStore.(metrics.Collector); ok {
+			logger.Debugf("batchStore register")
 			debugAPIService.MustRegisterMetrics(bs.Metrics()...)
 		}
 
 		if eventListener != nil {
 			if ls, ok := eventListener.(metrics.Collector); ok {
+				logger.Debugf("eventListener register")
 				debugAPIService.MustRegisterMetrics(ls.Metrics()...)
 			}
 		}
 
 		if pssServiceMetrics, ok := pssService.(metrics.Collector); ok {
+			logger.Debugf("pssServiceMetrics register")
 			debugAPIService.MustRegisterMetrics(pssServiceMetrics.Metrics()...)
 		}
 
 		if apiService != nil {
+			logger.Debugf("apiService register")
 			debugAPIService.MustRegisterMetrics(apiService.Metrics()...)
 		}
 		if l, ok := logger.(metrics.Collector); ok {
+			logger.Debugf("Collector register")
 			debugAPIService.MustRegisterMetrics(l.Metrics()...)
 		}
-
+		logger.Debugf("pseudosettleService register")
 		debugAPIService.MustRegisterMetrics(pseudosettleService.Metrics()...)
 
 		if swapService != nil {
+			logger.Debugf("swapService register")
 			debugAPIService.MustRegisterMetrics(swapService.Metrics()...)
 		}
 
 		// inject dependencies and configure full debug api http path routes
 		debugAPIService.Configure(swarmAddress, p2ps, pingPong, kad, lightNodes, storer, tagService, acc, pseudosettleService, o.SwapEnable, swapService, chequebookService, batchStore, post, postageContractService, traversalService)
 	}
+	logger.Debugf("kad start ")
 
 	if err := kad.Start(p2pCtx); err != nil {
 		return nil, err

pkg/topology/kademlia/kademlia.go

@@ -480,9 +480,11 @@ func (k *Kad) connectionAttemptsHandler(ctx context.Context, wg *sync.WaitGroup,
 
 // notifyManageLoop notifies kademlia manage loop.
 func (k *Kad) notifyManageLoop() {
+	k.logger.Debugf("kad notifyManageLoop")
 	select {
 	case k.manageC <- struct{}{}:
 	default:
+		k.logger.Errorf("k.manageC fulled")
 	}
 }