SzyWilliam commented on code in PR #11458:
URL: https://github.com/apache/iotdb/pull/11458#discussion_r1387959830
##########
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java:
##########
@@ -196,28 +208,21 @@ private boolean shouldRetry(RaftClientReply reply) {
/** launch a consensus write with retry mechanism */
private RaftClientReply writeWithRetry(CheckedSupplier<RaftClientReply,
IOException> caller)
throws IOException {
-
- final int maxRetryTimes = config.getImpl().getRetryTimesMax();
- final long waitMillis = config.getImpl().getRetryWaitMillis();
-
- int retry = 0;
RaftClientReply reply = null;
- while (retry < maxRetryTimes) {
- retry++;
-
- reply = caller.get();
- if (!shouldRetry(reply)) {
- return reply;
- }
- logger.debug("{} sending write request with retry = {} and reply = {}",
this, retry, reply);
-
- try {
- Thread.sleep(waitMillis);
- } catch (InterruptedException e) {
- logger.warn("{} retry write sleep is interrupted: {}", this, e);
- Thread.currentThread().interrupt();
- }
+ try {
+ reply =
+ Retriable.attempt(
+ caller,
+ this::shouldRetry,
Review Comment:
Done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
