2 * Copyright (c) 2014, 2015 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
9 package org.opendaylight.controller.cluster.datastore;
11 import static org.junit.Assert.assertEquals;
12 import static org.junit.Assert.assertFalse;
13 import static org.junit.Assert.assertTrue;
14 import com.google.common.collect.Sets;
15 import com.typesafe.config.ConfigFactory;
17 import java.util.List;
19 import org.junit.Assert;
20 import org.junit.BeforeClass;
21 import org.junit.Test;
23 public class ConfigurationImplTest {
25 private static ConfigurationImpl configuration;
28 public static void staticSetup(){
29 configuration = new ConfigurationImpl("module-shards.conf", "modules.conf");
33 public void testConstructor(){
34 Assert.assertNotNull(configuration);
38 public void testGetMemberShardNames(){
39 List<String> memberShardNames =
40 configuration.getMemberShardNames("member-1");
42 assertTrue(memberShardNames.contains("people-1"));
43 assertTrue(memberShardNames.contains("cars-1"));
45 // Retrieve once again to hit cache
48 configuration.getMemberShardNames("member-1");
50 assertTrue(memberShardNames.contains("people-1"));
51 assertTrue(memberShardNames.contains("cars-1"));
56 public void testGetMembersFromShardName(){
57 List<String> members =
58 configuration.getMembersFromShardName("default");
60 assertEquals(3, members.size());
62 assertTrue(members.contains("member-1"));
63 assertTrue(members.contains("member-2"));
64 assertTrue(members.contains("member-3"));
66 assertFalse(members.contains("member-26"));
68 // Retrieve once again to hit cache
70 configuration.getMembersFromShardName("default");
72 assertEquals(3, members.size());
74 assertTrue(members.contains("member-1"));
75 assertTrue(members.contains("member-2"));
76 assertTrue(members.contains("member-3"));
78 assertFalse(members.contains("member-26"));
81 // Try to find a shard which is not present
84 configuration.getMembersFromShardName("foobar");
86 assertEquals(0, members.size());
90 public void testReadConfigurationFromFile(){
91 File f = new File("./module-shards.conf");
92 ConfigFactory.parseFile(f);
96 public void testGetAllShardNames(){
97 Set<String> allShardNames = configuration.getAllShardNames();
99 assertEquals(4, allShardNames.size());
100 assertTrue(allShardNames.contains("default"));
101 assertTrue(allShardNames.contains("people-1"));
102 assertTrue(allShardNames.contains("cars-1"));
103 assertTrue(allShardNames.contains("test-1"));
107 public void testGetUniqueMemberNamesForAllShards() {
108 assertEquals("getUniqueMemberNamesForAllShards", Sets.newHashSet("member-1", "member-2", "member-3"),
109 configuration.getUniqueMemberNamesForAllShards());