412
}
413
414
>
func (db *taskQueueDB) updateBacklogStatsLocked(subqueue subqueueIndex, countDelta int64, oldestTime time.Time) {
db.go
415
>
// Prevent under-counting
416
>
count := &db.subqueues[subqueue].ApproximateBacklogCount
417
>
if *count+countDelta < 0 {
418
db.logger.Info("ApproximateBacklogCount could have under-counted.",
419
tag.WorkerVersion(db.queue.Version().MetricsTagValue()),
420
tag.WorkflowNamespaceID(db.queue.Partition().NamespaceId()))
421
*count = 0
423
*count += countDelta
424
}
425
>
db.subqueues[subqueue].oldestTime = oldestTime
db.go
426
}
427