update send msg time

nm/start.go

@@ -164,6 +164,7 @@ func monitorWorker(op *operate.DockerOp) {
 							}
 							ticker = time.NewTicker(time.Second * 20)
 							msgRespWorker.RegisterMsgResp(nodeManager, worker, RegisterInfoResp, nil)
+							time.Sleep(time.Second * 2)
 							msgRespWorker.RegisterMsgResp(nodeManager, worker, DeviceInfoResp, nil)
 							isSend = true
 							log.Info("------------------------Send once-off message ended------------------------")
@@ -176,12 +177,12 @@ func monitorWorker(op *operate.DockerOp) {
 				log.Info("Report model info started")
 
 				// 证明存储
-				go proofWorker.ProofStorage()
-				log.Info("Proof storage worker started")
+				//go proofWorker.ProofStorage()
+				//log.Info("Proof storage worker started")
 
 				// 证明提交
-				go proofWorker.CommitWitness()
-				log.Info("Proof commit worker started")
+				//go proofWorker.CommitWitness()
+				//log.Info("Proof commit worker started")
 
 				go handlerStandardTask(nodeManager, worker, msgRespWorker, taskMsgWorker)
 				log.Info("Handler standard task worker started")
@@ -307,25 +308,25 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
 
 				nmResultMsg := rev.GetProofTaskResult()
 				if nmResultMsg != nil {
-					containerSign, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.ContainerSign)
+					//containerSign, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.ContainerSign)
 					//if !ok {
 					//	log.Error("taskMsgWorker.LruCache.Get failed: ", nmSignMsg.TaskUuid+models.ContainerSign)
 					//}
-					minerSign, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.MinerSign)
+					//minerSign, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.MinerSign)
 					//if !ok {
 					//	log.Error("taskMsgWorker.LruCache.Get failed: ", nmSignMsg.TaskUuid+models.MinerSign)
 					//}
-					reqHash, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.ReqHash)
+					//reqHash, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.ReqHash)
 					//if !ok {
 					//	log.Error("taskMsgWorker.LruCache.Get failed: ", nmSignMsg.TaskUuid+models.ReqHash)
 					//}
-					respHash, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.RespHash)
+					//respHash, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.RespHash)
 					//if !ok {
 					//	log.Error("taskMsgWorker.LruCache.Get failed: ", nmSignMsg.TaskUuid+models.RespHash)
 					//}
-					taskType, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.TaskType)
-					proofWorker.ProductProof(nmResultMsg, taskType.(uint64), reqHash.([]byte), respHash.([]byte), containerSign.([]byte), minerSign.([]byte))
-					log.Info(nmResultMsg)
+					//taskType, _ := taskMsgWorker.LruCache.Get(nmResultMsg.TaskId + models.TaskType)
+					//proofWorker.ProductProof(nmResultMsg, taskType.(uint64), reqHash.([]byte), respHash.([]byte), containerSign.([]byte), minerSign.([]byte))
+					log.WithField("proof", nmResultMsg).Info("Output proof task result")
 					continue
 				}