From 885280f70eb218445ae39b534ec423d1e4183ff2 Mon Sep 17 00:00:00 2001
From: disksing <i@disksing.com>
Date: Mon, 26 Jul 2021 16:44:37 +0800
Subject: [PATCH] store/tikv: point get use lite resolve lock

Signed-off-by: disksing <i@disksing.com>
---
 store/copr/coprocessor.go   | 2 +-
 store/tikv/client_helper.go | 3 ++-
 store/tikv/snapshot.go      | 4 ++--
 3 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/store/copr/coprocessor.go b/store/copr/coprocessor.go
index 49e6d1d281ced..b871812d84d77 100644
--- a/store/copr/coprocessor.go
+++ b/store/copr/coprocessor.go
@@ -405,7 +405,7 @@ func (it *copIterator) open(ctx context.Context, enabledRateLimitAction bool) {
 			respChan:        it.respChan,
 			finishCh:        it.finishCh,
 			vars:            it.vars,
-			kvclient:        tikv.NewClientHelper(it.store.store, it.resolvedLocks),
+			kvclient:        tikv.NewClientHelper(it.store.store, it.resolvedLocks, false),
 			memTracker:      it.memTracker,
 			replicaReadSeed: it.replicaReadSeed,
 			actionOnExceed:  it.actionOnExceed,
diff --git a/store/tikv/client_helper.go b/store/tikv/client_helper.go
index bfa64fb372246..16e2af6d8c56f 100644
--- a/store/tikv/client_helper.go
+++ b/store/tikv/client_helper.go
@@ -38,12 +38,13 @@ type ClientHelper struct {
 }
 
 // NewClientHelper creates a helper instance.
-func NewClientHelper(store *KVStore, resolvedLocks *util.TSSet) *ClientHelper {
+func NewClientHelper(store *KVStore, resolvedLocks *util.TSSet, resolveLockLite bool) *ClientHelper {
 	return &ClientHelper{
 		lockResolver:  store.GetLockResolver(),
 		regionCache:   store.GetRegionCache(),
 		resolvedLocks: resolvedLocks,
 		client:        store.GetTiKVClient(),
+		resolveLite:   resolveLockLite,
 	}
 }
 
diff --git a/store/tikv/snapshot.go b/store/tikv/snapshot.go
index 3cc793e03ddc1..59ded1604351d 100644
--- a/store/tikv/snapshot.go
+++ b/store/tikv/snapshot.go
@@ -312,7 +312,7 @@ func (s *KVSnapshot) batchGetKeysByRegions(bo *Backoffer, keys [][]byte, collect
 }
 
 func (s *KVSnapshot) batchGetSingleRegion(bo *Backoffer, batch batchKeys, collectF func(k, v []byte)) error {
-	cli := NewClientHelper(s.store, s.resolvedLocks)
+	cli := NewClientHelper(s.store, s.resolvedLocks, false)
 	s.mu.RLock()
 	if s.mu.stats != nil {
 		cli.Stats = make(map[tikvrpc.CmdType]*RPCRuntimeStats)
@@ -483,7 +483,7 @@ func (s *KVSnapshot) get(ctx context.Context, bo *Backoffer, k []byte) ([]byte,
 		}
 	})
 
-	cli := NewClientHelper(s.store, s.resolvedLocks)
+	cli := NewClientHelper(s.store, s.resolvedLocks, true)
 
 	s.mu.RLock()
 	if s.mu.stats != nil {