opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DatastoreContextTest.java

   1 /*
   2  * Copyright (c) 2014, 2015 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.datastore;
   9
  10 import static org.junit.Assert.assertEquals;
  11 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_CONFIGURATION_READER;
  12 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS;
  13 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_INITIAL_PAYLOAD_SERIALIZED_BUFFER_CAPACITY;
  14 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_INITIAL_SETTLE_TIMEOUT_MULTIPLIER;
  15 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_ISOLATED_LEADER_CHECK_INTERVAL_IN_MILLIS;
  16 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE;
  17 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_MAX_MESSAGE_SLICE_SIZE;
  18 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_OPERATION_TIMEOUT_IN_MS;
  19 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_PERSISTENT;
  20 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_RECOVERY_EXPORT_BASE_DIR;
  21 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_RECOVERY_SNAPSHOT_INTERVAL_SECONDS;
  22 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_BATCHED_MODIFICATION_COUNT;
  23 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_ELECTION_TIMEOUT_FACTOR;
  24 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_INITIALIZATION_TIMEOUT;
  25 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_LEADER_ELECTION_TIMEOUT;
  26 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD;
  27 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD_PERCENTAGE;
  28 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT;
  29 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_TX_COMMIT_QUEUE_CAPACITY;
  30 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SHARD_TX_COMMIT_TIMEOUT_IN_SECONDS;
  31 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_SNAPSHOT_BATCH_COUNT;
  32 import static org.opendaylight.controller.cluster.datastore.DatastoreContext.DEFAULT_TX_CREATION_INITIAL_RATE_LIMIT;
  33
  34 import java.util.concurrent.TimeUnit;
  35 import org.junit.Assert;
  36 import org.junit.Test;
  37 import org.opendaylight.mdsal.dom.store.inmemory.InMemoryDOMDataStoreConfigProperties;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.distributed.datastore.provider.rev140612.DataStoreProperties.ExportOnRecovery;
  39
  40 public class DatastoreContextTest {
  41
  42     @Test
  43     public void testNewBuilderWithDefaultSettings() {
  44         DatastoreContext context = DatastoreContext.newBuilder().build();
  45
  46         assertEquals(DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT, context.getShardTransactionIdleTimeout());
  47         assertEquals(DEFAULT_OPERATION_TIMEOUT_IN_MS, context.getOperationTimeoutInMillis());
  48         assertEquals(DEFAULT_SHARD_TX_COMMIT_TIMEOUT_IN_SECONDS, context.getShardTransactionCommitTimeoutInSeconds());
  49         assertEquals(DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE,
  50                 context.getShardRaftConfig().getJournalRecoveryLogBatchSize());
  51         assertEquals(DEFAULT_SNAPSHOT_BATCH_COUNT, context.getShardRaftConfig().getSnapshotBatchCount());
  52         assertEquals(DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS,
  53                 context.getShardRaftConfig().getHeartBeatInterval().length());
  54         assertEquals(DEFAULT_SHARD_TX_COMMIT_QUEUE_CAPACITY, context.getShardTransactionCommitQueueCapacity());
  55         assertEquals(DEFAULT_SHARD_INITIALIZATION_TIMEOUT.duration().toMillis(),
  56                 context.getShardInitializationTimeout().duration().toMillis());
  57         assertEquals(DEFAULT_SHARD_LEADER_ELECTION_TIMEOUT.duration().toMillis(),
  58                 context.getShardLeaderElectionTimeout().duration().toMillis());
  59         assertEquals(DEFAULT_INITIAL_SETTLE_TIMEOUT_MULTIPLIER,
  60                 context.getInitialSettleTimeoutMultiplier());
  61         assertEquals(DEFAULT_PERSISTENT, context.isPersistent());
  62         assertEquals(DEFAULT_CONFIGURATION_READER, context.getConfigurationReader());
  63         assertEquals(DEFAULT_ISOLATED_LEADER_CHECK_INTERVAL_IN_MILLIS,
  64                 context.getShardRaftConfig().getIsolatedCheckIntervalInMillis());
  65         assertEquals(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD_PERCENTAGE,
  66                 context.getShardRaftConfig().getSnapshotDataThresholdPercentage());
  67         assertEquals(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD,
  68                 context.getShardRaftConfig().getSnapshotDataThreshold());
  69         assertEquals(DEFAULT_SHARD_ELECTION_TIMEOUT_FACTOR, context.getShardRaftConfig().getElectionTimeoutFactor());
  70         assertEquals(DEFAULT_TX_CREATION_INITIAL_RATE_LIMIT, context.getTransactionCreationInitialRateLimit());
  71         assertEquals(DatastoreContext.DEFAULT_SHARD_BATCHED_MODIFICATION_COUNT,
  72                 context.getShardBatchedModificationCount());
  73         assertEquals(DEFAULT_MAX_MESSAGE_SLICE_SIZE, context.getMaximumMessageSliceSize());
  74         assertEquals(DEFAULT_RECOVERY_EXPORT_BASE_DIR, context.getRecoveryExportBaseDir());
  75     }
  76
  77     @Test
  78     public void testNewBuilderWithCustomSettings() {
  79         DatastoreContext.Builder builder = DatastoreContext.newBuilder();
  80
  81         builder.shardTransactionIdleTimeout(DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT.toMillis() + 1,
  82                 TimeUnit.MILLISECONDS);
  83         builder.operationTimeoutInSeconds((int) (TimeUnit.MILLISECONDS.toSeconds(DEFAULT_OPERATION_TIMEOUT_IN_MS) + 1));
  84         builder.shardTransactionCommitTimeoutInSeconds(DEFAULT_SHARD_TX_COMMIT_TIMEOUT_IN_SECONDS + 1);
  85         builder.shardJournalRecoveryLogBatchSize(DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE + 1);
  86         builder.shardSnapshotBatchCount(DEFAULT_SNAPSHOT_BATCH_COUNT + 1);
  87         builder.recoverySnapshotIntervalSeconds(DEFAULT_RECOVERY_SNAPSHOT_INTERVAL_SECONDS + 1);
  88         builder.shardHeartbeatIntervalInMillis(DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS + 1);
  89         builder.shardTransactionCommitQueueCapacity(DEFAULT_SHARD_TX_COMMIT_QUEUE_CAPACITY + 1);
  90         builder.shardInitializationTimeout(DEFAULT_SHARD_INITIALIZATION_TIMEOUT
  91                 .duration().toMillis() + 1, TimeUnit.MILLISECONDS);
  92         builder.shardInitializationTimeout(DEFAULT_SHARD_INITIALIZATION_TIMEOUT.duration().toMillis() + 1,
  93                 TimeUnit.MILLISECONDS);
  94         builder.shardLeaderElectionTimeout(DEFAULT_SHARD_LEADER_ELECTION_TIMEOUT.duration().toMillis() + 1,
  95                 TimeUnit.MILLISECONDS);
  96         builder.initialSettleTimeoutMultiplier(DEFAULT_INITIAL_SETTLE_TIMEOUT_MULTIPLIER + 1);
  97         builder.persistent(!DEFAULT_PERSISTENT);
  98         builder.shardIsolatedLeaderCheckIntervalInMillis(DEFAULT_ISOLATED_LEADER_CHECK_INTERVAL_IN_MILLIS + 1);
  99         builder.shardSnapshotDataThresholdPercentage(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD_PERCENTAGE + 1);
 100         builder.shardSnapshotDataThreshold(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD + 1);
 101         builder.shardElectionTimeoutFactor(DEFAULT_SHARD_ELECTION_TIMEOUT_FACTOR + 1);
 102         builder.transactionCreationInitialRateLimit(DEFAULT_TX_CREATION_INITIAL_RATE_LIMIT + 1);
 103         builder.shardBatchedModificationCount(DEFAULT_SHARD_BATCHED_MODIFICATION_COUNT + 1);
 104         builder.maxShardDataChangeExecutorPoolSize(
 105                 InMemoryDOMDataStoreConfigProperties.DEFAULT_MAX_DATA_CHANGE_EXECUTOR_POOL_SIZE + 1);
 106         builder.maxShardDataChangeExecutorQueueSize(
 107                 InMemoryDOMDataStoreConfigProperties.DEFAULT_MAX_DATA_CHANGE_EXECUTOR_QUEUE_SIZE + 1);
 108         builder.maxShardDataChangeListenerQueueSize(
 109                 InMemoryDOMDataStoreConfigProperties.DEFAULT_MAX_DATA_CHANGE_LISTENER_QUEUE_SIZE + 1);
 110         builder.maxShardDataStoreExecutorQueueSize(
 111                 InMemoryDOMDataStoreConfigProperties.DEFAULT_MAX_DATA_STORE_EXECUTOR_QUEUE_SIZE + 1);
 112         builder.maximumMessageSliceSize(DEFAULT_MAX_MESSAGE_SLICE_SIZE + 1);
 113         builder.initialPayloadSerializedBufferCapacity(DEFAULT_INITIAL_PAYLOAD_SERIALIZED_BUFFER_CAPACITY + 1);
 114         builder.exportOnRecovery(ExportOnRecovery.Json);
 115         builder.recoveryExportBaseDir(DEFAULT_RECOVERY_EXPORT_BASE_DIR + "-new");
 116
 117         DatastoreContext context = builder.build();
 118
 119         verifyCustomSettings(context);
 120
 121         builder = DatastoreContext.newBuilderFrom(context);
 122
 123         DatastoreContext newContext = builder.build();
 124
 125         verifyCustomSettings(newContext);
 126
 127         Assert.assertNotSame(context, newContext);
 128     }
 129
 130     private static void verifyCustomSettings(final DatastoreContext context) {
 131         assertEquals(DEFAULT_SHARD_TRANSACTION_IDLE_TIMEOUT.toMillis() + 1,
 132                 context.getShardTransactionIdleTimeout().toMillis());
 133         assertEquals(TimeUnit.MILLISECONDS.toSeconds(DEFAULT_OPERATION_TIMEOUT_IN_MS) + 1,
 134                 TimeUnit.MILLISECONDS.toSeconds(context.getOperationTimeoutInMillis()));
 135         assertEquals(DEFAULT_SHARD_TX_COMMIT_TIMEOUT_IN_SECONDS + 1,
 136                 context.getShardTransactionCommitTimeoutInSeconds());
 137         assertEquals(DEFAULT_JOURNAL_RECOVERY_BATCH_SIZE + 1,
 138                 context.getShardRaftConfig().getJournalRecoveryLogBatchSize());
 139         assertEquals(DEFAULT_SNAPSHOT_BATCH_COUNT + 1, context.getShardRaftConfig().getSnapshotBatchCount());
 140         assertEquals(DEFAULT_RECOVERY_SNAPSHOT_INTERVAL_SECONDS + 1,
 141                 context.getShardRaftConfig().getRecoverySnapshotIntervalSeconds());
 142         assertEquals(DEFAULT_HEARTBEAT_INTERVAL_IN_MILLIS + 1,
 143                 context.getShardRaftConfig().getHeartBeatInterval().length());
 144         assertEquals(DEFAULT_SHARD_TX_COMMIT_QUEUE_CAPACITY + 1, context.getShardTransactionCommitQueueCapacity());
 145         assertEquals(DEFAULT_SHARD_INITIALIZATION_TIMEOUT.duration().toMillis() + 1,
 146                 context.getShardInitializationTimeout().duration().toMillis());
 147         assertEquals(DEFAULT_SHARD_LEADER_ELECTION_TIMEOUT.duration().toMillis() + 1,
 148                 context.getShardLeaderElectionTimeout().duration().toMillis());
 149         assertEquals(DEFAULT_INITIAL_SETTLE_TIMEOUT_MULTIPLIER + 1,
 150                 context.getInitialSettleTimeoutMultiplier());
 151         assertEquals(!DEFAULT_PERSISTENT, context.isPersistent());
 152         assertEquals(DEFAULT_CONFIGURATION_READER, context.getConfigurationReader());
 153         assertEquals(DEFAULT_ISOLATED_LEADER_CHECK_INTERVAL_IN_MILLIS + 1,
 154                 context.getShardRaftConfig().getIsolatedCheckIntervalInMillis());
 155         assertEquals(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD_PERCENTAGE + 1,
 156                 context.getShardRaftConfig().getSnapshotDataThresholdPercentage());
 157         assertEquals(DEFAULT_SHARD_SNAPSHOT_DATA_THRESHOLD + 1,
 158                 context.getShardRaftConfig().getSnapshotDataThreshold());
 159         assertEquals(DEFAULT_SHARD_ELECTION_TIMEOUT_FACTOR + 1,
 160                 context.getShardRaftConfig().getElectionTimeoutFactor());
 161         assertEquals(DEFAULT_TX_CREATION_INITIAL_RATE_LIMIT + 1, context.getTransactionCreationInitialRateLimit());
 162         assertEquals(DatastoreContext.DEFAULT_SHARD_BATCHED_MODIFICATION_COUNT + 1,
 163                 context.getShardBatchedModificationCount());
 164         assertEquals(DEFAULT_MAX_MESSAGE_SLICE_SIZE + 1, context.getMaximumMessageSliceSize());
 165         assertEquals(DEFAULT_INITIAL_PAYLOAD_SERIALIZED_BUFFER_CAPACITY + 1,
 166                 context.getInitialPayloadSerializedBufferCapacity());
 167         assertEquals(DEFAULT_RECOVERY_EXPORT_BASE_DIR + "-new",
 168                 context.getRecoveryExportBaseDir());
 169         assertEquals(ExportOnRecovery.Json, context.getExportOnRecovery());
 170     }
 171 }