kvcoord: include destination node ID in mux rangefeed recv errors

andyyang890 · claude · andyyang890 · commit ccbd5b5a89c3 · 2025-08-13T16:54:27.000-04:00
Previously, when mux rangefeed connections encountered gRPC recv errors, the error messages did not include the destination node ID, making it difficult to troubleshoot which node was causing connection issues. This change wraps mux rangefeed recv errors with the destination node ID information in the `receiveEventsFromNode` function. Release note: None 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude <noreply@anthropic.com>
diff --git a/pkg/kv/kvclient/kvcoord/dist_sender_mux_rangefeed.go b/pkg/kv/kvclient/kvcoord/dist_sender_mux_rangefeed.go
@@ -457,7 +457,7 @@ func (m *rangefeedMuxer) receiveEventsFromNode(
 	for {
 		event, err := receiver.Recv()
 		if err != nil {
-			return err
+			return errors.Wrapf(err, "receiving from node %d", ms.nodeID)
 		}
 
 		active := ms.lookupStream(event.StreamID)

Original file line number	Diff line number	Diff line change
`@@ -457,7 +457,7 @@ func (m *rangefeedMuxer) receiveEventsFromNode(`
`457`	`457`	`for {`
`458`	`458`	`event, err := receiver.Recv()`
`459`	`459`	`if err != nil {`
`460`		`- return err`
	`460`	`+ return errors.Wrapf(err, "receiving from node %d", ms.nodeID)`
`461`	`461`	`}`
`462`	`462`
`463`	`463`	`active := ms.lookupStream(event.StreamID)`