add log for worker

cmd/demoworker/main.go

@@ -83,6 +83,7 @@ func withManager(idx int, endpoint string) {
 				if !ok {
 					return
 				}
+				log.WithField("endpoint", endpoint).Info("got task in channel")
 				demoResult := "a demo task result return"
 				msg := &omanager.WorkerMessage{
 					Message: &omanager.WorkerMessage_SubmitTaskResult{
@@ -97,7 +98,9 @@ func withManager(idx int, endpoint string) {
 					},
 				}
 				if err := managerClient.Send(msg); err != nil {
-					log.WithField("endpoint", endpoint).Fatal("response device info failed", "err", err)
+					log.WithField("endpoint", endpoint).WithError(err).Error("send task result failed")
+				} else {
+					log.WithField("endpoint", endpoint).Info("send task result")
 				}
 
 			}

server/workerManager.go

@@ -174,7 +174,7 @@ func (wm *WorkerManager) AddNewWorker(id int64, worker omanager.NodeManagerServi
 	w := &Worker{
 		quit:     make(chan interface{}),
 		taskCh:   make(chan *dispatchTask),
-		resultCh: make(chan *omanager.SubmitTaskResult),
+		resultCh: make(chan *omanager.SubmitTaskResult, 10),
 
 		uuid:     id,
 		registed: false,