From 3ab546623fa8c34984dcb190fbfd2a9cb9a904cd Mon Sep 17 00:00:00 2001 From: Daniel Nephin Date: Tue, 9 Feb 2021 13:56:50 -0500 Subject: [PATCH] submatview: do not reset retry waiter when materializer is reset The materializer is often reset when an error is received. By resetting the retryWaiter we effectively never wait. The retryWaiter should only be reset when we get an event without error. This is done in Materializer.updateView(). --- agent/submatview/materializer.go | 1 - 1 file changed, 1 deletion(-) diff --git a/agent/submatview/materializer.go b/agent/submatview/materializer.go index 0bed8bfc2..b5a515754 100644 --- a/agent/submatview/materializer.go +++ b/agent/submatview/materializer.go @@ -181,7 +181,6 @@ func (m *Materializer) reset() { m.view.Reset() m.index = 0 - m.retryWaiter.Reset() } func (m *Materializer) updateView(events []*pbsubscribe.Event, index uint64) error {