diff --git a/monkit.lock b/monkit.lock index 0447f6c06..ccb375ee3 100644 --- a/monkit.lock +++ b/monkit.lock @@ -1,3 +1,5 @@ +storj.io/storj/private/lifecycle."slow_shutdown" Event +storj.io/storj/private/lifecycle."unexpected_shutdown" Event storj.io/storj/satellite/accounting."bucket_bytes" IntVal storj.io/storj/satellite/accounting."bucket_inline_bytes" IntVal storj.io/storj/satellite/accounting."bucket_inline_segments" IntVal diff --git a/private/lifecycle/group.go b/private/lifecycle/group.go index 101d18ee5..006279490 100644 --- a/private/lifecycle/group.go +++ b/private/lifecycle/group.go @@ -72,6 +72,7 @@ func (group *Group) Run(ctx context.Context, g *errgroup.Group) { defer shutdownDeadline.Stop() select { case <-shutdownDeadline.C: + mon.Event("slow_shutdown") //mon:locked group.log.Warn("service takes long to shutdown", zap.String("name", item.Name)) group.logStackTrace() case <-shutdownCtx.Done(): @@ -89,6 +90,7 @@ func (group *Group) Run(ctx context.Context, g *errgroup.Group) { err = errs2.IgnoreCanceled(err) } if err != nil { + mon.Event("unexpected_shutdown") //mon:locked group.log.Error("unexpected shutdown of a runner", zap.String("name", item.Name), zap.Error(err)) } return err