Add getPeerIds to RaftActorContext

[controller.git] / opendaylight / md-sal / sal-akka-raft / src / main / java / org / opendaylight / controller / cluster / raft / behaviors / AbstractLeader.java

diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java
index 3c5ad0428fd90ba59e3aabfea701a46f8a7af6cb..b80a1bab15a9d248fa43a8628fdf810ef5bb0289 100644 (file)
--- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java
+++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/behaviors/AbstractLeader.java
@@ -97,7 +97,7 @@ public abstract class AbstractLeader extends AbstractRaftActorBehavior {
 
         setLeaderPayloadVersion(context.getPayloadVersion());
 
-        for (String followerId : context.getPeerAddresses().keySet()) {
+        for (String followerId : context.getPeerIds()) {
             FollowerLogInformation followerLogInformation =
                 new FollowerLogInformationImpl(followerId, -1, context);
 
@@ -157,7 +157,7 @@ public abstract class AbstractLeader extends AbstractRaftActorBehavior {
         minIsolatedLeaderPeerCount = minReplicationCount > 0 ? (minReplicationCount - 1) : 0;
     }
 
-    public int getMinIsolatedLeaderPeerCount(){
+    protected int getMinIsolatedLeaderPeerCount(){
         return minIsolatedLeaderPeerCount;
     }
 
@@ -433,7 +433,7 @@ public abstract class AbstractLeader extends AbstractRaftActorBehavior {
                     }
                     wasLastChunk = true;
                     FollowerState followerState = followerLogInformation.getFollowerState();
-                    if(followerState ==  FollowerState.VOTING_NOT_INITIALIZED){
+                    if(followerState == FollowerState.VOTING_NOT_INITIALIZED){
                         UnInitializedFollowerSnapshotReply unInitFollowerSnapshotSuccess =
                                              new UnInitializedFollowerSnapshotReply(followerId);
                         context.getActor().tell(unInitFollowerSnapshotSuccess, context.getActor());