mirror of
https://github.com/gogrlx/nats-server.git
synced 2026-04-17 03:24:40 -07:00
@@ -3279,7 +3279,7 @@ func (o *consumer) checkAckFloor() {
|
||||
defer o.mu.Unlock()
|
||||
|
||||
// If we are here, and this should be rare, we still are off with our ack floor.
|
||||
// We will set it explcitly to 1 behind our current lowest in pending, or if
|
||||
// We will set it explicitly to 1 behind our current lowest in pending, or if
|
||||
// pending is empty, to our current delivered -1.
|
||||
if o.asflr < ss.FirstSeq-1 {
|
||||
var psseq, pdseq uint64
|
||||
|
||||
Reference in New Issue
Block a user