handler container resp is nil

nm/start.go

@@ -317,6 +317,7 @@ func handlerMsg(nodeManager *models.NodeManagerClient,
 								taskExecRes.TaskExecError = fmt.Sprintf("%s-%s", "Container sign failed", taskExecRes.TaskExecError)
 							}
 						} else {
+							isSuccess = false
 							taskExecRes.TaskExecError = fmt.Sprintf("%s-%s", "Task exec error", taskExecRes.TaskExecError)
 						}
 						reqHash, respHash, minerSign := taskMsgWorker.GetMinerSign(taskMsg, taskExecRes.TaskRespBody)

nm/task_msg.go

@@ -104,9 +104,7 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 		TaskExecTime:       0,
 		TaskExecError:      "",
 	}
-	t.Mutex.Lock()
 	t.LruCache.Add(taskMsg.TaskId, taskExecResult)
-	t.Mutex.Unlock()
 	taskCmd := &models.TaskCmd{}
 	err := json.Unmarshal(bytes.NewBufferString(taskMsg.TaskCmd).Bytes(), taskCmd)
 	if err != nil {
@@ -295,6 +293,12 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 								apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
 								taskExecResult.TaskRespBody = apiResBody
 							}
+							if len(apiRes) == 0 || len(apiRes[0]) == 0 {
+								log.Warn("Container resp output is nil")
+								taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp output is nil")
+								t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
+								return
+							}
 						}
 					case []string:
 						{
@@ -330,6 +334,12 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 								apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
 								taskExecResult.TaskRespBody = apiResBody
 							}
+							if len(apiRes) == 0 {
+								log.Warn("Container resp output is nil")
+								taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp output is nil")
+								t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
+								return
+							}
 						}
 					case string:
 						{
@@ -366,20 +376,23 @@ func (t *TaskHandler) ComputeTaskHandler(taskMsg *nodeManagerV1.PushTaskMessage)
 								apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
 								taskExecResult.TaskRespBody = apiResBody
 							}
+							if len(apiRes) == 0 {
+								log.Warn("Container resp output is nil")
+								taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp output is nil")
+								t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
+								return
+							}
 						}
 					default:
 						log.Error("data is unknown type", v)
 						taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp data is unknown type")
-						apiRes := make([]string, 0)
-						apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
-						taskExecResult.TaskRespBody = apiResBody
+						t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
+						return
 					}
 				} else {
-					taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp ouput is nil")
+					log.Error("Container resp output is nil")
+					taskExecResult.TaskExecError = fmt.Sprintf("worker:%s,%s", conf.GetConfig().SignPublicAddress.Hex(), "Container resp output is nil")
 					t.ExecTaskIdIsSuccess.Store(taskMsg.TaskId, true)
-					apiRes := make([]string, 0)
-					apiResBody := utils.EncodeJsonEscapeHTML(apiRes)
-					taskExecResult.TaskRespBody = apiResBody
 					return
 				}
 			}