X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorSnapshotMessageSupport.java;h=bf0fc10aad944ae8539c8b3b2a4da70020500944;hp=2db595d743b727fdde09a66d57f8791c0545ac2f;hb=3fda1a923defdbf18849c6080c3aa19f1ebf2c5f;hpb=55e018bfad0c70b773641142d6fbf009cd67fda4 diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java index 2db595d743..bf0fc10aad 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorSnapshotMessageSupport.java @@ -55,7 +55,7 @@ class RaftActorSnapshotMessageSupport { boolean handleSnapshotMessage(Object message) { if(message instanceof ApplySnapshot ) { - onApplySnapshot(((ApplySnapshot) message).getSnapshot()); + onApplySnapshot((ApplySnapshot) message); return true; } else if (message instanceof SaveSnapshotSuccess) { onSaveSnapshotSuccess((SaveSnapshotSuccess) message); @@ -95,10 +95,10 @@ class RaftActorSnapshotMessageSupport { context.getSnapshotManager().commit(sequenceNumber, currentBehavior); } - private void onApplySnapshot(Snapshot snapshot) { + private void onApplySnapshot(ApplySnapshot message) { log.info("{}: Applying snapshot on follower with snapshotIndex: {}, snapshotTerm: {}", context.getId(), - snapshot.getLastAppliedIndex(), snapshot.getLastAppliedTerm()); + message.getSnapshot().getLastAppliedIndex(), message.getSnapshot().getLastAppliedTerm()); - context.getSnapshotManager().apply(snapshot); + context.getSnapshotManager().apply(message); } }