File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed
src/main/java/io/openmessaging/storage/dledger Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -396,6 +396,9 @@ private void maintainAsCandidate() throws Exception {
396
396
long term ;
397
397
long ledgerEndTerm ;
398
398
long ledgerEndIndex ;
399
+ if (!memberState .isCandidate ()) {
400
+ return ;
401
+ }
399
402
synchronized (memberState ) {
400
403
if (!memberState .isCandidate ()) {
401
404
return ;
@@ -443,9 +446,6 @@ private void maintainAsCandidate() throws Exception {
443
446
case ACCEPT :
444
447
acceptedNum .incrementAndGet ();
445
448
break ;
446
- case REJECT_ALREADY_VOTED :
447
- case REJECT_TAKING_LEADERSHIP :
448
- break ;
449
449
case REJECT_ALREADY_HAS_LEADER :
450
450
alreadyHasLeader .compareAndSet (false , true );
451
451
break ;
@@ -462,6 +462,8 @@ private void maintainAsCandidate() throws Exception {
462
462
case REJECT_TERM_NOT_READY :
463
463
notReadyTermNum .incrementAndGet ();
464
464
break ;
465
+ case REJECT_ALREADY_VOTED :
466
+ case REJECT_TAKING_LEADERSHIP :
465
467
default :
466
468
break ;
467
469
You can’t perform that action at this time.
0 commit comments