import static org.junit.Assert.assertTrue;
import static org.mockito.Matchers.any;
import static org.mockito.Matchers.anyInt;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.never;
import static org.mockito.Mockito.verify;
import org.opendaylight.controller.cluster.raft.base.messages.ApplyLogEntries;
import org.opendaylight.controller.cluster.raft.base.messages.DeleteEntries;
import org.opendaylight.controller.cluster.raft.base.messages.UpdateElectionTerm;
-import org.opendaylight.controller.cluster.raft.behaviors.RaftActorBehavior;
import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@Mock
private DataPersistenceProvider mockPersistence;
- @Mock
- private RaftActorBehavior mockBehavior;
@Mock
private RaftActorRecoveryCohort mockCohort;
public void setup() {
MockitoAnnotations.initMocks(this);
- doNothing().when(mockCohort).startLogRecoveryBatch(any(int.class));
- doNothing().when(mockCohort).applyCurrentLogRecoveryBatch();
- doNothing().when(mockCohort).applyRecoverySnapshot(any(byte[].class));
- doNothing().when(mockCohort).appendRecoveredLogEntry(any(Payload.class));
- doReturn(null).when(mockCohort).getRestoreFromSnapshot();
- doReturn(true).when(mockPersistence).isRecoveryApplicable();
- doNothing().when(mockPersistence).deleteMessages(any(long.class));
- doNothing().when(mockPersistentProvider).deleteMessages(any(long.class));
- doNothing().when(mockPersistentProvider).deleteSnapshots(any(SnapshotSelectionCriteria.class));
- doNothing().when(mockPersistentProvider).persist(any(Object.class), any(Procedure.class));
-
context = new RaftActorContextImpl(null, null, localId, new ElectionTermImpl(mockPersistentProvider, "test", LOG),
-1, -1, Collections.<String,String>emptyMap(), configParams, mockPersistence, LOG);
- support = new RaftActorRecoverySupport(context, mockBehavior , mockCohort);
- context.setReplicatedLog(ReplicatedLogImpl.newInstance(context, mockBehavior));
+
+ support = new RaftActorRecoverySupport(context, mockCohort);
+
+ doReturn(true).when(mockPersistence).isRecoveryApplicable();
+
+ context.setReplicatedLog(ReplicatedLogImpl.newInstance(context));
}
private void sendMessageToSupport(Object message) {