Add log when server is stopped (#12233)

Signed-off-by: Nxiaofan-luan <xiaofan.luan@zilliz.com>

internal/distributed/datacoord/service.go

@@ -167,6 +167,7 @@ func (s *Server) start() error {
 // Stop stops the DataCoord server gracefully.
 // Need to call the GracefulStop interface of grpc server and call the stop method of the inner DataCoord object.
 func (s *Server) Stop() error {
+	log.Debug("Datacoord stop", zap.String("Address", Params.Address))
 	var err error
 	if s.closer != nil {
 		if err = s.closer.Close(); err != nil {

internal/distributed/datanode/service.go

@@ -151,6 +151,7 @@ func (s *Server) Run() error {
 }
 
 func (s *Server) Stop() error {
+	log.Debug("Datanode stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
 			return err

internal/distributed/indexcoord/service.go

@@ -114,6 +114,7 @@ func (s *Server) start() error {
 
 // Stop stops IndexCoord's grpc service.
 func (s *Server) Stop() error {
+	log.Debug("Indexcoord stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
 			return err

internal/distributed/indexnode/service.go

@@ -168,6 +168,7 @@ func (s *Server) start() error {
 
 // Stop stops IndexNode's grpc service.
 func (s *Server) Stop() error {
+	log.Debug("IndexNode stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
 			return err

internal/distributed/proxy/service.go

@@ -269,6 +269,7 @@ func (s *Server) start() error {
 
 // Stop stop the Proxy Server
 func (s *Server) Stop() error {
+	log.Debug("Proxy stop", zap.String("Address", Params.Address))
 	var err error
 	if s.closer != nil {
 		if err = s.closer.Close(); err != nil {

internal/distributed/querycoord/service.go

@@ -266,6 +266,7 @@ func (s *Server) start() error {
 
 // Stop stops QueryCoord's grpc service.
 func (s *Server) Stop() error {
+	log.Debug("QueryCoord stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
 			return err

internal/distributed/querynode/service.go

@@ -251,6 +251,7 @@ func (s *Server) Run() error {
 
 // Stop stops QueryNode's grpc service.
 func (s *Server) Stop() error {
+	log.Debug("QueryNode stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
 			return err

internal/distributed/rootcoord/service.go

@@ -264,31 +264,33 @@ func (s *Server) start() error {
 }
 
 func (s *Server) Stop() error {
+	log.Debug("Rootcoord stop", zap.String("Address", Params.Address))
 	if s.closer != nil {
 		if err := s.closer.Close(); err != nil {
-			log.Error("close opentracing", zap.Error(err))
+			log.Error("Failed to close opentracing", zap.Error(err))
 		}
 	}
 	if s.indexCoord != nil {
 		if err := s.indexCoord.Stop(); err != nil {
-			log.Debug("close indexCoord client", zap.Error(err))
+			log.Error("Failed to close indexCoord client", zap.Error(err))
 		}
 	}
 	if s.dataCoord != nil {
 		if err := s.dataCoord.Stop(); err != nil {
-			log.Debug("close dataCoord client", zap.Error(err))
+			log.Error("Failed to close dataCoord client", zap.Error(err))
 		}
 	}
 	if s.queryCoord != nil {
 		if err := s.queryCoord.Stop(); err != nil {
-			log.Debug("close queryCoord client", zap.Error(err))
+			log.Error("Failed to close queryCoord client", zap.Error(err))
 		}
 	}
 	if s.rootCoord != nil {
 		if err := s.rootCoord.Stop(); err != nil {
-			log.Debug("close rootCoord", zap.Error(err))
+			log.Error("Failed to close close rootCoord", zap.Error(err))
 		}
 	}
+	log.Debug("Rootcoord begin to stop grpc server")
 	s.cancel()
 	if s.grpcServer != nil {
 		s.grpcServer.GracefulStop()