- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for enqueueFreeVersion (0.17 sec)
-
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) -
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)