Skip to content

Commit 8c1802b

Browse files
authored
feat(region_cache): sync leader store epoch when switchWorkLeaderToPeer (#573)
Signed-off-by: renhongdi <ryan.hd.ren@gmail.com>
1 parent f867f49 commit 8c1802b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

internal/locate/region_cache.go

+1
Original file line numberDiff line numberDiff line change
@@ -2073,6 +2073,7 @@ retry:
20732073
}
20742074
newRegionStore := oldRegionStore.clone()
20752075
newRegionStore.workTiKVIdx = leaderIdx
2076+
newRegionStore.storeEpochs[leaderIdx] = atomic.LoadUint32(&newRegionStore.stores[leaderIdx].epoch)
20762077
if !r.compareAndSwapStore(oldRegionStore, newRegionStore) {
20772078
goto retry
20782079
}

0 commit comments

Comments
 (0)