fix bug

server/workerManager.go

@@ -435,7 +435,6 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 			wmsg, err := worker.stream.Recv()
 			if err != nil {
 				l.WithError(err).WithField("worker-addr", worker.workerAddr).Error("recv msg failed")
-				close(worker.quit)
 				return
 			}
 			worker.online = true
@@ -478,7 +477,6 @@ func (wm *WorkerManager) handleWorkerMsg(worker *Worker) {
 				if worker.workerAddr == "" {
 					if w := wm.GetWorkerByAddr(addr); w != nil {
 						log.WithField("worker-addr", addr).Error("worker with the address is existed")
-						close(worker.quit)
 						return
 					}
 				}