update

server/worker.go

 package server
 
 import (
+	"errors"
 	"github.com/ethereum/go-ethereum/common"
 	lru "github.com/hashicorp/golang-lru"
 	omanager "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
@@ -111,7 +112,7 @@ func (w *Worker) RecvMessage() {
 		wmsg, err := w.stream.Recv()
 		if err != nil {
 			l.WithError(err).WithField("worker-addr", w.workerAddr).WithField("recv duration", time.Now().Sub(start).String()).Error("recv msg failed")
-			w.quit <- "recv msg failed"
+			w.errCh <- errors.New("recv msg failed")
 			return
 		}
 		if w.DisConnected() {