From 376d9c8c2128781e87c1481c4fba84c93795ed5d Mon Sep 17 00:00:00 2001
From: vate <806019582@qq.com>
Date: Sun, 8 Oct 2023 11:42:26 +0800
Subject: [PATCH] [ISSUE #312] Optimize
 DLedgerLeaderElector.maintainAsCandidate Lock

---
 .../storage/dledger/DLedgerLeaderElector.java | 57 ++++++++++---------
 1 file changed, 31 insertions(+), 26 deletions(-)

diff --git a/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerLeaderElector.java b/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerLeaderElector.java
index e23bff61..ca1e805b 100644
--- a/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerLeaderElector.java
+++ b/dledger/src/main/java/io/openmessaging/storage/dledger/DLedgerLeaderElector.java
@@ -454,33 +454,38 @@ private void maintainAsCandidate() throws Exception {
                     if (x.getVoteResult() != VoteResponse.RESULT.UNKNOWN) {
                         validNum.incrementAndGet();
                     }
-                    synchronized (knownMaxTermInGroup) {
-                        switch (x.getVoteResult()) {
-                            case ACCEPT:
-                                acceptedNum.incrementAndGet();
-                                break;
-                            case REJECT_ALREADY_HAS_LEADER:
-                                alreadyHasLeader.compareAndSet(false, true);
-                                break;
-                            case REJECT_TERM_SMALL_THAN_LEDGER:
-                            case REJECT_EXPIRED_VOTE_TERM:
-                                if (x.getTerm() > knownMaxTermInGroup.get()) {
-                                    knownMaxTermInGroup.set(x.getTerm());
+                    switch (x.getVoteResult()) {
+                        case ACCEPT:
+                            acceptedNum.incrementAndGet();
+                            break;
+                        case REJECT_ALREADY_HAS_LEADER:
+                            alreadyHasLeader.compareAndSet(false, true);
+                            break;
+                        case REJECT_TERM_SMALL_THAN_LEDGER:
+                        case REJECT_EXPIRED_VOTE_TERM:
+                            // cas update
+                            for (;;) {
+                                long maxTermInGroup = knownMaxTermInGroup.get();
+                                if (x.getTerm() <= maxTermInGroup) {
+                                    break;
+                                }
+                                if (knownMaxTermInGroup.compareAndSet(maxTermInGroup, x.getTerm())) {
+                                    break;
                                 }
-                                break;
-                            case REJECT_EXPIRED_LEDGER_TERM:
-                            case REJECT_SMALL_LEDGER_END_INDEX:
-                                biggerLedgerNum.incrementAndGet();
-                                break;
-                            case REJECT_TERM_NOT_READY:
-                                notReadyTermNum.incrementAndGet();
-                                break;
-                            case REJECT_ALREADY_VOTED:
-                            case REJECT_TAKING_LEADERSHIP:
-                            default:
-                                break;
-
-                        }
+                            }
+                            break;
+                        case REJECT_EXPIRED_LEDGER_TERM:
+                        case REJECT_SMALL_LEDGER_END_INDEX:
+                            biggerLedgerNum.incrementAndGet();
+                            break;
+                        case REJECT_TERM_NOT_READY:
+                            notReadyTermNum.incrementAndGet();
+                            break;
+                        case REJECT_ALREADY_VOTED:
+                        case REJECT_TAKING_LEADERSHIP:
+                        default:
+                            break;
+
                     }
                     if (alreadyHasLeader.get()
                             || memberState.isQuorum(acceptedNum.get())