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%2FReplicatedLogImpl.java;h=66d7b352a22f3ec94a896104098d3145c4fc30d5;hb=66e956cbf397a86f1a512396feb7cb87ea602f92;hp=c53cad68c5def14c0dae3718ffc01144235db5fe;hpb=7daddd72031b33ed686abe18a0813e41263aac8d;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLogImpl.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLogImpl.java index c53cad68c5..66d7b352a2 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLogImpl.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLogImpl.java @@ -9,9 +9,9 @@ package org.opendaylight.controller.cluster.raft; import static java.util.Objects.requireNonNull; -import akka.japi.Procedure; import java.util.Collections; import java.util.List; +import java.util.function.Consumer; import org.opendaylight.controller.cluster.raft.persisted.DeleteEntries; import org.opendaylight.controller.cluster.raft.persisted.Snapshot; @@ -42,10 +42,9 @@ final class ReplicatedLogImpl extends AbstractReplicatedLogImpl { @Override public boolean removeFromAndPersist(final long logEntryIndex) { - // FIXME: Maybe this should be done after the command is saved long adjustedIndex = removeFrom(logEntryIndex); if (adjustedIndex >= 0) { - context.getPersistenceProvider().persist(new DeleteEntries(adjustedIndex), NoopProcedure.instance()); + context.getPersistenceProvider().persist(new DeleteEntries(logEntryIndex), NoopProcedure.instance()); return true; } @@ -93,7 +92,7 @@ final class ReplicatedLogImpl extends AbstractReplicatedLogImpl { @Override public boolean appendAndPersist(final ReplicatedLogEntry replicatedLogEntry, - final Procedure callback, final boolean doAsync) { + final Consumer callback, final boolean doAsync) { context.getLogger().debug("{}: Append log entry and persist {} ", context.getId(), replicatedLogEntry); @@ -112,24 +111,18 @@ final class ReplicatedLogImpl extends AbstractReplicatedLogImpl { } private void persistCallback(final ReplicatedLogEntry persistedLogEntry, - final Procedure callback) { + final Consumer callback) { context.getExecutor().execute(() -> syncPersistCallback(persistedLogEntry, callback)); } - @SuppressWarnings("checkstyle:illegalCatch") private void syncPersistCallback(final ReplicatedLogEntry persistedLogEntry, - final Procedure callback) { + final Consumer callback) { context.getLogger().debug("{}: persist complete {}", context.getId(), persistedLogEntry); dataSizeSinceLastSnapshot += persistedLogEntry.size(); if (callback != null) { - try { - callback.apply(persistedLogEntry); - } catch (Exception e) { - context.getLogger().error("{}: persist callback failed", context.getId(), e); - throw new IllegalStateException("Persist callback failed", e); - } + callback.accept(persistedLogEntry); } } }