- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for scanStateStarted (0.1 sec)
-
cmd/metacache.go
if m.lastHandout.After(now) { m.lastHandout = now } } if m.status == scanStateStarted && update.status == scanStateSuccess { m.ended = now } if m.status == scanStateStarted && update.status != scanStateStarted { m.status = update.status } if m.status == scanStateStarted && time.Since(m.lastHandout) > metacacheMaxClientWait { // Drop if client hasn't been seen for 3 minutes.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
cmd/metacache_test.go
dataVersion: metacacheStreamVersion, }, 4: { id: "case-5-noupdate", bucket: "bucket", root: "folder/prefix", recursive: false, status: scanStateStarted, fileNotFound: false, error: "", started: metaCacheTestsetTimestamp.Add(-time.Minute), ended: time.Time{}, lastUpdate: metaCacheTestsetTimestamp.Add(-time.Minute),
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 08 18:06:45 UTC 2021 - 6.8K bytes - Viewed (0) -
cmd/metacache-manager.go
if err != nil { return err } cache := *c if cache.status == scanStateNone || cache.fileNotFound { return errFileNotFound } if cache.status == scanStateSuccess || cache.status == scanStateStarted { if time.Since(cache.lastUpdate) > metacacheMaxRunningAge { // We got a stale entry, mark error on handling server. err := fmt.Errorf("timeout: list %s not updated", cache.id) cache.error = err.Error()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 25 00:44:15 UTC 2022 - 5.2K bytes - Viewed (0)