gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Remove internal retries for mirrors and sources

Browse Source 
We let the go routine do it.

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2021-03-10 15:33:53 -07:00
parent c783bf1bed
commit 84fbcdcd34
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
server/stream.go
View File

@@ -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