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%2FReplicatedLog.java;h=82d0839bee772bd8efba88a8d1392ab1d336ff1c;hb=ee303a25aa7c90ab9f7f28c1effef5254a4c7676;hp=29d6a4557db8dde765accbfe767b9b4f8debd290;hpb=3019650e87a3fc05f80e8f6359e01ca5f1c5f197;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLog.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLog.java index 29d6a4557d..82d0839bee 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLog.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ReplicatedLog.java @@ -44,7 +44,10 @@ public interface ReplicatedLog { long lastTerm(); /** - * Remove all the entries from the logs >= index + * To be called when we need to remove entries from the in-memory log. + * This method will remove all entries >= index. This method should be used + * during recovery to appropriately trim the log based on persisted + * information * * @param index the index of the log entry */ @@ -52,10 +55,14 @@ public interface ReplicatedLog { /** - * Remove all entries starting from the specified entry and persist the - * information to disk + * To be called when we need to remove entries from the in-memory log and we + * need that information persisted to disk. This method will remove all + * entries >= index. + *
+ * The persisted information would then be used during recovery to properly
+ * reconstruct the state of the in-memory replicated log
*
- * @param index
+ * @param index the index of the log entry
*/
void removeFromAndPersist(long index);
@@ -65,6 +72,13 @@ public interface ReplicatedLog {
*/
void append(ReplicatedLogEntry replicatedLogEntry);
+ /**
+ * Optimization method to increase the capacity of the journal log prior to appending entries.
+ *
+ * @param amount the amount to increase by
+ */
+ void increaseJournalLogCapacity(int amount);
+
/**
*
* @param replicatedLogEntry
@@ -77,6 +91,11 @@ public interface ReplicatedLog {
*/
List