Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/erasure-server-pool.go

    	serverPools []*erasureSets
    
    	// Active decommission canceler
    	decommissionCancelers []context.CancelFunc
    
    	s3Peer *S3PeerSys
    
    	mpCache *xsync.MapOf[string, MultipartInfo]
    }
    
    func (z *erasureServerPools) SinglePool() bool {
    	return len(z.serverPools) == 1
    }
    
    // Initialize new pool of erasure sets.
    func newErasureServerPools(ctx context.Context, endpointServerPools EndpointServerPools) (ObjectLayer, error) {
    	var (
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom.go

    }
    
    // Decommission - start decommission session.
    func (z *erasureServerPools) Decommission(ctx context.Context, indices ...int) error {
    	if len(indices) == 0 {
    		return errInvalidArgument
    	}
    
    	if z.SinglePool() {
    		return errInvalidArgument
    	}
    
    	// Make pool unwritable before decommissioning.
    	if err := z.StartDecommission(ctx, indices...); err != nil {
    		return err
    	}
    
    	go func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
Back to top