Compare commits
4 Commits
8d3db70e01
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
| 439c481c60 | |||
| 0a58f85ca3 | |||
| 141c0e5100 | |||
| 9f3de791f9 |
+9
-2
@@ -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*2*24*time.Hour).Unix()); err != nil {
|
||||
log.Println("!", err)
|
||||
}
|
||||
}
|
||||
@@ -246,6 +251,8 @@ func (s S) pingAndRecord(ctx context.Context) error {
|
||||
}
|
||||
if err == nil {
|
||||
conn.Close()
|
||||
} else {
|
||||
log.Println("!", err)
|
||||
}
|
||||
}()
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user