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)
|
c := time.NewTicker(time.Hour)
|
||||||
defer c.Stop()
|
defer c.Stop()
|
||||||
|
|
||||||
for range c.C {
|
for {
|
||||||
|
select {
|
||||||
|
case <-c.C:
|
||||||
|
case <-ctx.Done():
|
||||||
|
return nil
|
||||||
|
}
|
||||||
if _, err := s.ExecContext(ctx, `
|
if _, err := s.ExecContext(ctx, `
|
||||||
DELETE FROM "pinger_pings"
|
DELETE FROM "pinger_pings"
|
||||||
WHERE
|
WHERE
|
||||||
@@ -155,7 +160,7 @@ func (s S) collectGarbage(ctx context.Context) error {
|
|||||||
ms < 100
|
ms < 100
|
||||||
OR ok
|
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)
|
log.Println("!", err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -246,6 +251,8 @@ func (s S) pingAndRecord(ctx context.Context) error {
|
|||||||
}
|
}
|
||||||
if err == nil {
|
if err == nil {
|
||||||
conn.Close()
|
conn.Close()
|
||||||
|
} else {
|
||||||
|
log.Println("!", err)
|
||||||
}
|
}
|
||||||
}()
|
}()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user