X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorSnapshotMessageSupport.java;h=4a17becd5bc8e37ac09a6895846ff5afaa3b85c2;hb=c9943f5bc72d4cde9356d3bd4cf73d36f4b2f754;hp=5173dc89f7c6b114ab857eb1970a2793b3c2f2e8;hpb=5ed99696d261c5359b2e036acfd2aef864f04a7e;p=controller.git 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 5173dc89f7..4a17becd5b 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 @@ -71,7 +71,8 @@ class RaftActorSnapshotMessageSupport { } private void onCaptureSnapshotReply(byte[] snapshotBytes) { - log.debug("{}: CaptureSnapshotReply received by actor: snapshot size {}", context.getId(), snapshotBytes.length); + log.debug("{}: CaptureSnapshotReply received by actor: snapshot size {}", context.getId(), + snapshotBytes.length); context.getSnapshotManager().persist(snapshotBytes, context.getTotalMemory()); } @@ -100,7 +101,7 @@ class RaftActorSnapshotMessageSupport { private void onGetSnapshot(ActorRef sender) { log.debug("{}: onGetSnapshot", context.getId()); - if(context.getPersistenceProvider().isRecoveryApplicable()) { + if (context.getPersistenceProvider().isRecoveryApplicable()) { CaptureSnapshot captureSnapshot = context.getSnapshotManager().newCaptureSnapshot( context.getReplicatedLog().last(), -1, false); @@ -110,7 +111,8 @@ class RaftActorSnapshotMessageSupport { cohort.createSnapshot(snapshotReplyActor); } else { - Snapshot snapshot = Snapshot.create(new byte[0], Collections.emptyList(), -1, -1, -1, -1, + Snapshot snapshot = Snapshot.create(new byte[0], Collections.emptyList(), + -1, -1, -1, -1, context.getTermInformation().getCurrentTerm(), context.getTermInformation().getVotedFor(), context.getPeerServerInfo(true));