Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for opCh (0.04 sec)

  1. cmd/mrf.go

    // mrfState sncapsulates all the information
    // related to the global background MRF.
    type mrfState struct {
    	opCh chan partialOperation
    }
    
    // Add a partial S3 operation (put/delete) when one or more disks are offline.
    func (m *mrfState) addPartialOp(op partialOperation) {
    	if m == nil {
    		return
    	}
    
    	select {
    	case m.opCh <- op:
    	default:
    	}
    }
    
    var healSleeper = newDynamicSleeper(5, time.Second, false)
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  2. cmd/globals.go

    	// The always present healing routine ready to heal objects
    	globalBackgroundHealRoutine = newHealRoutine()
    	globalBackgroundHealState   = newHealState(GlobalContext, false)
    
    	globalMRFState = mrfState{
    		opCh: make(chan partialOperation, mrfOpsQueueSize),
    	}
    
    	// If writes to FS backend should be O_SYNC.
    	globalFSOSync bool
    
    	globalProxyEndpoints []ProxyEndpoint
    
    	globalInternodeTransport http.RoundTripper
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 16.4K bytes
    - Viewed (0)
Back to top