cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

resource cleanup on milliseconds

Browse Source
This commit is contained in:
Andrew Jackson (Ajax) 2023-11-15 08:01:32 -06:00
parent 4b8aa53806
commit f80a5bcebf
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
lib/harmony/resources/resources.go
View File

@ -93,8 +93,9 @@ func Register(db *harmonydb.DB, hostnameAndPort string) (*Reg, error) {
} }
func CleanupMachines(ctx context.Context, db *harmonydb.DB) int { func CleanupMachines(ctx context.Context, db *harmonydb.DB) int {
ct, err := db.Exec(ctx, `DELETE FROM harmony_machines WHERE last_contact < $1`, ct, err := db.Exec(ctx,
time.Now().Add(-1*LOOKS_DEAD_TIMEOUT)) `DELETE FROM harmony_machines WHERE last_contact < CURRENT_TIMESTAMP - INTERVAL $1 MILLISECONDS`,
LOOKS_DEAD_TIMEOUT.Milliseconds()) // ms enables unit testing to change timeout.
if err != nil { if err != nil {
logger.Warn("unable to delete old machines: ", err) logger.Warn("unable to delete old machines: ", err)
} }