From 84fbcdcd34326a8f280aad8987a6b3499e98a101 Mon Sep 17 00:00:00 2001 From: Ivan Kozlovic Date: Wed, 10 Mar 2021 15:33:53 -0700 Subject: [PATCH] Remove internal retries for mirrors and sources We let the go routine do it. Signed-off-by: Ivan Kozlovic --- server/stream.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/server/stream.go b/server/stream.go index 59627892..10b7f2f7 100644 --- a/server/stream.go +++ b/server/stream.go @@ -1031,7 +1031,7 @@ func (mset *stream) processMirrorMsgs() { stalled := mset.mirror != nil && time.Since(mset.mirror.last) > 3*sourceHealthCheckInterval mset.mu.RUnlock() if stalled { - mset.resetMirrorConsumer() + mset.retryMirrorConsumer() } } } @@ -1266,8 +1266,6 @@ func (mset *stream) setupMirrorConsumer() error { case ccr := <-respCh: if ccr.Error != nil { mset.cancelMirrorConsumer() - // We will retry every 10 seconds or so - time.AfterFunc(10*time.Second, mset.retryMirrorConsumer) } else { // Capture consumer name. mset.mu.Lock() @@ -1426,7 +1424,6 @@ func (mset *stream) setSourceConsumer(sname string, seq uint64) { si.err = ccr.Error // We will retry every 10 seconds or so mset.cancelSourceConsumer(sname) - time.AfterFunc(10*time.Second, func() { mset.retrySourceConsumer(sname) }) } else { // Capture consumer name. si.cname = ccr.ConsumerInfo.Name