Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ccancel (0.04 sec)

  1. .github/workflows/ci.yml

                java: 21
                root-pom: pom.xml
        runs-on: ${{ matrix.os }}
        env:
          ROOT_POM: ${{ matrix.root-pom }}
        steps:
          # Cancel any previous runs for the same branch that are still running.
          - name: 'Cancel previous runs'
            uses: styfle/cancel-workflow-action@85880fa0301c86cca9da44039ee3bb12d3bedbfa # 0.12.1
            with:
              access_token: ${{ github.token }}
          - name: 'Check out repository'
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 19:19:31 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    	z.rebalMu.Lock()
    	defer z.rebalMu.Unlock()
    
    	r := z.rebalMeta
    	if r == nil { // rebalance not running in this node, nothing to do
    		return nil
    	}
    
    	if cancel := r.cancel; cancel != nil {
    		// cancel != nil only on pool leaders
    		r.cancel = nil
    		cancel()
    	}
    	return nil
    }
    
    // for rebalance trace support
    type rebalanceMetrics struct{}
    
    var globalRebalanceMetrics rebalanceMetrics
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  3. cmd/admin-handlers-pools.go

    	if objectAPI == nil {
    		return
    	}
    
    	pools, ok := objectAPI.(*erasureServerPools)
    	if !ok {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	// Cancel any ongoing rebalance operation
    	globalNotificationSys.StopRebalance(r.Context())
    	writeSuccessResponseHeadersOnly(w)
    	adminLogIf(ctx, pools.saveRebalanceStats(GlobalContext, 0, rebalSaveStoppedAt))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		Healing:          false,
    	}
    
    	mrfCheck := make(chan FileInfo)
    	defer xioutil.SafeClose(mrfCheck)
    
    	var rw sync.Mutex
    
    	// Ask for all disks first;
    	go func() {
    		ctx, cancel := context.WithCancel(ctx)
    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    				done <- false
    				continue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. docs/en/docs/release-notes.md

    ## 0.75.2
    
    This release includes upgrades to third-party packages that handle security issues. Although there's a chance these issues don't affect you in particular, please upgrade as soon as possible.
    
    ### Fixes
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
Back to top