X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-akka-raft%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fraft%2FConfigParams.java;h=8351374d60fe0e73bb5ca2fbfa2ea01cbd5a3f52;hb=HEAD;hp=fb571f11f84179fcfe49ff78434b76daf012e945;hpb=b4bf55727093657662d8c16a50fa85f87978a586;p=controller.git diff --git a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java index fb571f11f8..7f98295a30 100644 --- a/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java +++ b/opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/ConfigParams.java @@ -12,14 +12,9 @@ import org.opendaylight.controller.cluster.raft.policy.RaftPolicy; import scala.concurrent.duration.FiniteDuration; /** - * Configuration Parameter interface for configuring the Raft consensus system - * - *

- * Any component using this implementation might want to provide an implementation of - * this interface to configure - * - *

- * A default implementation will be used if none is provided. + * Configuration Parameter interface for configuring the Raft consensus system. Any component using this implementation + * might want to provide an implementation of this interface to configure. A default implementation will be used if none + * is provided. * * @author Kamal Rameshan */ @@ -35,11 +30,28 @@ public interface ConfigParams { /** * Returns the percentage of total memory used in the in-memory Raft log before a snapshot should be taken. + * Disabled when direct threshold is enabled. * * @return the percentage. */ int getSnapshotDataThresholdPercentage(); + /** + * Returns the max size of memory used in the in-memory Raft log before a snapshot should be taken. 0 means that + * direct threshold is disabled and percentage is used instead. + * + * @return maximum journal size (in MiB). + */ + int getSnapshotDataThreshold(); + + /** + * Returns the interval(in seconds) after which a snapshot should be taken during recovery. Negative value means + * do not take snapshots. + * + * @return the interval of recovery snapshot in seconds + */ + int getRecoverySnapshotIntervalSeconds(); + /** * Returns the interval at which a heart beat message should be sent to remote followers. * @@ -54,6 +66,14 @@ public interface ConfigParams { */ FiniteDuration getElectionTimeOutInterval(); + /** + * Returns the number by which a candidate should divide the election timeout it has calculated. This serves + * to speed up retries when elections result in a stalemate. + * + * @return the interval as a FiniteDuration. + */ + long getCandidateElectionTimeoutDivisor(); + /** * Returns the maximum election time variance. The election is scheduled using both the election timeout * and variance. @@ -67,7 +87,7 @@ public interface ConfigParams { * * @return the maximum size (in bytes). */ - int getSnapshotChunkSize(); + int getMaximumMessageSliceSize(); /** * Returns the maximum number of journal log entries to batch on recovery before applying. @@ -83,7 +103,6 @@ public interface ConfigParams { */ long getIsolatedCheckIntervalInMillis(); - /** * Returns the multiplication factor to be used to determine the shard election timeout. The election timeout * is determined by multiplying the election timeout factor with the heart beat duration. @@ -92,7 +111,6 @@ public interface ConfigParams { */ long getElectionTimeoutFactor(); - /** * Returns the RaftPolicy used to determine certain Raft behaviors. *