tikv
/
client-go
mirror of https://github.com/tikv/client-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

reduce redundant export 

Signed-off-by: husharp <jinhao.hu@pingcap.com>
This commit is contained in:
husharp 2023-08-03 11:25:49 +08:00
parent 0930be96a5
commit 1ee6c84e7d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tikv/kv.go
View File

@ -592,9 +592,9 @@ func (s *KVStore) updateSafeTS(ctx context.Context) {
for _, store := range stores { for _, store := range stores {
storeIDs = append(storeIDs, strconv.FormatUint(store.StoreID(), 10)) storeIDs = append(storeIDs, strconv.FormatUint(store.StoreID(), 10))
} }
StoreMinResolvedTSs := make(map[uint64]uint64) storeMinResolvedTSs := make(map[uint64]uint64)
if s.pdHttpClient != nil { if s.pdHttpClient != nil {
StoreMinResolvedTSs, err = s.pdHttpClient.GetMinResolvedTSByStoresIDs(ctx, storeIDs) storeMinResolvedTSs, err = s.pdHttpClient.GetMinResolvedTSByStoresIDs(ctx, storeIDs)
if err != nil { if err != nil {
// If getting the minimum resolved timestamp from PD failed, log the error and need to get it from TiKV. // If getting the minimum resolved timestamp from PD failed, log the error and need to get it from TiKV.
logutil.BgLogger().Debug("get resolved TS from PD failed", zap.Error(err), zap.Any("stores", storeIDs)) logutil.BgLogger().Debug("get resolved TS from PD failed", zap.Error(err), zap.Any("stores", storeIDs))
@ -610,7 +610,7 @@ func (s *KVStore) updateSafeTS(ctx context.Context) {
go func(ctx context.Context, wg *sync.WaitGroup, storeID uint64, storeAddr string) { go func(ctx context.Context, wg *sync.WaitGroup, storeID uint64, storeAddr string) {
defer wg.Done() defer wg.Done()
safeTS := StoreMinResolvedTSs[storeID] safeTS := storeMinResolvedTSs[storeID]
storeIDStr := strconv.FormatUint(storeID, 10) storeIDStr := strconv.FormatUint(storeID, 10)
// If getting the minimum resolved timestamp from PD failed or returned 0, try to get it from TiKV. // If getting the minimum resolved timestamp from PD failed or returned 0, try to get it from TiKV.
if safeTS == 0 || err != nil { if safeTS == 0 || err != nil {