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%2FSnapshotManagerTest.java;h=27596dff74f6a0b83ebab2775cf507d7515900fb;hb=refs%2Fchanges%2F18%2F32818%2F2;hp=6b0cd3a33e4c949f643a58ddc485929def58ff7d;hpb=bd8bff811e5f2af4622e1543106c240db8e4b2f2;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/SnapshotManagerTest.java b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/SnapshotManagerTest.java index 6b0cd3a33e..27596dff74 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/SnapshotManagerTest.java +++ b/opendaylight/md-sal/sal-akka-raft/src/test/java/org/opendaylight/controller/cluster/raft/SnapshotManagerTest.java @@ -14,7 +14,6 @@ import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertTrue; import static org.mockito.Matchers.any; import static org.mockito.Matchers.anyLong; -import static org.mockito.Mockito.doNothing; import static org.mockito.Mockito.doReturn; import static org.mockito.Mockito.doThrow; import static org.mockito.Mockito.mock; @@ -72,7 +71,7 @@ public class SnapshotManagerTest extends AbstractActorTest { private TestActorRef actorRef; @Before - public void setUp() throws Exception { + public void setUp(){ MockitoAnnotations.initMocks(this); doReturn(false).when(mockRaftActorContext).hasFollowers(); @@ -83,8 +82,6 @@ public class SnapshotManagerTest extends AbstractActorTest { doReturn("123").when(mockRaftActorContext).getId(); doReturn(mockDataPersistenceProvider).when(mockRaftActorContext).getPersistenceProvider(); doReturn("123").when(mockRaftActorBehavior).getLeaderId(); - doReturn(null).when(mockRaftActorBehavior).handleMessage(any(ActorRef.class), any(Object.class)); - doReturn(0L).when(mockRaftActorBehavior).getReplicatedToAllIndex(); doReturn(mockElectionTerm).when(mockRaftActorContext).getTermInformation(); doReturn(5L).when(mockElectionTerm).getCurrentTerm(); @@ -95,26 +92,6 @@ public class SnapshotManagerTest extends AbstractActorTest { actorRef = factory.createTestActor(MessageCollectorActor.props(), factory.generateActorId("test-")); doReturn(actorRef).when(mockRaftActorContext).getActor(); - doReturn(0L).when(mockRaftActorContext).getLastApplied(); - doReturn(null).when(mockRaftActorContext).getPeerServerInfo(any(boolean.class)); - doReturn(null).when(mockReplicatedLog).get(any(long.class)); - doReturn(null).when(mockReplicatedLog).getFrom(any(long.class)); - doReturn(0).when(mockReplicatedLog).dataSize(); - doReturn(0L).when(mockReplicatedLog).size(); - doReturn(0L).when(mockReplicatedLog).getSnapshotIndex(); - doReturn(0L).when(mockReplicatedLog).getSnapshotTerm(); - doNothing().when(mockReplicatedLog).snapshotPreCommit(any(long.class), any(long.class)); - doNothing().when(mockReplicatedLog).snapshotRollback(); - doNothing().when(mockReplicatedLog).snapshotCommit(); - doNothing().when(mockRaftActorBehavior).setReplicatedToAllIndex(any(long.class)); - - doReturn(0L).when(mockDataPersistenceProvider).getLastSequenceNumber(); - doNothing().when(mockDataPersistenceProvider).saveSnapshot(any(Object.class)); - doNothing().when(mockDataPersistenceProvider).persist(any(Object.class), any(Procedure.class)); - doNothing().when(mockDataPersistenceProvider).deleteSnapshots(any(SnapshotSelectionCriteria.class)); - doNothing().when(mockDataPersistenceProvider).deleteMessages(any(long.class)); - - doNothing().when(mockProcedure).apply(null); snapshotManager.setCreateSnapshotCallable(mockProcedure); }