We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cf0ca74 commit b29e19fCopy full SHA for b29e19f
store/tikv/client.go
@@ -126,13 +126,13 @@ func (c *batchCommandsClient) batchRecvLoop(cfg config.TiKVClient) {
126
// When `conn.Close()` is called, `client.Recv()` will return an error.
127
resp, err := c.client.Recv()
128
if err != nil {
129
- if c.isStopped() {
130
- return
131
- }
132
logutil.Logger(context.Background()).Error("batchRecvLoop error when receive", zap.Error(err))
133
134
now := time.Now()
135
for { // try to re-create the streaming in the loop.
+ if c.isStopped() {
+ return
+ }
136
// Hold the lock to forbid batchSendLoop using the old client.
137
c.clientLock.Lock()
138
c.failPendingRequests(err) // fail all pending requests.
0 commit comments