import akka.actor.ActorRef;
import akka.actor.Cancellable;
+import java.util.HashSet;
import java.util.Random;
+import java.util.Set;
import java.util.concurrent.TimeUnit;
import org.opendaylight.controller.cluster.raft.ClientRequestTracker;
import org.opendaylight.controller.cluster.raft.RaftActorContext;
import org.opendaylight.controller.cluster.raft.ReplicatedLogEntry;
import org.opendaylight.controller.cluster.raft.SerializationUtils;
import org.opendaylight.controller.cluster.raft.ServerConfigurationPayload;
+import org.opendaylight.controller.cluster.raft.VotingState;
import org.opendaylight.controller.cluster.raft.base.messages.ApplyJournalEntries;
import org.opendaylight.controller.cluster.raft.base.messages.ApplyState;
import org.opendaylight.controller.cluster.raft.base.messages.ElectionTimeout;
}
public void applyServerConfiguration(ServerConfigurationPayload serverConfig) {
- for(String peerId: context.getPeerAddresses().keySet()) {
- context.removePeer(peerId);
- }
-
+ Set<String> currentPeers = new HashSet<>(context.getPeerIds());
for(String peerId: serverConfig.getNewServerConfig()) {
if(!getId().equals(peerId)) {
- context.addToPeers(peerId, null);
+ if(!currentPeers.contains(peerId)) {
+ context.addToPeers(peerId, null, VotingState.VOTING);
+ } else {
+ currentPeers.remove(peerId);
+ }
}
}
+
+ for(String peerIdToRemove: currentPeers) {
+ context.removePeer(peerIdToRemove);
+ }
}
}