X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorServerConfigurationSupport.java;h=0014a6fce716f988a2f96ffe22b3e0ffc5ee6d2b;hb=6751227ff9443018d75e3a99da5693230d23d82b;hp=782ecc06a87ac11b19c6ef6b8335e6a9aa820b1a;hpb=b0f8283587b5cc8573d29f66219cbe7f70e21e1b;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorServerConfigurationSupport.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorServerConfigurationSupport.java index 782ecc06a8..0014a6fce7 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorServerConfigurationSupport.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorServerConfigurationSupport.java @@ -237,7 +237,8 @@ class RaftActorServerConfigurationSupport { operationContext.includeSelfInNewConfiguration(raftActor)); LOG.debug("{}: New server configuration : {}", raftContext.getId(), payload.getServerConfig()); - raftActor.persistData(operationContext.getClientRequestor(), operationContext.getContextId(), payload); + raftActor.persistData(operationContext.getClientRequestor(), operationContext.getContextId(), + payload, false); currentOperationState = new Persisting(operationContext, newTimer(new ServerOperationTimeout( operationContext.getLoggingContext()))); @@ -627,7 +628,9 @@ class RaftActorServerConfigurationSupport { public void initiate() { String serverId = getRemoveServerContext().getOperation().getServerId(); raftContext.removePeer(serverId); - ((AbstractLeader)raftActor.getCurrentBehavior()).removeFollower(serverId); + AbstractLeader leader = (AbstractLeader)raftActor.getCurrentBehavior(); + leader.removeFollower(serverId); + leader.updateMinReplicaCount(); persistNewServerConfiguration(getRemoveServerContext()); }