RawGet changes the while (true) mechanism to a retry limit. (#90)

mikechengwei · web-flow · commit 26121ee2245d · 2020-09-11T20:08:56.000+08:00
Signed-off-by: mikechengwei &lt;842725815@qq.com&gt;
diff --git a/src/main/java/org/tikv/raw/RawKVClient.java b/src/main/java/org/tikv/raw/RawKVClient.java
@@ -130,14 +130,15 @@ private void batchPut(BackOffer backOffer, Map<ByteString, ByteString> kvPairs)
    */
   public ByteString get(ByteString key) {
     BackOffer backOffer = defaultBackOff();
-    while (true) {
+    for (int i = 0; i < MAX_RETRY_LIMIT; i++) {
       RegionStoreClient client = clientBuilder.build(key);
       try {
         return client.rawGet(defaultBackOff(), key);
       } catch (final TiKVException e) {
         backOffer.doBackOff(BackOffFunction.BackOffFuncType.BoRegionMiss, e);
       }
     }
+    throw ERR_RETRY_LIMIT_EXCEEDED;
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -130,14 +130,15 @@ private void batchPut(BackOffer backOffer, Map<ByteString, ByteString> kvPairs)`
`130`	`130`	`*/`
`131`	`131`	`public ByteString get(ByteString key) {`
`132`	`132`	`BackOffer backOffer = defaultBackOff();`
`133`		`- while (true) {`
	`133`	`+ for (int i = 0; i < MAX_RETRY_LIMIT; i++) {`
`134`	`134`	`RegionStoreClient client = clientBuilder.build(key);`
`135`	`135`	`try {`
`136`	`136`	`return client.rawGet(defaultBackOff(), key);`
`137`	`137`	`} catch (final TiKVException e) {`
`138`	`138`	`backOffer.doBackOff(BackOffFunction.BackOffFuncType.BoRegionMiss, e);`
`139`	`139`	`}`
`140`	`140`	`}`
	`141`	`+ throw ERR_RETRY_LIMIT_EXCEEDED;`
`141`	`142`	`}`
`142`	`143`
`143`	`144`	`/**`