X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fclustered-data-store%2Fimplementation%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fdatastore%2Finternal%2FClusteredDataStoreManagerTest.java;h=10f9622c7ae981ea5e095f59789e2596d20f7cba;hp=84b07e7cd4dfd971d3e53ee938333e33e7913004;hb=8baeda4ab8d240f847cd530ef6af7c7c1c2d4d13;hpb=0b3fe7299bbeccc10f2c1b859f95de07c168ac9f

diff --git a/opendaylight/md-sal/clustered-data-store/implementation/src/test/java/org/opendaylight/controller/datastore/internal/ClusteredDataStoreManagerTest.java b/opendaylight/md-sal/clustered-data-store/implementation/src/test/java/org/opendaylight/controller/datastore/internal/ClusteredDataStoreManagerTest.java
index 84b07e7cd4..10f9622c7a 100644
--- a/opendaylight/md-sal/clustered-data-store/implementation/src/test/java/org/opendaylight/controller/datastore/internal/ClusteredDataStoreManagerTest.java
+++ b/opendaylight/md-sal/clustered-data-store/implementation/src/test/java/org/opendaylight/controller/datastore/internal/ClusteredDataStoreManagerTest.java
@@ -1,5 +1,15 @@
+/*
+ * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
 package org.opendaylight.controller.datastore.internal;
 
+import java.util.concurrent.ConcurrentHashMap;
+
 import org.apache.felix.dm.Component;
 import org.junit.BeforeClass;
 import org.junit.Test;
@@ -8,7 +18,8 @@ import org.opendaylight.controller.clustering.services.CacheExistException;
 import org.opendaylight.controller.clustering.services.IClusterGlobalServices;
 import org.opendaylight.controller.md.sal.common.api.data.DataCommitHandler.DataCommitTransaction;
 import org.opendaylight.controller.md.sal.common.api.data.DataModification;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.data.api.CompositeNode;
+import org.opendaylight.yangtools.yang.data.api.InstanceIdentifier;
 
 import static junit.framework.Assert.assertNotNull;
 import static org.junit.Assert.assertEquals;
@@ -20,103 +31,78 @@ import static org.mockito.Mockito.spy;
 import static org.mockito.Mockito.when;
 
 public class ClusteredDataStoreManagerTest {
-	
-	private  static ClusteredDataStoreManager clusteredDSMgr = null;
-	private IClusterGlobalServices icClusterGlbServices =  mock(IClusterGlobalServices.class);
-	 
-	@BeforeClass
-	public static void construct(){
-		clusteredDSMgr = new ClusteredDataStoreManager();
+
+    private static ClusteredDataStoreManager clusteredDSMgr = null;
+    private IClusterGlobalServices icClusterGlbServices = mock(IClusterGlobalServices.class);
+
+    @BeforeClass
+    public static void construct() {
+        clusteredDSMgr = new ClusteredDataStoreManager();
         assertNotNull(clusteredDSMgr);
-	}
-	 
-	@Test
-	public void construct_OnSetClusterGlobalServices_AssertNoException(){
-		icClusterGlbServices =  mock(IClusterGlobalServices.class);
-		 
-		clusteredDSMgr.setClusterGlobalServices(icClusterGlbServices);
-	 }
-	 
-	 @Test
-	 public void construct_OnUnSetClusterGlobalServices_AssertNoException(){
-		 IClusterGlobalServices icClusterGlbServices =  mock(IClusterGlobalServices.class);
-		 
-		 clusteredDSMgr.unsetClusterGlobalServices(icClusterGlbServices);
-	 }
-	 
-	 @Test
-	 public void construct_init_AssertNoException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreImpl clusteredDSImpl =  mock(ClusteredDataStoreImpl.class);
-		 
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-	 }
-	 
-	 @Test(expected = IllegalStateException.class)
-	 public void construct_init_AssertCacheExistException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doThrow(CacheExistException.class).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-	 }
-	 
-	 @Test(expected = IllegalStateException.class)
-	 public void construct_init_AssertCacheConfigException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doThrow(CacheConfigException.class).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-	 }
-	 
-	 @Test
-	 public void construct_readOperationalData_AssertNoException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreImpl clusteredDSImpl =  mock(ClusteredDataStoreImpl.class);
-		 
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-		 
-		 Object o = mock(Object.class);
-		 
-		 when(clusteredDSImpl.readOperationalData(any(InstanceIdentifier.class))).thenReturn(o);
-		 assertEquals(o,clusteredDSManager.readOperationalData(any(InstanceIdentifier.class)));
-	 }
-	 
-	 
-	 @Test
-	 public void construct_readConfigurationData_AssertNoException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreImpl clusteredDSImpl =  mock(ClusteredDataStoreImpl.class);
-		 
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-		 Object o = mock(Object.class);
-		 
-		 when(clusteredDSImpl.readConfigurationData(any(InstanceIdentifier.class))).thenReturn(o);
-		 assertEquals(o,clusteredDSManager.readConfigurationData(any(InstanceIdentifier.class)));
-	 }
-	 
-	 @Test
-	 public void construct_requestCommit_AssertNoException() throws CacheExistException,CacheConfigException{
-		 ClusteredDataStoreImpl clusteredDSImpl =  mock(ClusteredDataStoreImpl.class);
-		 
-		 ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
-		 doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore(any(Component.class));
-		 Component c = mock(Component.class);
-		 
-		 clusteredDSManager.init(c);
-		 DataCommitTransaction dataCommitTransaction = mock(DataCommitTransaction.class);
-		 
-		 when(clusteredDSImpl.requestCommit(any(DataModification.class))).thenReturn(dataCommitTransaction);
-		 assertEquals(dataCommitTransaction,clusteredDSManager.requestCommit(any(DataModification.class)));
-	 }
+    }
+
+    @Test
+    public void construct_OnSetClusterGlobalServices_AssertNoException() {
+        doReturn(new ConcurrentHashMap<InstanceIdentifier, CompositeNode>()).when(icClusterGlbServices).getCache(ClusteredDataStoreImpl.CONFIGURATION_DATA_CACHE);
+        doReturn(new ConcurrentHashMap<InstanceIdentifier, CompositeNode>()).when(icClusterGlbServices).getCache(ClusteredDataStoreImpl.OPERATIONAL_DATA_CACHE);
+        clusteredDSMgr.setClusterGlobalServices(icClusterGlbServices);
+    }
+
+    @Test
+    public void construct_init_AssertNoException() throws CacheExistException, CacheConfigException {
+        ClusteredDataStoreImpl clusteredDSImpl = mock(ClusteredDataStoreImpl.class);
+
+        ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
+        doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore();
+        clusteredDSManager.start();
+    }
+
+
+    @Test
+    public void construct_readOperationalData_AssertNoException() throws CacheExistException, CacheConfigException {
+        ClusteredDataStoreImpl clusteredDSImpl = mock(ClusteredDataStoreImpl.class);
+
+        ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
+        doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore();
+        Component c = mock(Component.class);
+        
+        clusteredDSManager.start();
+        clusteredDSManager.setClusterGlobalServices(icClusterGlbServices);
+        CompositeNode o = mock(CompositeNode.class);
+
+        when(clusteredDSImpl.readOperationalData(any(InstanceIdentifier.class))).thenReturn(o);
+        assertEquals(o, clusteredDSManager.readOperationalData(any(InstanceIdentifier.class)));
+    }
+
+    @Test
+    public void construct_readConfigurationData_AssertNoException() throws CacheExistException, CacheConfigException {
+        ClusteredDataStoreImpl clusteredDSImpl = mock(ClusteredDataStoreImpl.class);
+
+        ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
+        doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore();
+        Component c = mock(Component.class);
+
+        clusteredDSManager.start();
+        clusteredDSManager.setClusterGlobalServices(icClusterGlbServices);
+        
+        CompositeNode o = mock(CompositeNode.class);
+
+        when(clusteredDSImpl.readConfigurationData(any(InstanceIdentifier.class))).thenReturn(o);
+        assertEquals(o, clusteredDSManager.readConfigurationData(any(InstanceIdentifier.class)));
+    }
+
+    @Test
+    public void construct_requestCommit_AssertNoException() throws CacheExistException, CacheConfigException {
+        ClusteredDataStoreImpl clusteredDSImpl = mock(ClusteredDataStoreImpl.class);
+
+        ClusteredDataStoreManager clusteredDSManager = spy(new ClusteredDataStoreManager());
+        doReturn(clusteredDSImpl).when(clusteredDSManager).createClusteredDataStore();
+        IClusterGlobalServices globalServices = mock(IClusterGlobalServices.class);
+        clusteredDSManager.setClusterGlobalServices(globalServices);
+        clusteredDSManager.start();
+        DataCommitTransaction dataCommitTransaction = mock(DataCommitTransaction.class);
+
+        when(clusteredDSImpl.requestCommit(any(DataModification.class))).thenReturn(dataCommitTransaction);
+        assertEquals(dataCommitTransaction, clusteredDSManager.requestCommit(any(DataModification.class)));
+    }
 }