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;h=238b7e77852b34f242c0d500cec206960deedba4;hb=bfe4439155b27fbf9ae300252420c8a81fcbdb80;hp=466609d8938c7c9674af0d3954fb6b9e7fa6c7f3;hpb=93ccb43ad0f5c78337f19884a51e2bd479cc46fd;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 466609d893..238b7e7785 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 @@ -12,6 +12,7 @@ import com.google.common.base.Preconditions; import org.opendaylight.controller.cluster.DataPersistenceProvider; import org.opendaylight.controller.cluster.DelegatingPersistentDataProvider; import org.opendaylight.controller.cluster.PersistentDataProvider; +import org.opendaylight.controller.cluster.raft.protobuff.client.messages.Payload; import org.opendaylight.controller.cluster.raft.protobuff.client.messages.PersistentPayload; /** @@ -30,20 +31,43 @@ class RaftActorDelegatingPersistentDataProvider extends DelegatingPersistentData } @Override - public void persist(T o, Procedure procedure) { - if(getDelegate().isRecoveryApplicable()) { - super.persist(o, procedure); - } else { - boolean isPersistentPayload = false; - if(o instanceof ReplicatedLogEntry) { - isPersistentPayload = ((ReplicatedLogEntry)o).getData() instanceof PersistentPayload; - } + public void persist(final T entry, final Procedure procedure) { + doPersist(entry, procedure, false); + } + + @Override + public void persistAsync(T entry, Procedure procedure) { + doPersist(entry, procedure, true); + } - if(isPersistentPayload) { - persistentProvider.persist(o, procedure); + private void doPersist(final T entry, final Procedure procedure, final boolean async) { + if (getDelegate().isRecoveryApplicable()) { + persistSuper(entry, procedure, async); + } else { + if (entry instanceof ReplicatedLogEntry) { + Payload payload = ((ReplicatedLogEntry)entry).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. + if (async) { + persistentProvider.persistAsync(payload, p -> procedure.apply(entry)); + } else { + persistentProvider.persist(payload, p -> procedure.apply(entry)); + } + } else { + persistSuper(entry, procedure, async); + } } else { - super.persist(o, procedure); + persistSuper(entry, procedure, async); } } } + + private void persistSuper(final T object, final Procedure procedure, final boolean async) { + if (async) { + super.persistAsync(object, procedure); + } else { + super.persist(object, procedure); + } + } }