405
// updateApproximateBacklogCount updates the in-memory DB state with the given delta value
406
// TODO(pri): old matcher cleanup
407
>
func (db *taskQueueDB) updateBacklogStats(countDelta int64, oldestTime time.Time) {
db.go
408
>
db.Lock()
409
>
defer db.Unlock()
410
>
db.lastChange = time.Now()
411
>
db.updateBacklogStatsLocked(subqueueZero, countDelta, oldestTime)
412
>
}
413
414
func (db *taskQueueDB) updateBacklogStatsLocked(subqueue subqueueIndex, countDelta int64, oldestTime time.Time) {