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

Refine region refresh logic in RegionStoreClient.get (#27) 

Signed-off-by: birdstorm <samuelwyf@hotmail.com>
This commit is contained in:
birdstorm 2019-01-21 18:37:55 +08:00 committed by GitHub
parent ebe6f6bece
commit 1d66f4effa
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/tikv/common/region/RegionStoreClient.java
View File

@ -82,9 +82,6 @@ public class RegionStoreClient extends AbstractGRPCClient<TikvBlockingStub, Tikv
// APIs for KV Scan/Put/Get/Delete // APIs for KV Scan/Put/Get/Delete
public ByteString get(BackOffer backOffer, ByteString key, long version) { public ByteString get(BackOffer backOffer, ByteString key, long version) {
while (true) { while (true) {
// we should refresh region
region = regionManager.getRegionByKey(key);
Supplier<GetRequest> factory = Supplier<GetRequest> factory =
() -> () ->
GetRequest.newBuilder() GetRequest.newBuilder()
@ -105,6 +102,9 @@ public class RegionStoreClient extends AbstractGRPCClient<TikvBlockingStub, Tikv
if (getHelper(backOffer, resp)) { if (getHelper(backOffer, resp)) {
return resp.getValue(); return resp.getValue();
} }
// we should refresh region
region = regionManager.getRegionByKey(key);
} }
} }