import com.google.common.base.Preconditions;
import java.util.Collections;
import java.util.List;
-import org.opendaylight.controller.cluster.raft.base.messages.DeleteEntries;
+import org.opendaylight.controller.cluster.raft.persisted.DeleteEntries;
/**
* Implementation of ReplicatedLog used by the RaftActor.
}
@Override
- public void removeFromAndPersist(final long logEntryIndex) {
+ 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), deleteProcedure);
+ return true;
}
+
+ return false;
}
@Override