From 2e5851d6c4fac0d82c4d4be3ac8b7d4d4a927b01 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Jean-No=C3=ABl=20Moyne?= Date: Mon, 29 Apr 2024 15:12:51 -0700 Subject: [PATCH] PR Feedback MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Jean-Noël Moyne --- server/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/stream.go b/server/stream.go index 94446a02c1..dd44cc4bbf 100644 --- a/server/stream.go +++ b/server/stream.go @@ -291,8 +291,8 @@ type stream struct { syncSub *subscription // Internal subscription for sync messages (on "$JSC.SYNC"). infoSub *subscription // Internal subscription for stream info requests. clMu sync.Mutex // The mutex for clseq and clfs. - clseq uint64 // The commit log current last sequence number. - clfs uint64 // The count of the commit log failed sequence numbers. + clseq uint64 // The current last seq being proposed to the NRG layer. + clfs uint64 // The count (offset) of the number of failed NRG sequences used to compute clseq. inflight map[uint64]uint64 // Inflight message sizes per clseq. leader string // The current leader for the RAFT group. lqsent time.Time // The time at which the last lost quorum advisory was sent. Used to rate limit.