milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix master service 

Signed-off-by: neza2017 <yefu.chen@zilliz.com>
pull/4973/head^2
neza2017 2021-03-29 09:50:52 +08:00 committed by yefu.chen
parent ad0ad5e767
commit 71614313b0
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
internal/distributed/masterservice/server.go
View File

@ -230,19 +230,29 @@ func (s *Server) Stop() error {
}
}
if s.proxyService != nil {
_ = s.proxyService.Stop()
if err := s.proxyService.Stop(); err != nil {
log.Debug("close proxyService client", zap.Error(err))
}
}
if s.indexService != nil {
_ = s.indexService.Stop()
if err := s.indexService.Stop(); err != nil {
log.Debug("close indexService client", zap.Error(err))
}
}
if s.dataService != nil {
_ = s.dataService.Stop()
if err := s.dataService.Stop(); err != nil {
log.Debug("close dataService client", zap.Error(err))
}
}
if s.queryService != nil {
_ = s.queryService.Stop()
if err := s.queryService.Stop(); err != nil {
log.Debug("close queryService client", zap.Error(err))
}
}
if s.masterService != nil {
return s.masterService.Stop()
if err := s.masterService.Stop(); err != nil {
log.Debug("close masterService", zap.Error(err))
}
}
s.cancel()
if s.grpcServer != nil {