diff --git a/cmd/pinger/main.go b/cmd/pinger/main.go index 847f456..2842445 100644 --- a/cmd/pinger/main.go +++ b/cmd/pinger/main.go @@ -146,7 +146,12 @@ func (s S) collectGarbage(ctx context.Context) error { c := time.NewTicker(time.Hour) defer c.Stop() - for range c.C { + for { + select { + case <-c.C: + case <-ctx.Done(): + return nil + } if _, err := s.ExecContext(ctx, ` DELETE FROM "pinger_pings" WHERE @@ -155,7 +160,7 @@ func (s S) collectGarbage(ctx context.Context) error { ms < 100 OR ok ) - `, time.Now().Add(-1*12*time.Hour).Unix()); err != nil { + `, time.Now().Add(-1*55*time.Hour).Unix()); err != nil { log.Println("!", err) } }