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%2Fbase%2Fmessages%2FCaptureSnapshot.java;h=daa8f7768a44033ba61585249f294fd80df00925;hb=753515e8868a1a15982d3f2697439f522f273db5;hp=bb86e1a37d9e1b1bb481dbcf78c48792d9ce312b;hpb=2dc333588d0c15eb7f2df6223dcdcc15e05b077e;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/CaptureSnapshot.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/CaptureSnapshot.java index bb86e1a37d..daa8f7768a 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/CaptureSnapshot.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/base/messages/CaptureSnapshot.java @@ -9,17 +9,28 @@ package org.opendaylight.controller.cluster.raft.base.messages; public class CaptureSnapshot { - private long lastAppliedIndex; - private long lastAppliedTerm; - private long lastIndex; - private long lastTerm; + private final long lastAppliedIndex; + private final long lastAppliedTerm; + private final long lastIndex; + private final long lastTerm; + private final boolean installSnapshotInitiated; + private final long replicatedToAllIndex; + private final long replicatedToAllTerm; public CaptureSnapshot(long lastIndex, long lastTerm, - long lastAppliedIndex, long lastAppliedTerm) { + long lastAppliedIndex, long lastAppliedTerm, long replicatedToAllIndex, long replicatedToAllTerm) { + this(lastIndex, lastTerm, lastAppliedIndex, lastAppliedTerm, replicatedToAllIndex , replicatedToAllTerm, false); + } + + public CaptureSnapshot(long lastIndex, long lastTerm,long lastAppliedIndex, + long lastAppliedTerm, long replicatedToAllIndex, long replicatedToAllTerm, boolean installSnapshotInitiated) { this.lastIndex = lastIndex; this.lastTerm = lastTerm; this.lastAppliedIndex = lastAppliedIndex; this.lastAppliedTerm = lastAppliedTerm; + this.installSnapshotInitiated = installSnapshotInitiated; + this.replicatedToAllIndex = replicatedToAllIndex; + this.replicatedToAllTerm = replicatedToAllTerm; } public long getLastAppliedIndex() { @@ -37,4 +48,27 @@ public class CaptureSnapshot { public long getLastTerm() { return lastTerm; } + + public boolean isInstallSnapshotInitiated() { + return installSnapshotInitiated; + } + + public long getReplicatedToAllIndex() { + return replicatedToAllIndex; + } + + public long getReplicatedToAllTerm() { + return replicatedToAllTerm; + } + + @Override + public String toString() { + StringBuilder builder = new StringBuilder(); + builder.append("CaptureSnapshot [lastAppliedIndex=").append(lastAppliedIndex).append(", lastAppliedTerm=") + .append(lastAppliedTerm).append(", lastIndex=").append(lastIndex).append(", lastTerm=") + .append(lastTerm).append(", installSnapshotInitiated=").append(installSnapshotInitiated) + .append(", replicatedToAllIndex=").append(replicatedToAllIndex).append(", replicatedToAllTerm=") + .append(replicatedToAllTerm).append("]"); + return builder.toString(); + } }