update

server/dispatchTask.go

@@ -10,17 +10,20 @@ import (
 )
 
 type dispatchTask struct {
-	worker *Worker
-	task   *odysseus.TaskContent
-	status TaskStatus
-	ack    chan interface{}
-	errCh  chan error
-	mux    sync.Mutex
-	result chan *omanager.SubmitTaskResult
+	create     time.Time
+	resultTime time.Time
+	worker     *Worker
+	task       *odysseus.TaskContent
+	status     TaskStatus
+	ack        chan interface{}
+	errCh      chan error
+	mux        sync.Mutex
+	result     chan *omanager.SubmitTaskResult
 }
 
 func newDispatchTask(w *Worker, task *odysseus.TaskContent) *dispatchTask {
 	return &dispatchTask{
+		create: time.Now(),
 		worker: w,
 		task:   task,
 		status: TASK_CREATE,
@@ -98,7 +101,6 @@ func (d *dispatchTask) finalize(wm *WorkerManager) {
 	var result *omanager.SubmitTaskResult
 	select {
 	case <-ticker.C:
-		l.WithField("worker", d.worker.workerAddr).Info("task timeout")
 		d.setStatus(TASK_TIMEOUT)
 		result = &omanager.SubmitTaskResult{
 			TaskId:              d.task.TaskId,
@@ -108,10 +110,14 @@ func (d *dispatchTask) finalize(wm *WorkerManager) {
 		}
 
 	case r := <-d.result:
-		l.WithField("worker", d.worker.workerAddr).Info("task finished")
 		d.setStatus(TASK_FINISHED)
 		result = r
 	}
+	d.resultTime = time.Now()
+	l.WithFields(log.Fields{
+		"totaltime": d.resultTime.Sub(d.create).Milliseconds(),
+		"status":    d.status,
+	}).Debug("task finished")
 
 	task := d.task
 	if task.TaskKind != odysseus.TaskKind_StandardTask && d.worker.online == true {