Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for decommissionCancelers (0.1 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{})
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  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
    
    	mpCache *xsync.MapOf[string, MultipartInfo]
    }
    
    func (z *erasureServerPools) SinglePool() bool {
    	return len(z.serverPools) == 1
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top