Skip to content

Commit 5f41232

Browse files
authored
Merge pull request #153875 from cockroachdb/blathers/backport-release-25.3-152038
release-25.3: rangefeed: update BufferedSenderQueueSize metric correctly
2 parents 18f9fcc + 7249e36 commit 5f41232

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/kv/kvserver/rangefeed/buffered_sender.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,10 +131,10 @@ func (bs *BufferedSender) run(
131131
case <-bs.notifyDataC:
132132
for {
133133
e, success := bs.popFront()
134-
bs.metrics.BufferedSenderQueueSize.Dec(1)
135134
if !success {
136135
break
137136
}
137+
bs.metrics.BufferedSenderQueueSize.Dec(1)
138138
err := bs.sender.Send(e.ev)
139139
e.alloc.Release(ctx)
140140
if e.ev.Error != nil {

0 commit comments

Comments
 (0)