X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FAbstractReplicatedLogImplTest.java;h=bf0eda6a5e6e38b671348e87f4b513e8979d84c1;hp=a3e4396f37a95f698c8bc660fc558dbd443fd38a;hb=fa96da71c5ab10973a9f93c2e8b35494b96fd7ed;hpb=8274ae55bc9eba37035a62f49d992f85391524ed diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImplTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImplTest.java index a3e4396f37..bf0eda6a5e 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImplTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/AbstractReplicatedLogImplTest.java @@ -12,6 +12,7 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNull; import static org.junit.Assert.assertTrue; + import akka.japi.Procedure; import java.util.HashMap; import java.util.List; @@ -23,7 +24,7 @@ import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockPayload import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockReplicatedLogEntry; /** -* +* Unit tests for AbstractReplicatedLogImplTest. */ public class AbstractReplicatedLogImplTest { @@ -303,7 +304,7 @@ public class AbstractReplicatedLogImplTest { long lastIndex = 0; long lastTerm = 0; - for(int i = 0; i < numEntries; i++) { + for (int i = 0; i < numEntries; i++) { ReplicatedLogEntry entry = replicatedLogImpl.getAtPhysicalIndex(i); map.put(entry.getIndex(), entry.getData().toString()); lastIndex = entry.getIndex(); @@ -316,23 +317,21 @@ public class AbstractReplicatedLogImplTest { return map; } - class MockAbstractReplicatedLogImpl extends AbstractReplicatedLogImpl { - @Override - public void appendAndPersist(final ReplicatedLogEntry replicatedLogEntry) { - } + class MockAbstractReplicatedLogImpl extends AbstractReplicatedLogImpl { @Override - public void removeFromAndPersist(final long index) { + public boolean removeFromAndPersist(final long index) { + return true; } @Override - public void appendAndPersist(ReplicatedLogEntry replicatedLogEntry, Procedure callback) { + public boolean appendAndPersist(ReplicatedLogEntry replicatedLogEntry, Procedure callback, + boolean doAsync) { + return true; } @Override public void captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry) { } - - } }