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=c99f253657734cee8112f42e85b93e7feeebf215;hb=fa96da71c5ab10973a9f93c2e8b35494b96fd7ed;hpb=68fb550b416dddd0a50e0110add0a4ae9b706758 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 c99f253657..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 @@ -1,5 +1,6 @@ /* * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved. + * Copyright (c) 2015 Brocade Communications Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, @@ -11,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; @@ -22,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 { @@ -39,6 +41,35 @@ public class AbstractReplicatedLogImplTest { } + @Test + public void testEmptyLog() { + replicatedLogImpl = new MockAbstractReplicatedLogImpl(); + + assertEquals("size", 0, replicatedLogImpl.size()); + assertEquals("dataSize", 0, replicatedLogImpl.dataSize()); + assertEquals("getSnapshotIndex", -1, replicatedLogImpl.getSnapshotIndex()); + assertEquals("getSnapshotTerm", -1, replicatedLogImpl.getSnapshotTerm()); + assertEquals("lastIndex", -1, replicatedLogImpl.lastIndex()); + assertEquals("lastTerm", -1, replicatedLogImpl.lastTerm()); + assertEquals("isPresent", false, replicatedLogImpl.isPresent(0)); + assertEquals("isInSnapshot", false, replicatedLogImpl.isInSnapshot(0)); + Assert.assertNull("get(0)", replicatedLogImpl.get(0)); + Assert.assertNull("last", replicatedLogImpl.last()); + + List list = replicatedLogImpl.getFrom(0, 1, ReplicatedLog.NO_MAX_SIZE); + assertEquals("getFrom size", 0, list.size()); + + assertEquals("removeFrom", -1, replicatedLogImpl.removeFrom(1)); + + replicatedLogImpl.setSnapshotIndex(2); + replicatedLogImpl.setSnapshotTerm(1); + + assertEquals("getSnapshotIndex", 2, replicatedLogImpl.getSnapshotIndex()); + assertEquals("getSnapshotTerm", 1, replicatedLogImpl.getSnapshotTerm()); + assertEquals("lastIndex", 2, replicatedLogImpl.lastIndex()); + assertEquals("lastTerm", 1, replicatedLogImpl.lastTerm()); + } + @Test public void testIndexOperations() { @@ -106,19 +137,41 @@ public class AbstractReplicatedLogImplTest { } @Test - public void testGetFromWithMax(){ - List from = replicatedLogImpl.getFrom(0, 1); + public void testGetFromWithMax() { + List from = replicatedLogImpl.getFrom(0, 1, ReplicatedLog.NO_MAX_SIZE); Assert.assertEquals(1, from.size()); - Assert.assertEquals(1, from.get(0).getTerm()); + Assert.assertEquals("A", from.get(0).getData().toString()); - from = replicatedLogImpl.getFrom(0, 20); + from = replicatedLogImpl.getFrom(0, 20, ReplicatedLog.NO_MAX_SIZE); Assert.assertEquals(4, from.size()); - Assert.assertEquals(2, from.get(3).getTerm()); + Assert.assertEquals("A", from.get(0).getData().toString()); + Assert.assertEquals("D", from.get(3).getData().toString()); + + from = replicatedLogImpl.getFrom(1, 2, ReplicatedLog.NO_MAX_SIZE); + Assert.assertEquals(2, from.size()); + Assert.assertEquals("B", from.get(0).getData().toString()); + Assert.assertEquals("C", from.get(1).getData().toString()); + + from = replicatedLogImpl.getFrom(1, 3, 2); + Assert.assertEquals(2, from.size()); + Assert.assertEquals("B", from.get(0).getData().toString()); + Assert.assertEquals("C", from.get(1).getData().toString()); + + from = replicatedLogImpl.getFrom(1, 3, 3); + Assert.assertEquals(3, from.size()); + Assert.assertEquals("B", from.get(0).getData().toString()); + Assert.assertEquals("C", from.get(1).getData().toString()); + Assert.assertEquals("D", from.get(2).getData().toString()); - from = replicatedLogImpl.getFrom(1, 2); + from = replicatedLogImpl.getFrom(1, 2, 3); Assert.assertEquals(2, from.size()); - Assert.assertEquals(1, from.get(1).getTerm()); + Assert.assertEquals("B", from.get(0).getData().toString()); + Assert.assertEquals("C", from.get(1).getData().toString()); + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 4, new MockPayload("12345"))); + from = replicatedLogImpl.getFrom(4, 2, 2); + Assert.assertEquals(1, from.size()); + Assert.assertEquals("12345", from.get(0).getData().toString()); } @Test @@ -133,24 +186,67 @@ public class AbstractReplicatedLogImplTest { replicatedLogImpl.snapshotPreCommit(-1, -1); assertEquals(8, replicatedLogImpl.size()); assertEquals(-1, replicatedLogImpl.getSnapshotIndex()); + assertEquals(-1, replicatedLogImpl.getSnapshotTerm()); - replicatedLogImpl.snapshotPreCommit(4, 3); + replicatedLogImpl.snapshotPreCommit(4, 2); assertEquals(3, replicatedLogImpl.size()); assertEquals(4, replicatedLogImpl.getSnapshotIndex()); + assertEquals(2, replicatedLogImpl.getSnapshotTerm()); replicatedLogImpl.snapshotPreCommit(6, 3); assertEquals(1, replicatedLogImpl.size()); assertEquals(6, replicatedLogImpl.getSnapshotIndex()); + assertEquals(3, replicatedLogImpl.getSnapshotTerm()); replicatedLogImpl.snapshotPreCommit(7, 3); assertEquals(0, replicatedLogImpl.size()); assertEquals(7, replicatedLogImpl.getSnapshotIndex()); + assertEquals(3, replicatedLogImpl.getSnapshotTerm()); //running it again on an empty list should not throw exception replicatedLogImpl.snapshotPreCommit(7, 3); assertEquals(0, replicatedLogImpl.size()); assertEquals(7, replicatedLogImpl.getSnapshotIndex()); + assertEquals(3, replicatedLogImpl.getSnapshotTerm()); + } + + @Test + public void testSnapshotCommit() { + + replicatedLogImpl.snapshotPreCommit(1, 1); + + replicatedLogImpl.snapshotCommit(); + + assertEquals("size", 2, replicatedLogImpl.size()); + assertEquals("dataSize", 2, replicatedLogImpl.dataSize()); + assertEquals("getSnapshotIndex", 1, replicatedLogImpl.getSnapshotIndex()); + assertEquals("getSnapshotTerm", 1, replicatedLogImpl.getSnapshotTerm()); + assertEquals("lastIndex", 3, replicatedLogImpl.lastIndex()); + assertEquals("lastTerm", 2, replicatedLogImpl.lastTerm()); + + Assert.assertNull("get(0)", replicatedLogImpl.get(0)); + Assert.assertNull("get(1)", replicatedLogImpl.get(1)); + Assert.assertNotNull("get(2)", replicatedLogImpl.get(2)); + Assert.assertNotNull("get(3)", replicatedLogImpl.get(3)); + } + + @Test + public void testSnapshotRollback() { + + replicatedLogImpl.snapshotPreCommit(1, 1); + + assertEquals("size", 2, replicatedLogImpl.size()); + assertEquals("getSnapshotIndex", 1, replicatedLogImpl.getSnapshotIndex()); + assertEquals("getSnapshotTerm", 1, replicatedLogImpl.getSnapshotTerm()); + + replicatedLogImpl.snapshotRollback(); + assertEquals("size", 4, replicatedLogImpl.size()); + assertEquals("dataSize", 4, replicatedLogImpl.dataSize()); + assertEquals("getSnapshotIndex", -1, replicatedLogImpl.getSnapshotIndex()); + assertEquals("getSnapshotTerm", -1, replicatedLogImpl.getSnapshotTerm()); + Assert.assertNotNull("get(0)", replicatedLogImpl.get(0)); + Assert.assertNotNull("get(3)", replicatedLogImpl.get(3)); } @Test @@ -208,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(); @@ -221,17 +317,21 @@ public class AbstractReplicatedLogImplTest { return map; } + class MockAbstractReplicatedLogImpl extends AbstractReplicatedLogImpl { @Override - public void appendAndPersist(final ReplicatedLogEntry replicatedLogEntry) { + public boolean removeFromAndPersist(final long index) { + return true; } @Override - public void removeFromAndPersist(final long index) { + public boolean appendAndPersist(ReplicatedLogEntry replicatedLogEntry, Procedure callback, + boolean doAsync) { + return true; } @Override - public void appendAndPersist(ReplicatedLogEntry replicatedLogEntry, Procedure callback) { + public void captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry) { } } }