X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FMockRaftActorContext.java;h=a41c5013dea526b8b3d478f31a0c6f06793ba2df;hb=d3e310b940b60f6590f0e94a576aece95a055942;hp=723de650c2e889f5ab2ca99df4a83f3661f4f779;hpb=dc538304e4d5f91185c140cc227575f4305344df;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 723de650c2..a41c5013de 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 @@ -81,6 +81,7 @@ public class MockRaftActorContext extends RaftActorContextImpl { replicatedLog.append(new MockReplicatedLogEntry(term, 0, new MockPayload("1"))); replicatedLog.append(new MockReplicatedLogEntry(term, 1, new MockPayload("2"))); setReplicatedLog(replicatedLog); + setCommitIndex(replicatedLog.lastIndex()); } @Override public ActorRef actorOf(Props props) { @@ -145,8 +146,9 @@ public class MockRaftActorContext extends RaftActorContextImpl { public void captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry) { } - @Override public void removeFromAndPersist(long index) { - removeFrom(index); + @Override + public boolean removeFromAndPersist(long index) { + return removeFrom(index) >= 0; } @Override