Merge pull request #347 from yongman/fix-update-regioncache

This commit is contained in:
iosmanthus 2022-06-15 22:37:48 +08:00 committed by GitHub
commit b524bc6779
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions

View File

@ -207,11 +207,11 @@ impl<C: RetryClientTrait> RegionCache<C> {
leader: metapb::Peer,
) -> Result<()> {
let mut cache = self.region_cache.write().await;
let region_entry = cache
.ver_id_to_region
.get_mut(&ver_id)
.ok_or(Error::EntryNotFoundInRegionCache)?;
region_entry.leader = Some(leader);
let region_entry = cache.ver_id_to_region.get_mut(&ver_id);
if let Some(region) = region_entry {
region.leader = Some(leader);
}
Ok(())
}