Skip to content

Commit 6bf2922

Browse files
committed
Fix: Delete timed-out tracker sources
1 parent 6a4080c commit 6bf2922

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

internal/app/engine/consume_tracker.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ func (e *Engine) processTrackerSources() {
5555
for sourceId, state := range e.trackerState {
5656
if now.Sub(e.trackerLastUpdate[*state.Uuid]) > time.Second {
5757
delete(e.trackerState, sourceId)
58+
delete(e.gcState.Trackers, sourceId)
5859
}
5960
}
6061
}

0 commit comments

Comments
 (0)