Skip to content

Commit 0664f12

Browse files
craig[bot]xuchef
andcommitted
Merge #152038
152038: rangefeed: update BufferedSenderQueueSize metric correctly r=wenyihu6 a=xuchef Previously, we were decrementing the buffered sender queue size before checking if we successfully popped an event, leading to the metric becoming a negative value. <img width="872" height="614" alt="Screenshot 2025-08-18 at 5 54 10 PM" src="https://github.com/user-attachments/assets/42735b2b-bbc2-47dd-94b5-701ce6772999" /> Epic: None Release note: None Co-authored-by: Michael Xu <[email protected]>
2 parents 896c2fe + a6d2e19 commit 0664f12

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)