Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for newHealState (0.17 sec)

  1. cmd/globals.go

    		if ptr == nil {
    			return ""
    		}
    		return *ptr
    	}
    
    	globalAllHealState = newHealState(GlobalContext, true)
    
    	// The always present healing routine ready to heal objects
    	globalBackgroundHealRoutine = newHealRoutine()
    	globalBackgroundHealState   = newHealState(GlobalContext, false)
    
    	globalMRFState = mrfState{
    		opCh: make(chan partialOperation, mrfOpsQueueSize),
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  2. cmd/admin-heal-ops.go

    	//    true: the disk is currently healing
    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    // newHealState - initialize global heal state management
    func newHealState(ctx context.Context, cleanup bool) *allHealState {
    	hstate := &allHealState{
    		healSeqMap:     make(map[string]*healSequence),
    		healLocalDisks: make(map[Endpoint]bool),
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  3. cmd/test-utils_test.go

    	if globalAllHealState == nil {
    		globalAllHealState = newHealState(GlobalContext, false)
    	} else {
    		globalAllHealState.Lock()
    		for _, v := range globalAllHealState.healSeqMap {
    			if !v.hasEnded() {
    				v.stop()
    			}
    		}
    		globalAllHealState.Unlock()
    	}
    
    	// Init background heal state
    	if globalBackgroundHealState == nil {
    		globalBackgroundHealState = newHealState(GlobalContext, false)
    	} else {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:06:57 GMT 2024
    - 75.7K bytes
    - Viewed (0)
Back to top