import java.util.HashMap;
import java.util.Map;
import org.opendaylight.controller.cluster.NonPersistentDataProvider;
+import org.opendaylight.controller.cluster.raft.behaviors.RaftActorBehavior;
import org.opendaylight.controller.cluster.raft.policy.RaftPolicy;
import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload;
import org.slf4j.Logger;
replicatedLog.append(new MockReplicatedLogEntry(term, 0, new MockPayload("1")));
replicatedLog.append(new MockReplicatedLogEntry(term, 1, new MockPayload("2")));
setReplicatedLog(replicatedLog);
+ setCommitIndex(replicatedLog.lastIndex());
}
@Override public ActorRef actorOf(Props props) {
@Override
public SnapshotManager getSnapshotManager() {
SnapshotManager snapshotManager = super.getSnapshotManager();
- snapshotManager.setCreateSnapshotCallable(NoopProcedure.<Void>instance());
+ snapshotManager.setCreateSnapshotRunnable(() -> { });
return snapshotManager;
}
public void captureSnapshotIfReady(ReplicatedLogEntry replicatedLogEntry) {
}
- @Override public void removeFromAndPersist(long index) {
- removeFrom(index);
+ @Override
+ public boolean removeFromAndPersist(long index) {
+ return removeFrom(index) >= 0;
}
@Override
return this.mockLog;
}
}
+
+ @Override
+ public void setCurrentBehavior(final RaftActorBehavior behavior) {
+ super.setCurrentBehavior(behavior);
+ }
}