- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for staleUploadsCleanupIntervalChangedCh (0.18 sec)
-
cmd/handler-api.go
if t.staleUploadsCleanupInterval != cfg.StaleUploadsCleanupInterval { t.staleUploadsCleanupInterval = cfg.StaleUploadsCleanupInterval // signal that cleanup interval has changed select { case staleUploadsCleanupIntervalChangedCh <- struct{}{}: default: // in case the channel is blocked... } } } func (t *apiConfig) odirectEnabled() bool { t.mu.RLock() defer t.mu.RUnlock() return t.enableODirect
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/erasure-sets.go
defaultParityCount int poolIndex int // Distribution algorithm of choice. distributionAlgo string deploymentID [16]byte lastConnectDisksOpTime time.Time } var staleUploadsCleanupIntervalChangedCh = make(chan struct{}) func (s *erasureSets) getDiskMap() map[Endpoint]StorageAPI { diskMap := make(map[Endpoint]StorageAPI) s.erasureDisksMu.RLock() defer s.erasureDisksMu.RUnlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1)