have a max collection threshold even when only processing regular pro…

…vides
ipfs · May 12, 2021 · 4f3814c · 4f3814c
1 parent f498246
commit 4f3814c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/batched/system.go b/batched/system.go
@@ -127,6 +127,9 @@ func (s *BatchProvidingSystem) Run() {
 					m[c] = struct{}{}
 					resetTimer(pauseDetectTimer, pauseDetectionThreshold)
 					continue
+				case <-maxCollectionDurationTimer.C:
+					emptyTimer(pauseDetectTimer)
+					break loop
 				default:
 				}