Browse Source

Merge pull request #7768 from gyuho/close-serverc

embed: signal 'grpcServerC' before cmux serve
Gyu-Ho Lee 8 years ago
parent
commit
385e18bc6c
1 changed files with 1 additions and 2 deletions
  1. 1 2
      embed/serve.go

+ 1 - 2
embed/serve.go

@@ -74,8 +74,6 @@ func (sctx *serveCtx) serve(s *etcdserver.EtcdServer, tlscfg *tls.Config, handle
 	servElection := v3election.NewElectionServer(v3c)
 	servElection := v3election.NewElectionServer(v3c)
 	servLock := v3lock.NewLockServer(v3c)
 	servLock := v3lock.NewLockServer(v3c)
 
 
-	defer close(sctx.grpcServerC)
-
 	if sctx.insecure {
 	if sctx.insecure {
 		gs := v3rpc.Server(s, nil)
 		gs := v3rpc.Server(s, nil)
 		sctx.grpcServerC <- gs
 		sctx.grpcServerC <- gs
@@ -140,6 +138,7 @@ func (sctx *serveCtx) serve(s *etcdserver.EtcdServer, tlscfg *tls.Config, handle
 		plog.Infof("serving client requests on %s", sctx.l.Addr().String())
 		plog.Infof("serving client requests on %s", sctx.l.Addr().String())
 	}
 	}
 
 
+	close(sctx.grpcServerC)
 	return m.Serve()
 	return m.Serve()
 }
 }