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%2FRaftActorDelegatingPersistentDataProvider.java;fp=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FRaftActorDelegatingPersistentDataProvider.java;h=378f33a2be2528071de02ad171f573fb9d791d99;hb=c9943f5bc72d4cde9356d3bd4cf73d36f4b2f754;hp=84e2dafafae8ac78bf94cc539af89a3675662dd3;hpb=5ed99696d261c5359b2e036acfd2aef864f04a7e;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorDelegatingPersistentDataProvider.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorDelegatingPersistentDataProvider.java index 84e2dafafa..378f33a2be 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorDelegatingPersistentDataProvider.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/RaftActorDelegatingPersistentDataProvider.java @@ -31,21 +31,21 @@ class RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentData } @Override - public void persist(final T o, final Procedure procedure) { - if(getDelegate().isRecoveryApplicable()) { - super.persist(o, procedure); + public void persist(final T object, final Procedure procedure) { + if (getDelegate().isRecoveryApplicable()) { + super.persist(object, procedure); } else { - if(o instanceof ReplicatedLogEntry) { - Payload payload = ((ReplicatedLogEntry)o).getData(); - if(payload instanceof PersistentPayload) { + if (object instanceof ReplicatedLogEntry) { + Payload payload = ((ReplicatedLogEntry)object).getData(); + if (payload instanceof PersistentPayload) { // We persist the Payload but not the ReplicatedLogEntry to avoid gaps in the journal indexes // on recovery if data persistence is later enabled. - persistentProvider.persist(payload, p -> procedure.apply(o)); + persistentProvider.persist(payload, p -> procedure.apply(object)); } else { - super.persist(o, procedure); + super.persist(object, procedure); } } else { - super.persist(o, procedure); + super.persist(object, procedure); } } }