- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for queueMRFHeal (0.19 sec)
-
cmd/bucket-replication.go
continue } if err := p.queueMRFHeal(); err != nil && !osIsNotExist(err) { replLogIf(p.ctx, err) } pTimer.Reset(mrfQueueInterval) case <-p.ctx.Done(): return } } } // process sends error logs to the heal channel for an attempt to heal replication. func (p *ReplicationPool) queueMRFHeal() error { p.mrfMU.Lock() defer p.mrfMU.Unlock()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 112.2K bytes - Viewed (1)