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     private FiniteDuration electionTimeOutInterval;
  47
  48     // 12 is just an arbitrary percentage. This is the amount of the total memory that a raft actor's
  49     // in-memory journal can use before it needs to snapshot
  50     private int snapshotDataThresholdPercentage = 12;
  51
  52     private long electionTimeoutFactor = 2;
  53
  54     public void setHeartBeatInterval(FiniteDuration heartBeatInterval) {
  55         this.heartBeatInterval = heartBeatInterval;
  56         electionTimeOutInterval = null;
  57     }
  58
  59     public void setSnapshotBatchCount(long snapshotBatchCount) {
  60         this.snapshotBatchCount = snapshotBatchCount;
  61     }
  62
  63     public void setSnapshotDataThresholdPercentage(int snapshotDataThresholdPercentage){
  64         this.snapshotDataThresholdPercentage = snapshotDataThresholdPercentage;
  65     }
  66
  67     public void setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize) {
  68         this.journalRecoveryLogBatchSize = journalRecoveryLogBatchSize;
  69     }
  70
  71     public void setIsolatedLeaderCheckInterval(FiniteDuration isolatedLeaderCheckInterval) {
  72         this.isolatedLeaderCheckInterval = isolatedLeaderCheckInterval.toMillis();
  73     }
  74
  75     public void setElectionTimeoutFactor(long electionTimeoutFactor){
  76         this.electionTimeoutFactor = electionTimeoutFactor;
  77         electionTimeOutInterval = null;
  78     }
  79
  80     @Override
  81     public long getSnapshotBatchCount() {
  82         return snapshotBatchCount;
  83     }
  84
  85     @Override
  86     public int getSnapshotDataThresholdPercentage() {
  87         return snapshotDataThresholdPercentage;
  88     }
  89
  90
  91     @Override
  92     public FiniteDuration getHeartBeatInterval() {
  93         return heartBeatInterval;
  94     }
  95
  96     @Override
  97     public FiniteDuration getElectionTimeOutInterval() {
  98         if(electionTimeOutInterval == null) {
  99             electionTimeOutInterval = getHeartBeatInterval().$times(electionTimeoutFactor);
 100         }
 101
 102         return electionTimeOutInterval;
 103     }
 104
 105     @Override
 106     public int getElectionTimeVariance() {
 107         return ELECTION_TIME_MAX_VARIANCE;
 108     }
 109
 110     @Override
 111     public int getSnapshotChunkSize() {
 112         return SNAPSHOT_CHUNK_SIZE;
 113     }
 114
 115     @Override
 116     public int getJournalRecoveryLogBatchSize() {
 117         return journalRecoveryLogBatchSize;
 118     }
 119
 120     @Override
 121     public long getIsolatedCheckIntervalInMillis() {
 122         return isolatedLeaderCheckInterval;
 123     }
 124
 125     @Override
 126     public long getElectionTimeoutFactor() {
 127         return electionTimeoutFactor;
 128     }
 129 }