- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for lastHandout (0.54 sec)
-
cmd/metacache-bucket.go
// Sort oldest last... sort.Slice(remainCaches, func(i, j int) bool { return remainCaches[i].lastHandout.Before(remainCaches[j].lastHandout) }) // Keep first metacacheMaxEntries... for _, cache := range remainCaches[metacacheMaxEntries:] { if time.Since(cache.lastHandout) > metacacheMaxClientWait { remove[cache.id] = struct{}{} } } } } for id := range remove {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6.6K bytes - Viewed (0) -
cmd/metacache.go
func (m *metacache) update(update metacache) { now := UTCNow() m.lastUpdate = now if update.lastHandout.After(m.lastHandout) { m.lastHandout = update.lastUpdate if m.lastHandout.After(now) { m.lastHandout = now } } if m.status == scanStateStarted && update.status == scanStateSuccess { m.ended = now }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/metacache-set.go
meta := *mc.meta meta, err = o.updateMetacacheListing(meta, rpc) if err == nil && time.Since(meta.lastHandout) > metacacheMaxClientWait { cancel() exit = true meta.status = scanStateError meta.error = fmt.Sprintf("listing canceled since time since last handout was %v ago", time.Since(meta.lastHandout).Round(time.Second)) o.debugln(color.Green("saveMetaCacheStream: ") + meta.error)
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 30.7K bytes - Viewed (0)