* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.controller.cluster.raft;
import static org.junit.Assert.assertArrayEquals;
import akka.actor.ActorRef;
import akka.persistence.SnapshotSelectionCriteria;
import java.io.OutputStream;
-import java.util.Arrays;
+import java.util.List;
import java.util.Optional;
import java.util.function.Consumer;
import org.junit.After;
@Test
public void testConstruction() {
- assertEquals(false, snapshotManager.isCapturing());
+ assertFalse(snapshotManager.isCapturing());
}
@SuppressWarnings({ "unchecked", "rawtypes" })
snapshotManager.captureToInstall(new SimpleReplicatedLogEntry(0, 1,
new MockRaftActorContext.MockPayload()), 0, "follower-1");
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
ArgumentCaptor<Optional> outputStream = ArgumentCaptor.forClass(Optional.class);
verify(mockProcedure).accept(outputStream.capture());
assertTrue(capture);
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
ArgumentCaptor<Optional> outputStream = ArgumentCaptor.forClass(Optional.class);
verify(mockProcedure).accept(outputStream.capture());
assertTrue(capture);
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
ArgumentCaptor<Optional> outputStream = ArgumentCaptor.forClass(Optional.class);
verify(mockProcedure).accept(outputStream.capture());
assertFalse(capture);
- assertEquals(false, snapshotManager.isCapturing());
+ assertFalse(snapshotManager.isCapturing());
verify(mockProcedure).accept(any());
}
8L, 2L, new MockRaftActorContext.MockPayload());
doReturn(lastAppliedEntry).when(mockReplicatedLog).get(8L);
- doReturn(Arrays.asList(lastLogEntry)).when(mockReplicatedLog).getFrom(9L);
+ doReturn(List.of(lastLogEntry)).when(mockReplicatedLog).getFrom(9L);
// when replicatedToAllIndex = -1
snapshotManager.capture(lastLogEntry, -1);
assertEquals("getLastAppliedTerm", 2L, snapshot.getLastAppliedTerm());
assertEquals("getLastAppliedIndex", 8L, snapshot.getLastAppliedIndex());
assertEquals("getState", snapshotState, snapshot.getState());
- assertEquals("getUnAppliedEntries", Arrays.asList(lastLogEntry), snapshot.getUnAppliedEntries());
+ assertEquals("getUnAppliedEntries", List.of(lastLogEntry), snapshot.getUnAppliedEntries());
assertEquals("electionTerm", mockElectionTerm.getCurrentTerm(), snapshot.getElectionTerm());
assertEquals("electionVotedFor", mockElectionTerm.getVotedFor(), snapshot.getElectionVotedFor());
snapshotManager.persist(snapshotState, installSnapshotStream, Runtime.getRuntime().totalMemory());
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
verify(mockDataPersistenceProvider).saveSnapshot(any(Snapshot.class));
snapshotManager.persist(ByteState.empty(), Optional.empty(), Runtime.getRuntime().totalMemory());
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
snapshotManager.commit(100L, 1234L);
- assertEquals(false, snapshotManager.isCapturing());
+ assertFalse(snapshotManager.isCapturing());
verify(mockReplicatedLog).snapshotCommit();
assertTrue(capture);
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
snapshotManager.trimLog(10);
assertTrue(capture);
- assertEquals(true, snapshotManager.isCapturing());
+ assertTrue(snapshotManager.isCapturing());
snapshotManager.trimLog(10);