Skip to content

Commit 2dc6680

Browse files
authored
Merge branch 'master' into fix/test-otp-equals-delimiter
2 parents 338491f + 77f5918 commit 2dc6680

2 files changed

Lines changed: 11 additions & 12 deletions

File tree

cmd/serve_cmd.go

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -93,11 +93,11 @@ func serve(ctx context.Context) {
9393

9494
var err error
9595
defer func() {
96-
logFn := wrkLog.Info
97-
if err != nil {
98-
logFn = wrkLog.WithError(err).Error
96+
exitFn := wrkLog.Info
97+
if err != nil && !errors.Is(err, context.Canceled) {
98+
exitFn = wrkLog.WithError(err).Error
9999
}
100-
logFn("background apiworker is exiting")
100+
exitFn("background apiworker is exiting")
101101
}()
102102

103103
// Work exits when ctx is done as in-flight requests do not depend
@@ -125,7 +125,7 @@ func serve(ctx context.Context) {
125125
var err error
126126
defer func() {
127127
exitFn := le.Info
128-
if err != nil {
128+
if err != nil && !errors.Is(err, context.Canceled) {
129129
exitFn = le.WithError(err).Error
130130
}
131131
exitFn("config reloader is exiting")
@@ -162,9 +162,7 @@ func serve(ctx context.Context) {
162162
}
163163

164164
rl := reloader.NewReloader(rc, watchDir)
165-
if err = rl.Watch(ctx, fn); err != nil {
166-
log.WithError(err).Error("config reloader is exiting")
167-
}
165+
err = rl.Watch(ctx, fn)
168166
}()
169167
}
170168

internal/observability/metrics.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@ package observability
22

33
import (
44
"context"
5+
"errors"
56
"fmt"
67
"net"
78
"net/http"
@@ -69,17 +70,17 @@ func enablePrometheusMetrics(ctx context.Context, mc *conf.MetricsConfig) error
6970
shutdownCtx, shutdownCancel := context.WithTimeout(context.Background(), 5*time.Second)
7071
defer shutdownCancel()
7172

72-
if err := server.Shutdown(shutdownCtx); err != nil {
73+
if err := server.Shutdown(shutdownCtx); err != nil && !errors.Is(err, context.Canceled) {
7374
logrus.WithError(err).Errorf("prometheus server (%s) failed to gracefully shut down", addr)
7475
}
7576
}()
7677

7778
logrus.Infof("prometheus server listening on %s", addr)
7879

79-
if err := server.ListenAndServe(); err != nil {
80-
logrus.WithError(err).Errorf("prometheus server (%s) shut down", addr)
81-
} else {
80+
if err := server.ListenAndServe(); errors.Is(err, http.ErrServerClosed) {
8281
logrus.Info("prometheus metric exporter shut down")
82+
} else {
83+
logrus.WithError(err).Errorf("prometheus server (%s) shut down", addr)
8384
}
8485
}()
8586

0 commit comments

Comments
 (0)