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=d175289af56c0226a938ccae5cc3d37632d3d2ec;hp=d95c9d502712159334171301868ee9af4cfa99d7;hb=f9a9cd1ea40d2477ccb16b03c71a87595226595a;hpb=82be26d1da9096cb86f2f36e142854003415f4ae 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 d95c9d5027..d175289af5 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,15 +12,16 @@ 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; import java.util.Map; -import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.Test; import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockPayload; import org.opendaylight.controller.cluster.raft.MockRaftActorContext.MockReplicatedLogEntry; + /** * */ @@ -38,12 +40,33 @@ public class AbstractReplicatedLogImplTest { } - @After - public void tearDown() { - replicatedLogImpl.journal.clear(); - replicatedLogImpl.setSnapshotIndex(-1); - replicatedLogImpl.setSnapshotTerm(-1); - replicatedLogImpl = null; + @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); + 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 @@ -63,7 +86,7 @@ public class AbstractReplicatedLogImplTest { // now create a snapshot of 3 entries, with 1 unapplied entry left in the log // It removes the entries which have made it to snapshot // and updates the snapshot index and term - Map state = takeSnapshot(3); + takeSnapshot(3); // check the values after the snapshot. // each index value passed in the test is the logical index (log entry index) @@ -99,7 +122,7 @@ public class AbstractReplicatedLogImplTest { assertEquals(2, replicatedLogImpl.getFrom(6).size()); // take a second snapshot with 5 entries with 0 unapplied entries left in the log - state = takeSnapshot(5); + takeSnapshot(5); assertEquals(0, replicatedLogImpl.size()); assertNull(replicatedLogImpl.last()); @@ -128,19 +151,145 @@ public class AbstractReplicatedLogImplTest { } + @Test + public void testSnapshotPreCommit() { + //add 4 more entries + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 4, new MockPayload("E"))); + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 5, new MockPayload("F"))); + replicatedLogImpl.append(new MockReplicatedLogEntry(3, 6, new MockPayload("G"))); + replicatedLogImpl.append(new MockReplicatedLogEntry(3, 7, new MockPayload("H"))); + + //sending negative values should not cause any changes + replicatedLogImpl.snapshotPreCommit(-1, -1); + assertEquals(8, replicatedLogImpl.size()); + assertEquals(-1, replicatedLogImpl.getSnapshotIndex()); + assertEquals(-1, replicatedLogImpl.getSnapshotTerm()); + + 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 + public void testIsPresent() { + assertTrue(replicatedLogImpl.isPresent(0)); + assertTrue(replicatedLogImpl.isPresent(1)); + assertTrue(replicatedLogImpl.isPresent(2)); + assertTrue(replicatedLogImpl.isPresent(3)); + + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 4, new MockPayload("D"))); + replicatedLogImpl.snapshotPreCommit(3, 2); //snapshot on 3 + replicatedLogImpl.snapshotCommit(); + + assertFalse(replicatedLogImpl.isPresent(0)); + assertFalse(replicatedLogImpl.isPresent(1)); + assertFalse(replicatedLogImpl.isPresent(2)); + assertFalse(replicatedLogImpl.isPresent(3)); + assertTrue(replicatedLogImpl.isPresent(4)); + + replicatedLogImpl.snapshotPreCommit(4, 2); //snapshot on 4 + replicatedLogImpl.snapshotCommit(); + assertFalse(replicatedLogImpl.isPresent(4)); + + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 5, new MockPayload("D"))); + assertTrue(replicatedLogImpl.isPresent(5)); + } + + @Test + public void testRemoveFrom() { + + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 4, new MockPayload("E", 2))); + replicatedLogImpl.append(new MockReplicatedLogEntry(2, 5, new MockPayload("F", 3))); + + assertEquals("dataSize", 9, replicatedLogImpl.dataSize()); + + long adjusted = replicatedLogImpl.removeFrom(4); + assertEquals("removeFrom - adjusted", 4, adjusted); + assertEquals("size", 4, replicatedLogImpl.size()); + assertEquals("dataSize", 4, replicatedLogImpl.dataSize()); + + takeSnapshot(1); + + adjusted = replicatedLogImpl.removeFrom(2); + assertEquals("removeFrom - adjusted", 1, adjusted); + assertEquals("size", 1, replicatedLogImpl.size()); + assertEquals("dataSize", 1, replicatedLogImpl.dataSize()); + + assertEquals("removeFrom - adjusted", -1, replicatedLogImpl.removeFrom(0)); + assertEquals("removeFrom - adjusted", -1, replicatedLogImpl.removeFrom(100)); + } + // create a snapshot for test public Map takeSnapshot(final int numEntries) { Map map = new HashMap<>(numEntries); - List entries = replicatedLogImpl.getEntriesTill(numEntries); - for (ReplicatedLogEntry entry : entries) { + + long lastIndex = 0; + long lastTerm = 0; + for(int i = 0; i < numEntries; i++) { + ReplicatedLogEntry entry = replicatedLogImpl.getAtPhysicalIndex(i); map.put(entry.getIndex(), entry.getData().toString()); + lastIndex = entry.getIndex(); + lastTerm = entry.getTerm(); } - int term = (int) replicatedLogImpl.lastTerm(); - int lastIndex = (int) entries.get(entries.size() - 1).getIndex(); - entries.clear(); - replicatedLogImpl.setSnapshotTerm(term); - replicatedLogImpl.setSnapshotIndex(lastIndex); + replicatedLogImpl.snapshotPreCommit(lastIndex, lastTerm); + replicatedLogImpl.snapshotCommit(); return map; @@ -155,22 +304,7 @@ public class AbstractReplicatedLogImplTest { } @Override - public void setSnapshotIndex(final long snapshotIndex) { - this.snapshotIndex = snapshotIndex; - } - - @Override - public void setSnapshotTerm(final long snapshotTerm) { - this.snapshotTerm = snapshotTerm; - } - - @Override - public int dataSize() { - return -1; - } - - public List getEntriesTill(final int index) { - return journal.subList(0, index); + public void appendAndPersist(ReplicatedLogEntry replicatedLogEntry, Procedure callback) { } } }