Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 1 of 1 for getWorkerCh (0.08 seconds)

  1. 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)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 33.7K bytes
    - Click Count (0)
Back to Top