kv: perform local calls in a goroutine

Perform local calls in a goroutine so that they can be cancelled and so that they don't block the caller indefinitely. See #10427
cockroachdb · Nov 23, 2016 · aecff9f · aecff9f
1 parent a67cc0b
commit aecff9f
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/pkg/kv/transport.go b/pkg/kv/transport.go
@@ -181,9 +181,11 @@ func (gt *grpcTransport) SendNext(done chan<- BatchCall) {
  client.args.Txn = &clonedTxn
  }
 
- reply, err := localServer.Batch(gt.opts.ctx, &client.args)
- gt.setPending(client.args.Replica, false)
- done <- BatchCall{Reply: reply, Err: err}
+ go func() {
+ reply, err := localServer.Batch(gt.opts.ctx, &client.args)
+ gt.setPending(client.args.Replica, false)
+ done <- BatchCall{Reply: reply, Err: err}
+ }()
  return
  }