Skip to content

Commit 32b4b7e

Browse files
author
kongzhi.jy
committed
update
1 parent b69dd4a commit 32b4b7e

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

ratis-server/src/main/java/org/apache/ratis/server/impl/RaftServerImpl.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1661,12 +1661,9 @@ leaderId, getMemberId(), currentTerm, followerCommit, inconsistencyReplyNextInde
16611661
CompletableFuture<Void> checkAndUpdateListenerState() {
16621662
CompletableFuture<Void> future = CompletableFuture.completedFuture(null);
16631663
if (role.getCurrentRole() == RaftPeerRole.LISTENER) {
1664-
RaftConfigurationImpl currentConf = getRaftConf();
1665-
if (currentConf.isStable() && currentConf.containsInConf(getId())) {
1666-
Object reason = "Listener transitionRole";
1667-
final AtomicBoolean termUpdated = new AtomicBoolean();
1668-
future = changeToFollower(state.getCurrentTerm(), false, true, reason, termUpdated);
1669-
}
1664+
Object reason = "Listener transitionRole";
1665+
final AtomicBoolean termUpdated = new AtomicBoolean();
1666+
future = changeToFollower(state.getCurrentTerm(), false, true, reason, termUpdated);
16701667
}
16711668
return future;
16721669
}

0 commit comments

Comments
 (0)