add log

server/node.go

@@ -142,38 +142,43 @@ func (n *Node) Loop(idx int) {
 			client.Close()
 			return
 
-		case task := <-taskCh:
-			log.WithField("task", task).Info("get task")
-			for {
-				worker, err := PopWorker(n.rdb)
-				if err == ErrNoWorker {
-					result := &odysseus.TaskResponse{
-						TaskUuid:      task.TaskUuid,
-						TaskUid:       task.TaskUid,
-						TaskFee:       task.TaskFee,
-						TaskIsSucceed: false,
-						TaskError:     err.Error(),
+		case t := <-taskCh:
+			go func(task *odysseus.TaskContent) {
+				l := log.WithField("task-id", task.TaskId)
+				l.WithField("task", task).Info("get task")
+				for {
+					worker, err := PopWorker(n.rdb)
+					if err == ErrNoWorker {
+						result := &odysseus.TaskResponse{
+							TaskUuid:      task.TaskUuid,
+							TaskUid:       task.TaskUid,
+							TaskFee:       task.TaskFee,
+							TaskIsSucceed: false,
+							TaskError:     err.Error(),
+						}
+						l.WithError(err).Error("pop worker failed")
+						postReceipt(task, result, err)
+						err = postResult(task, result)
+						if err != nil {
+							l.WithError(err).Error("post task result failed")
+						}
+						break
 					}
-					postReceipt(task, result, err)
-					err = postResult(task, result)
+
 					if err != nil {
-						log.WithError(err).Error("post task result failed")
+						l.WithError(err).Error("pop worker failed")
+						continue
+					}
+					err = DispatchTask(worker, task)
+					if err != nil {
+						l.WithError(err).Error("dispatch task failed")
+						continue
+					} else {
+						l.WithField("task-id", task.TaskId).Info("dispatch task success")
+						break
 					}
-					break
-				}
-
-				if err != nil {
-					log.WithError(err).Error("pop worker failed")
-					continue
-				}
-				err = DispatchTask(worker, task)
-				if err != nil {
-					log.WithError(err).Error("dispatch task failed")
-					continue
-				} else {
-					break
 				}
-			}
+			}(t)
 
 		}
 	}