- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newDynamicSleeper (0.11 sec)
-
cmd/globals.go
// dynamic sleeper to avoid thundering herd for trash folder expunge routine deleteCleanupSleeper = newDynamicSleeper(5, 25*time.Millisecond, false) // dynamic sleeper for multipart expiration routine deleteMultipartCleanupSleeper = newDynamicSleeper(5, 25*time.Millisecond, false) // Is MINIO_SYNC_BOOT set? globalEnableSyncBoot bool
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 16.2K bytes - Viewed (0) -
cmd/mrf.go
localDrive.Delete(GlobalContext, minioMetaBucket, pathJoin(healMRFDir, "list.bin"), DeleteOptions{}) break } return } var healSleeper = newDynamicSleeper(5, time.Second, false) // healRoutine listens to new disks reconnection events and // issues healing requests for queued objects belonging to the // corresponding erasure set
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/data-scanner.go
// cycle will be closed cycle chan struct{} // isScanner should be set when this is used by the scanner // to record metrics. isScanner bool } // newDynamicSleeper func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper { return &dynamicSleeper{ factor: factor, cycle: make(chan struct{}), maxSleep: maxWait,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
} } func (sys *BucketMetadataSys) refreshBucketsMetadataLoop(ctx context.Context) { const bucketMetadataRefresh = 15 * time.Minute sleeper := newDynamicSleeper(2, 150*time.Millisecond, false) t := time.NewTimer(bucketMetadataRefresh) defer t.Stop() for { select { case <-ctx.Done(): return case <-t.C:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 20.4K bytes - Viewed (0)