import org.opendaylight.controller.cluster.raft.base.messages.ApplySnapshot;
import org.opendaylight.controller.cluster.raft.base.messages.CaptureSnapshot;
import org.opendaylight.controller.cluster.raft.base.messages.CaptureSnapshotReply;
-import org.opendaylight.controller.cluster.raft.behaviors.RaftActorBehavior;
import org.opendaylight.controller.cluster.raft.client.messages.GetSnapshot;
import org.opendaylight.controller.cluster.raft.client.messages.GetSnapshotReply;
import org.slf4j.Logger;
static final String COMMIT_SNAPSHOT = "commit_snapshot";
private final RaftActorContext context;
- private final RaftActorBehavior currentBehavior;
private final RaftActorSnapshotCohort cohort;
private final Logger log;
private Duration snapshotReplyActorTimeout = Duration.create(30, TimeUnit.SECONDS);
- RaftActorSnapshotMessageSupport(RaftActorContext context, RaftActorBehavior currentBehavior,
- RaftActorSnapshotCohort cohort) {
+ RaftActorSnapshotMessageSupport(final RaftActorContext context, final RaftActorSnapshotCohort cohort) {
this.context = context;
- this.currentBehavior = currentBehavior;
this.cohort = cohort;
this.log = context.getLogger();
} else if (message instanceof CaptureSnapshotReply) {
onCaptureSnapshotReply(((CaptureSnapshotReply) message).getSnapshot());
} else if (message.equals(COMMIT_SNAPSHOT)) {
- context.getSnapshotManager().commit(-1, currentBehavior);
+ context.getSnapshotManager().commit(-1);
} else if (message instanceof GetSnapshot) {
onGetSnapshot(sender);
} else {
private void onCaptureSnapshotReply(byte[] snapshotBytes) {
log.debug("{}: CaptureSnapshotReply received by actor: snapshot size {}", context.getId(), snapshotBytes.length);
- context.getSnapshotManager().persist(snapshotBytes, currentBehavior, context.getTotalMemory());
+ context.getSnapshotManager().persist(snapshotBytes, context.getTotalMemory());
}
private void onSaveSnapshotFailure(SaveSnapshotFailure saveSnapshotFailure) {
long sequenceNumber = success.metadata().sequenceNr();
- context.getSnapshotManager().commit(sequenceNumber, currentBehavior);
+ context.getSnapshotManager().commit(sequenceNumber);
}
private void onApplySnapshot(ApplySnapshot message) {