Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for SinglePool (0.07 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top