From ea9abc5ef8a8247e8c03a067d243476b6d5a4a45 Mon Sep 17 00:00:00 2001 From: Derek Collison Date: Tue, 9 Mar 2021 05:41:00 -0600 Subject: [PATCH] Wait longer for response Signed-off-by: Derek Collison --- server/const.go | 2 +- server/stream.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/server/const.go b/server/const.go index 1993f102..5762d60b 100644 --- a/server/const.go +++ b/server/const.go @@ -41,7 +41,7 @@ var ( const ( // VERSION is the current version for the server. - VERSION = "2.2.0-RC.7.1" + VERSION = "2.2.0-RC.7.2" // PROTO is the currently supported protocol. // 0 was the original diff --git a/server/stream.go b/server/stream.go index 1714b200..2db0c62d 100644 --- a/server/stream.go +++ b/server/stream.go @@ -1427,7 +1427,7 @@ func (mset *stream) setSourceConsumer(sname string, seq uint64) { } } mset.mu.Unlock() - case <-time.After(5 * time.Second): + case <-time.After(10 * time.Second): // Make sure things have not changed. mset.mu.Lock() if si := mset.sources[sname]; si != nil && si.cname == _EMPTY_ {