Skip to content

Commit

Permalink
kv: remove unused arg
Browse files Browse the repository at this point in the history
Release note: None
  • Loading branch information
andreimatei committed Mar 17, 2019
1 parent 5a133ca commit 44d9dab
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions pkg/kv/txn_coord_sender.go
Original file line number Diff line number Diff line change
Expand Up @@ -761,7 +761,7 @@ func (tc *TxnCoordSender) Send(
// Send the command through the txnInterceptor stack.
br, pErr := tc.interceptorStack[0].SendLocked(ctx, ba)

pErr = tc.updateStateLocked(ctx, startNs, ba, br, pErr)
pErr = tc.updateStateLocked(ctx, ba, br, pErr)

// If we succeeded to commit, or we attempted to rollback, we move to
// txnFinalized.
Expand Down Expand Up @@ -986,17 +986,8 @@ func (tc *TxnCoordSender) handleRetryableErrLocked(
// updateStateLocked updates the transaction state in both the success and error
// cases. It also updates retryable errors with the updated transaction for use
// by client restarts.
//
// startNS is the time when the request that's updating the state has been sent.
// This is not used if the request is known to not be the one in charge of
// starting tracking the transaction - i.e. this is the case for DistSQL, which
// just does reads and passes 0.
func (tc *TxnCoordSender) updateStateLocked(
ctx context.Context,
startNS int64,
ba roachpb.BatchRequest,
br *roachpb.BatchResponse,
pErr *roachpb.Error,
ctx context.Context, ba roachpb.BatchRequest, br *roachpb.BatchResponse, pErr *roachpb.Error,
) *roachpb.Error {

// We handle a couple of different cases:
Expand Down

0 comments on commit 44d9dab

Please sign in to comment.