update nm status

nm/start.go

@@ -11,7 +11,6 @@ import (
 	"fmt"
 	nodeManagerV1 "github.com/odysseus/odysseus-protocol/gen/proto/go/nodemanager/v1"
 	"google.golang.org/grpc"
-	"io"
 	"time"
 )
 
@@ -27,7 +26,7 @@ var (
 func init() {
 	nodeManagerArr = make([]*NodeManager, 0)
 	usedNodeManagerClient = make([]*models.NodeManagerClient, 0)
-	nodeManagerClientChan = make(chan *models.NodeManagerClient, 0)
+	nodeManagerClientChan = make(chan *models.NodeManagerClient, 10)
 	nodeManagerMsgChan = make(chan *nodeManagerV1.ManagerMessage, 1000)
 }
 
@@ -209,16 +208,6 @@ func monitorWorker(op *operate.DockerOp) {
 						return
 					}
 					rev, err := worker.Recv()
-					if err == io.EOF {
-						log.Errorf("Node manage not work endpoint:%s", nodeManager.Endpoint)
-						params := buildParams(fmt.Sprintf("Node manage not work endpoint:%s", nodeManager.Endpoint))
-						msgRespWorker.RegisterMsgResp(nodeManager, worker, GoodbyeResp, params)
-						if nodeManager.Status {
-							nodeManager.UpdateStatus(false)
-						}
-						log.Error("Received nm msg failed:%s", err)
-						return
-					}
 					if err != nil {
 						log.Error("Rev failed:", err)
 						params := buildParams(fmt.Sprintf("Rev failed:%s", err.Error()))