优化服务器无法正常退出问题
This commit is contained in:
parent
5abb539bd0
commit
aeade860be
|
@ -371,11 +371,11 @@ func (slf *Server) Shutdown(err error, stack ...string) {
|
||||||
}
|
}
|
||||||
log.ErrorWithStack("Server", s, zap.Any("network", slf.network), zap.String("listen", slf.addr),
|
log.ErrorWithStack("Server", s, zap.Any("network", slf.network), zap.String("listen", slf.addr),
|
||||||
zap.String("action", "shutdown"), zap.String("state", "exception"), zap.Error(err))
|
zap.String("action", "shutdown"), zap.String("state", "exception"), zap.Error(err))
|
||||||
slf.closeChannel <- struct{}{}
|
|
||||||
} else {
|
} else {
|
||||||
log.Info("Server", zap.Any("network", slf.network), zap.String("listen", slf.addr),
|
log.Info("Server", zap.Any("network", slf.network), zap.String("listen", slf.addr),
|
||||||
zap.String("action", "shutdown"), zap.String("state", "normal"))
|
zap.String("action", "shutdown"), zap.String("state", "normal"))
|
||||||
}
|
}
|
||||||
|
slf.closeChannel <- struct{}{}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (slf *Server) GRPCServer() *grpc.Server {
|
func (slf *Server) GRPCServer() *grpc.Server {
|
||||||
|
|
Loading…
Reference in New Issue