X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FMockRaftActorContext.java;h=9d3e5dcb12da55ee474f27e055487ff690321def;hb=664fc9940569ebfd54dcfc3db87bab66fad9300e;hp=2424d4d557f7f1dc58e65a1718e44a6a84db501f;hpb=3a71a222b896b9d07e638af62300180799bdac67;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java index 2424d4d557..9d3e5dcb12 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/MockRaftActorContext.java @@ -34,6 +34,7 @@ public class MockRaftActorContext implements RaftActorContext { private ReplicatedLog replicatedLog; private Map peerAddresses = new HashMap<>(); private ConfigParams configParams; + private boolean snapshotCaptureInitiated; public MockRaftActorContext(){ electionTerm = null; @@ -55,14 +56,17 @@ public class MockRaftActorContext implements RaftActorContext { private long currentTerm = 0; private String votedFor = ""; + @Override public long getCurrentTerm() { return currentTerm; } + @Override public String getVotedFor() { return votedFor; } + @Override public void update(long currentTerm, String votedFor){ this.currentTerm = currentTerm; this.votedFor = votedFor; @@ -127,6 +131,7 @@ public class MockRaftActorContext implements RaftActorContext { return lastApplied; } + @Override public void setReplicatedLog(ReplicatedLog replicatedLog) { this.replicatedLog = replicatedLog; } @@ -181,6 +186,16 @@ public class MockRaftActorContext implements RaftActorContext { return configParams; } + @Override + public void setSnapshotCaptureInitiated(boolean snapshotCaptureInitiated) { + this.snapshotCaptureInitiated = snapshotCaptureInitiated; + } + + @Override + public boolean isSnapshotCaptureInitiated() { + return snapshotCaptureInitiated; + } + public void setConfigParams(ConfigParams configParams) { this.configParams = configParams; } @@ -202,7 +217,7 @@ public class MockRaftActorContext implements RaftActorContext { } public static class MockPayload extends Payload implements Serializable { - private static final long serialVersionUID = 1L; + private static final long serialVersionUID = 3121380393130864247L; private String value = ""; public MockPayload(){ @@ -235,6 +250,7 @@ public class MockRaftActorContext implements RaftActorContext { return MockPayload.class.getName(); } + @Override public String toString() { return value; } @@ -273,7 +289,7 @@ public class MockRaftActorContext implements RaftActorContext { } public static class MockReplicatedLogBuilder { - private ReplicatedLog mockLog = new SimpleReplicatedLog(); + private final ReplicatedLog mockLog = new SimpleReplicatedLog(); public MockReplicatedLogBuilder createEntries(int start, int end, int term) { for (int i=start; i