Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for staleUploadsCleanupIntervalChangedCh (0.18 sec)

  1. 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)
  2. 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)
Back to top