opendaylight/md-sal/sal-akka-raft/src/main/java/org/opendaylight/controller/cluster/raft/DefaultConfigParamsImpl.java

   1 /*
   2  * Copyright (c) 2014 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.controller.cluster.raft;
   9
  10 import java.util.concurrent.TimeUnit;
  11 import scala.concurrent.duration.FiniteDuration;
  12
  13 /**
  14  * Default implementation of the ConfigParams
  15  *
  16  * If no implementation is provided for ConfigParams, then this will be used.
  17  */
  18 public class DefaultConfigParamsImpl implements ConfigParams {
  19
  20     private static final int SNAPSHOT_BATCH_COUNT = 20000;
  21
  22     private static final int JOURNAL_RECOVERY_LOG_BATCH_SIZE = 1000;
  23
  24     /**
  25      * The maximum election time variance
  26      */
  27     private static final int ELECTION_TIME_MAX_VARIANCE = 100;
  28
  29     private static final int SNAPSHOT_CHUNK_SIZE = 2048 * 1000; //2MB
  30
  31
  32     /**
  33      * The interval at which a heart beat message will be sent to the remote
  34      * RaftActor
  35      * <p/>
  36      * Since this is set to 100 milliseconds the Election timeout should be
  37      * at least 200 milliseconds
  38      */
  39     public static final FiniteDuration HEART_BEAT_INTERVAL =
  40         new FiniteDuration(100, TimeUnit.MILLISECONDS);
  41
  42     private FiniteDuration heartBeatInterval = HEART_BEAT_INTERVAL;
  43     private long snapshotBatchCount = SNAPSHOT_BATCH_COUNT;
  44     private int journalRecoveryLogBatchSize = JOURNAL_RECOVERY_LOG_BATCH_SIZE;
  45     private long isolatedLeaderCheckInterval = HEART_BEAT_INTERVAL.$times(1000).toMillis();
  46
  47     // 12 is just an arbitrary percentage. This is the amount of the total memory that a raft actor's
  48     // in-memory journal can use before it needs to snapshot
  49     private int snapshotDataThresholdPercentage = 12;
  50
  51     private long electionTimeoutFactor = 2;
  52
  53     public void setHeartBeatInterval(FiniteDuration heartBeatInterval) {
  54         this.heartBeatInterval = heartBeatInterval;
  55     }
  56
  57     public void setSnapshotBatchCount(long snapshotBatchCount) {
  58         this.snapshotBatchCount = snapshotBatchCount;
  59     }
  60
  61     public void setSnapshotDataThresholdPercentage(int snapshotDataThresholdPercentage){
  62         this.snapshotDataThresholdPercentage = snapshotDataThresholdPercentage;
  63     }
  64
  65     public void setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize) {
  66         this.journalRecoveryLogBatchSize = journalRecoveryLogBatchSize;
  67     }
  68
  69     public void setIsolatedLeaderCheckInterval(FiniteDuration isolatedLeaderCheckInterval) {
  70         this.isolatedLeaderCheckInterval = isolatedLeaderCheckInterval.toMillis();
  71     }
  72
  73     public void setElectionTimeoutFactor(long electionTimeoutFactor){
  74         this.electionTimeoutFactor = electionTimeoutFactor;
  75     }
  76
  77     @Override
  78     public long getSnapshotBatchCount() {
  79         return snapshotBatchCount;
  80     }
  81
  82     @Override
  83     public int getSnapshotDataThresholdPercentage() {
  84         return snapshotDataThresholdPercentage;
  85     }
  86
  87
  88     @Override
  89     public FiniteDuration getHeartBeatInterval() {
  90         return heartBeatInterval;
  91     }
  92
  93     @Override
  94     public FiniteDuration getElectionTimeOutInterval() {
  95         return getHeartBeatInterval().$times(electionTimeoutFactor);
  96     }
  97
  98     @Override
  99     public int getElectionTimeVariance() {
 100         return ELECTION_TIME_MAX_VARIANCE;
 101     }
 102
 103     @Override
 104     public int getSnapshotChunkSize() {
 105         return SNAPSHOT_CHUNK_SIZE;
 106     }
 107
 108     @Override
 109     public int getJournalRecoveryLogBatchSize() {
 110         return journalRecoveryLogBatchSize;
 111     }
 112
 113     @Override
 114     public long getIsolatedCheckIntervalInMillis() {
 115         return isolatedLeaderCheckInterval;
 116     }
 117
 118     @Override
 119     public long getElectionTimeoutFactor() {
 120         return electionTimeoutFactor;
 121     }
 122 }