Skip to content

Commit

Permalink
fix lock handle
Browse files Browse the repository at this point in the history
Signed-off-by: you06 <you1474600@gmail.com>
  • Loading branch information
you06 committed Dec 1, 2022
1 parent b34e889 commit c1011b3
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion store/copr/coprocessor.go
Original file line number Diff line number Diff line change
Expand Up @@ -1275,12 +1275,13 @@ func (worker *copIteratorWorker) handleBatchCopResponse(bo *Backoffer, batchResp
remainTasks = append(remainTasks, remains...)
continue
}
//TODO: handle resolveLockDetail
//TODO: handle locks in batch
if lockErr := batchResp.GetLocked(); lockErr != nil {
if err := worker.handleLockErr(bo, resp.pbResp.GetLocked(), task); err != nil {
return nil, err
}
remainTasks = append(remainTasks, task)
continue
}
if otherErr := batchResp.GetOtherError(); otherErr != "" {
err := errors.Errorf("other error: %s", otherErr)
Expand Down

0 comments on commit c1011b3

Please sign in to comment.