33
34
// Registers task as in-flight and moves read level to it. Tasks can be added in increasing order of taskID only.
36
>
m.Lock()
37
>
defer m.Unlock()
38
>
if m.readLevel >= taskID {
39
m.logger.Fatal("Next task ID is less than current read level.",
40
tag.TaskID(taskID),
41
tag.ReadLevel(m.readLevel))
42
}
44
>
if _, found := m.outstandingTasks.Get(taskID); found {
45
m.logger.Fatal("Already present in outstanding tasks", tag.TaskID(taskID))
46
}
48
>
m.backlogCountHint.Add(1)
49
}
50