add log print

nm/nm_operate.go

@@ -48,7 +48,7 @@ func getUnUsedNodeManagers() []*NodeManager {
 func isExistNodeManager(nodeManager *nodeManagerV1.NodeManagerInfo) bool {
 	for _, manager := range nodeManagerArr {
 		if nodeManager.Endpoint == manager.Info.Endpoint {
-			manager.Info.Publickey = nodeManager.Publickey
+			//manager.Info.Publickey = nodeManager.Publickey
 			return true
 		}
 	}

nm/start.go

@@ -140,12 +140,14 @@ func monitorWorker(op *operate.DockerOp) {
 				worker, err := nodeManager.Client.RegisterWorker(context.Background(), grpc.EmptyCallOption{})
 				if err != nil {
 					log.Error("Registration worker failed", err)
-					nodeManager.UpdateStatus(false)
+					if nodeManager.Status {
+						nodeManager.UpdateStatus(false)
+					}
 					return
 				}
 
 				msgRespWorker := NewMsgRespWorker()
-				for i := 0; i < 3; i++ {
+				for i := 0; i < 2; i++ {
 					go msgRespWorker.SendMsg()
 				}
 
@@ -191,7 +193,7 @@ func monitorWorker(op *operate.DockerOp) {
 				log.Info("Handler standard task worker started")
 
 				// 处理消息
-				for i := 0; i < 5; i++ {
+				for i := 0; i < 2; i++ {
 					go handlerMsg(nodeManager, worker, msgRespWorker, taskMsgWorker, proofWorker)
 				}
 
@@ -226,10 +228,9 @@ func monitorWorker(op *operate.DockerOp) {
 						}
 						return
 					}
-					log.Info("---------------------Received message---------------------")
+					log.Info("---------------------received message success---------------------")
 					nodeManagerMsgChan <- rev
-					log.Info("---------------------Send Received message success---------------------")
-					continue
+					log.Info("---------------------The message input channel success---------------------")
 				}
 			}(managerClient)
 		}