Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for decommissionCancelers (0.39 sec)

  1. cmd/erasure-server-pool-decom.go

    			}
    		}
    	}
    
    	return nil
    }
    
    func (z *erasureServerPools) doDecommissionInRoutine(ctx context.Context, idx int) {
    	z.poolMetaMutex.Lock()
    	var dctx context.Context
    	dctx, z.decommissionCancelers[idx] = context.WithCancel(GlobalContext)
    	z.poolMetaMutex.Unlock()
    
    	// Generate an empty request info so it can be directly modified later by audit
    	dctx = logger.SetReqInfo(dctx, &logger.ReqInfo{})
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.3K bytes
    - Viewed (1)
  2. cmd/erasure-server-pool.go

    	poolMeta      poolMeta
    
    	rebalMu   sync.RWMutex
    	rebalMeta *rebalanceMeta
    
    	deploymentID     [16]byte
    	distributionAlgo string
    
    	serverPools []*erasureSets
    
    	// Active decommission canceler
    	decommissionCancelers []context.CancelFunc
    
    	s3Peer *S3PeerSys
    }
    
    func (z *erasureServerPools) SinglePool() bool {
    	return len(z.serverPools) == 1
    }
    
    // Initialize new pool of erasure sets.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
Back to top