2 * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
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
8 package org.opendaylight.controller.cluster.raft;
10 import scala.concurrent.duration.FiniteDuration;
12 import java.util.concurrent.TimeUnit;
15 * Default implementation of the ConfigParams
17 * If no implementation is provided for ConfigParams, then this will be used.
19 public class DefaultConfigParamsImpl implements ConfigParams {
21 private static final int SNAPSHOT_BATCH_COUNT = 20000;
23 private static final int JOURNAL_RECOVERY_LOG_BATCH_SIZE = 1000;
26 * The maximum election time variance
28 private static final int ELECTION_TIME_MAX_VARIANCE = 100;
30 private static final int SNAPSHOT_CHUNK_SIZE = 2048 * 1000; //2MB
34 * The interval at which a heart beat message will be sent to the remote
37 * Since this is set to 100 milliseconds the Election timeout should be
38 * at least 200 milliseconds
40 public static final FiniteDuration HEART_BEAT_INTERVAL =
41 new FiniteDuration(100, TimeUnit.MILLISECONDS);
44 private FiniteDuration heartBeatInterval = HEART_BEAT_INTERVAL;
45 private long snapshotBatchCount = SNAPSHOT_BATCH_COUNT;
46 private int journalRecoveryLogBatchSize = JOURNAL_RECOVERY_LOG_BATCH_SIZE;
48 public void setHeartBeatInterval(FiniteDuration heartBeatInterval) {
49 this.heartBeatInterval = heartBeatInterval;
52 public void setSnapshotBatchCount(long snapshotBatchCount) {
53 this.snapshotBatchCount = snapshotBatchCount;
56 public void setJournalRecoveryLogBatchSize(int journalRecoveryLogBatchSize) {
57 this.journalRecoveryLogBatchSize = journalRecoveryLogBatchSize;
61 public long getSnapshotBatchCount() {
62 return snapshotBatchCount;
66 public FiniteDuration getHeartBeatInterval() {
67 return heartBeatInterval;
71 public FiniteDuration getElectionTimeOutInterval() {
72 // returns 2 times the heart beat interval
73 return getHeartBeatInterval().$times(2);
77 public int getElectionTimeVariance() {
78 return ELECTION_TIME_MAX_VARIANCE;
82 public int getSnapshotChunkSize() {
83 return SNAPSHOT_CHUNK_SIZE;
87 public int getJournalRecoveryLogBatchSize() {
88 return journalRecoveryLogBatchSize;