Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for enqueueFreeVersion (0.17 sec)

  1. cmd/bucket-lifecycle.go

    		return
    	}
    	select {
    	case <-GlobalContext.Done():
    	case wrkr <- je:
    	default:
    		es.stats.missedTierJournalTasks.Add(1)
    	}
    }
    
    // enqueueFreeVersion enqueues a free version to be deleted
    func (es *expiryState) enqueueFreeVersion(oi ObjectInfo) {
    	task := freeVersionTask{ObjectInfo: oi}
    	wrkr := es.getWorkerCh(task.OpHash())
    	if wrkr == nil {
    		es.stats.missedFreeVersTasks.Add(1)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. cmd/xl-storage.go

    		for _, freeVersion := range fivs.FreeVersions {
    			oi := freeVersion.ToObjectInfo(item.bucket, item.objectPath(), versioned)
    			done = globalScannerMetrics.time(scannerMetricTierObjSweep)
    			globalExpiryState.enqueueFreeVersion(oi)
    			done()
    		}
    
    		// These are rather expensive. Skip if nobody listens.
    		if globalTrace.NumSubscribers(madmin.TraceScanner) > 0 {
    			if len(fivs.FreeVersions) > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top