update log

server/workerManager.go

@@ -397,12 +397,16 @@ func (wm *WorkerManager) manageWorker(worker *Worker) error {
 			}
 		case result := <-worker.resultCh:
 			log.WithFields(log.Fields{
-				"task":        result.TaskId,
-				"worker addr": worker.workerAddr,
-				"success":     result.IsSuccessed,
-				"result code": result.TaskExecuteCode,
-				"duration":    result.TaskExecuteDuration / 1000,
+				"task":          result.TaskId,
+				"worker addr":   worker.workerAddr,
+				"success":       result.IsSuccessed,
+				"result code":   result.TaskExecuteCode,
+				"duration":      result.TaskExecuteDuration / 1000,
+				"result length": result.TaskResultBody,
 			}).Info("got result from worker")
+			if result.TaskExecuteCode == 303 {
+				log.WithField("result data", result.TaskResultBody).WithField("task", result.TaskId).Info("got worker result body")
+			}
 			// verify result and make a new signature.
 			data, exist := worker.recentTask.Get(result.TaskId)
 			if !exist {