import org.opendaylight.controller.cluster.raft.RaftState;
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.base.messages.ApplyJournalEntries;
import org.opendaylight.controller.cluster.raft.base.messages.ApplyState;
import org.opendaylight.controller.cluster.raft.base.messages.ElectionTimeout;
return context.getId();
}
+ public void applyServerConfiguration(ServerConfigurationPayload serverConfig) {
+ for(String peerId: context.getPeerAddresses().keySet()) {
+ context.removePeer(peerId);
+ }
+
+ for(String peerId: serverConfig.getNewServerConfig()) {
+ if(!getId().equals(peerId)) {
+ context.addToPeers(peerId, null);
+ }
+ }
+ }
}