diff --git a/cmd/openim-api/main.go b/cmd/openim-api/main.go index 7f9c71a4d..c8746bc20 100644 --- a/cmd/openim-api/main.go +++ b/cmd/openim-api/main.go @@ -85,7 +85,7 @@ func run(port int, proPort int) error { go func() { p := ginprom.NewPrometheus("app", prommetrics.GetGinCusMetrics("Api")) p.SetListenAddress(fmt.Sprintf(":%d", proPort)) - if err := p.Use(router); err != nil && err != http.ErrServerClosed { + if err = p.Use(router); err != nil && err != http.ErrServerClosed { netErr = errs.Wrap(err, fmt.Sprintf("prometheus start err: %d", proPort)) netDone <- struct{}{} } diff --git a/pkg/common/startrpc/start.go b/pkg/common/startrpc/start.go index ec4dee6df..6ae76604d 100644 --- a/pkg/common/startrpc/start.go +++ b/pkg/common/startrpc/start.go @@ -149,6 +149,7 @@ func Start( if err != nil { return errs.Wrap(err, "shutdown err") } + return errors.New("SIGTERM received, shutting down") case <-netDone: close(netDone) return netErr