- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for getWorkerCh (0.07 sec)
-
cmd/bucket-lifecycle.go
// object corresponding to a 'replaced' object versions. This applies only to // non-versioned or version suspended buckets. func (es *expiryState) enqueueTierJournalEntry(je jentry) { wrkr := es.getWorkerCh(je.OpHash()) if wrkr == nil { es.stats.missedTierJournalTasks.Add(1) return } select { case <-GlobalContext.Done(): case wrkr <- je: default: es.stats.missedTierJournalTasks.Add(1)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0)