opendaylight/hosttracker/integrationtest/src/test/java/org/opendaylight/controller/hosttracker/internal/HostTrackerIntegrationTest.java

   1 \r
   2 /*\r
   3  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.\r
   4  *\r
   5  * This program and the accompanying materials are made available under the\r
   6  * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
   7  * and is available at http://www.eclipse.org/legal/epl-v10.html\r
   8  */\r
   9 \r
  10 package org.opendaylight.controller.hosttracker.internal;\r
  11 \r
  12 \r
  13 import java.net.InetAddress;\r
  14 import java.net.UnknownHostException;\r
  15 import java.util.ArrayList;\r
  16 import java.util.HashSet;\r
  17 import java.util.Iterator;\r
  18 import java.util.List;\r
  19 import java.util.Map;\r
  20 import java.util.Set;\r
  21 import java.util.Map.Entry;\r
  22 \r
  23 import org.slf4j.Logger;\r
  24 import org.slf4j.LoggerFactory;\r
  25 import org.osgi.framework.ServiceReference;\r
  26 import org.osgi.framework.Bundle;\r
  27 import javax.inject.Inject;\r
  28 \r
  29 import org.eclipse.osgi.framework.console.CommandProvider;\r
  30 import org.junit.Assert;\r
  31 import org.junit.Test;\r
  32 import org.junit.Before;\r
  33 import org.junit.After;\r
  34 import org.junit.runner.RunWith;\r
  35 import org.opendaylight.controller.sal.core.Node;\r
  36 import org.opendaylight.controller.sal.core.NodeConnector;\r
  37 import org.opendaylight.controller.sal.core.UpdateType;\r
  38 import org.opendaylight.controller.sal.utils.NodeConnectorCreator;\r
  39 import org.opendaylight.controller.sal.utils.NodeCreator;\r
  40 import org.opendaylight.controller.sal.utils.Status;\r
  41 //import org.opendaylight.controller.hosttracker.*;\r
  42 import org.opendaylight.controller.hosttracker.IfIptoHost;\r
  43 import org.opendaylight.controller.hosttracker.IfHostListener;\r
  44 import org.opendaylight.controller.hosttracker.hostAware.HostNodeConnector;\r
  45 import org.opendaylight.controller.switchmanager.IInventoryListener;\r
  46 import org.opendaylight.controller.switchmanager.ISwitchManager;\r
  47 import org.opendaylight.controller.switchmanager.ISwitchManagerAware;\r
  48 import org.opendaylight.controller.topologymanager.ITopologyManagerAware;\r
  49 \r
  50 import org.ops4j.pax.exam.junit.PaxExam;\r
  51 import org.ops4j.pax.exam.util.Filter;\r
  52 import org.osgi.framework.BundleContext;\r
  53 import static org.junit.Assert.*;\r
  54 import org.ops4j.pax.exam.junit.Configuration;\r
  55 import static org.ops4j.pax.exam.CoreOptions.*;\r
  56 \r
  57 import org.ops4j.pax.exam.Option;\r
  58 import org.ops4j.pax.exam.util.PathUtils;\r
  59 import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;\r
  60 import org.ops4j.pax.exam.spi.reactors.PerClass;\r
  61 \r
  62 @RunWith(PaxExam.class)\r
  63 public class HostTrackerIntegrationTest {\r
  64     private Logger log = LoggerFactory\r
  65             .getLogger(HostTrackerIntegrationTest.class);\r
  66     // get the OSGI bundle context\r
  67     @Inject\r
  68     private BundleContext bc;\r
  69     \r
  70     private IfIptoHost hosttracker = null;\r
  71     private ISwitchManagerAware switchManagerAware = null;\r
  72     private IInventoryListener invtoryListener = null;\r
  73     private IfHostListener hostListener = null;\r
  74     private ITopologyManagerAware topologyManagerAware = null;\r
  75     \r
  76     // Configure the OSGi container\r
  77     @Configuration\r
  78     public Option[] config() {\r
  79         return options(\r
  80                 //\r
  81                 systemProperty("logback.configurationFile").value(\r
  82                         "file:" + PathUtils.getBaseDir()\r
  83                                 + "/src/test/resources/logback.xml"),\r
  84                 // To start OSGi console for inspection remotely\r
  85                 systemProperty("osgi.console").value("2401"),\r
  86                 // Set the systemPackages (used by clustering)\r
  87                 systemPackages("sun.reflect", "sun.reflect.misc", "sun.misc"),\r
  88                 // List framework bundles\r
  89                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.console",\r
  90                         "1.0.0.v20120522-1841"),\r
  91                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.util",\r
  92                         "1.0.400.v20120522-2049"),\r
  93                 mavenBundle("equinoxSDK381", "org.eclipse.osgi.services",\r
  94                         "3.3.100.v20120522-1822"),\r
  95                 mavenBundle("equinoxSDK381", "org.eclipse.equinox.ds",\r
  96                         "1.4.0.v20120522-1841"),\r
  97                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.command",\r
  98                         "0.8.0.v201108120515"),\r
  99                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.runtime",\r
 100                         "0.8.0.v201108120515"),\r
 101                 mavenBundle("equinoxSDK381", "org.apache.felix.gogo.shell",\r
 102                         "0.8.0.v201110170705"),\r
 103                 // List logger bundles\r
 104                 mavenBundle("org.slf4j", "slf4j-api", "1.7.2"),\r
 105                 mavenBundle("org.slf4j", "log4j-over-slf4j", "1.7.2"),\r
 106                 mavenBundle("ch.qos.logback", "logback-core", "1.0.9"),\r
 107                 mavenBundle("ch.qos.logback", "logback-classic", "1.0.9"),\r
 108                 \r
 109                 // List all the bundles on which the test case depends\r
 110                 mavenBundle("org.opendaylight.controller", "sal",\r
 111                         "0.5.0-SNAPSHOT"),\r
 112                 mavenBundle("org.opendaylight.controller", "sal.implementation",\r
 113                         "0.4.0-SNAPSHOT"),\r
 114 \r
 115                // needed by statisticsmanager\r
 116                mavenBundle("org.opendaylight.controller", "containermanager",\r
 117                         "0.4.0-SNAPSHOT"),\r
 118                mavenBundle("org.opendaylight.controller", "containermanager.implementation",\r
 119                        "0.4.0-SNAPSHOT"),\r
 120                \r
 121                mavenBundle("org.opendaylight.controller",\r
 122                         "clustering.services", "0.4.0-SNAPSHOT"),\r
 123                mavenBundle("org.opendaylight.controller",\r
 124                         "clustering.stub", "0.4.0-SNAPSHOT"),\r
 125 \r
 126                 // needed by forwardingrulesmanager\r
 127                 mavenBundle("org.opendaylight.controller", "switchmanager",\r
 128                         "0.4.0-SNAPSHOT"),\r
 129                 mavenBundle("org.opendaylight.controller", "switchmanager.implementation",\r
 130                         "0.4.0-SNAPSHOT"),\r
 131                 mavenBundle("org.opendaylight.controller", "configuration",\r
 132                         "0.4.0-SNAPSHOT"),\r
 133                 mavenBundle("org.opendaylight.controller",\r
 134                         "configuration.implementation", "0.4.0-SNAPSHOT"),\r
 135                 mavenBundle("org.opendaylight.controller", "hosttracker",\r
 136                         "0.4.0-SNAPSHOT"),\r
 137                 mavenBundle("org.opendaylight.controller", "hosttracker.implementation",\r
 138                         "0.4.0-SNAPSHOT"),\r
 139 \r
 140                 // needed by hosttracker\r
 141                 mavenBundle("org.opendaylight.controller", "topologymanager",\r
 142                         "0.4.0-SNAPSHOT"),\r
 143                 mavenBundle("org.opendaylight.controller", "arphandler",\r
 144                         "0.4.0-SNAPSHOT"),\r
 145 \r
 146 \r
 147                 mavenBundle("org.jboss.spec.javax.transaction",\r
 148                         "jboss-transaction-api_1.1_spec", "1.0.1.Final"),\r
 149                 mavenBundle("org.apache.commons", "commons-lang3", "3.1"),\r
 150                 mavenBundle("org.apache.felix",\r
 151                         "org.apache.felix.dependencymanager", "3.1.0"),\r
 152                 junitBundles());\r
 153     }\r
 154 \r
 155     private String stateToString(int state) {\r
 156         switch (state) {\r
 157         case Bundle.ACTIVE:\r
 158             return "ACTIVE";\r
 159         case Bundle.INSTALLED:\r
 160             return "INSTALLED";\r
 161         case Bundle.RESOLVED:\r
 162             return "RESOLVED";\r
 163         case Bundle.UNINSTALLED:\r
 164             return "UNINSTALLED";\r
 165         default:\r
 166             return "Not CONVERTED";\r
 167         }\r
 168     }\r
 169 \r
 170     @Before\r
 171     public void areWeReady() {\r
 172         assertNotNull(bc);\r
 173         boolean debugit = false;\r
 174         Bundle b[] = bc.getBundles();\r
 175         for (int i = 0; i < b.length; i++) {\r
 176             int state = b[i].getState();\r
 177             if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) {\r
 178                 log.debug("Bundle:" + b[i].getSymbolicName() + " state:"\r
 179                         + stateToString(state));\r
 180                 debugit = true;\r
 181             }\r
 182         }\r
 183         if (debugit) {\r
 184             log.debug("Do some debugging because some bundle is "\r
 185                     + "unresolved");\r
 186         }\r
 187 \r
 188         // Assert if true, if false we are good to go!\r
 189         assertFalse(debugit);\r
 190 \r
 191          // Now lets create a hosttracker for testing purpose\r
 192          ServiceReference s = bc\r
 193              .getServiceReference(IfIptoHost.class.getName());\r
 194          if (s != null) {\r
 195                  this.hosttracker = (IfIptoHost)bc.getService(s);\r
 196                  this.switchManagerAware = (ISwitchManagerAware) this.hosttracker;\r
 197                  this.invtoryListener = (IInventoryListener) this.hosttracker;\r
 198                  this.hostListener = (IfHostListener) this.hosttracker;\r
 199                  this.topologyManagerAware = (ITopologyManagerAware) this.hosttracker;\r
 200          }\r
 201 \r
 202          // If StatisticsManager is null, cannot run tests.\r
 203          assertNotNull(this.hosttracker);\r
 204     }\r
 205     \r
 206     \r
 207     @Test\r
 208     public void testStaticHost() throws UnknownHostException {\r
 209         String ip;\r
 210         \r
 211         assertNotNull(this.hosttracker);\r
 212         \r
 213         // create one node and two node connectors\r
 214         Node node1 = NodeCreator.createOFNode(1L);\r
 215         NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);\r
 216         NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);\r
 217         \r
 218         // test addStaticHost(), store into inactive host DB \r
 219         Status st = this.hosttracker.addStaticHost("192.168.0.8", "11:22:33:44:55:66",\r
 220                 nc1_1, "0");\r
 221         Assert.assertTrue(st.isSuccess());\r
 222         st = this.hosttracker.addStaticHost("192.168.0.13", "11:22:33:44:55:77",\r
 223                 nc1_2, "0");\r
 224         Assert.assertTrue(st.isSuccess());\r
 225         \r
 226         // check inactive DB\r
 227         Iterator<HostNodeConnector> hnci = this.hosttracker.getInactiveStaticHosts().iterator();\r
 228         while (hnci.hasNext()) {\r
 229             ip = hnci.next().getNetworkAddressAsString();\r
 230             Assert.assertTrue(ip.equals("192.168.0.8") || ip.equals("192.168.0.13"));\r
 231         }\r
 232         \r
 233         // check active host DB\r
 234         hnci = this.hosttracker.getActiveStaticHosts().iterator();\r
 235         Assert.assertFalse(hnci.hasNext());\r
 236         \r
 237         // test removeStaticHost()\r
 238         st = this.hosttracker.removeStaticHost("192.168.0.8");\r
 239         Assert.assertTrue(st.isSuccess());\r
 240 \r
 241         hnci = this.hosttracker.getInactiveStaticHosts().iterator();\r
 242         while (hnci.hasNext()) {\r
 243             ip = hnci.next().getNetworkAddressAsString();\r
 244             Assert.assertTrue(ip.equals("192.168.0.13"));\r
 245         }\r
 246     }               \r
 247             \r
 248 \r
 249     \r
 250     @Test\r
 251     public void testNotifyNodeConnector() throws UnknownHostException {\r
 252         String ip;\r
 253         \r
 254         assertNotNull(this.invtoryListener);\r
 255 \r
 256         // create one node and two node connectors\r
 257         Node node1 = NodeCreator.createOFNode(1L);\r
 258         NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);\r
 259         NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);\r
 260         \r
 261         // test addStaticHost(), put into inactive host DB if not verifiable\r
 262         Status st = this.hosttracker.addStaticHost("192.168.0.8", "11:22:33:44:55:66",\r
 263                 nc1_1, "0");\r
 264         st = this.hosttracker.addStaticHost("192.168.0.13", "11:22:33:44:55:77",\r
 265                 nc1_2, "0");\r
 266         \r
 267         this.invtoryListener.notifyNodeConnector(nc1_1,\r
 268                 UpdateType.ADDED, null);\r
 269 \r
 270         // check all host list\r
 271         Iterator<HostNodeConnector> hnci = this.hosttracker\r
 272                 .getAllHosts().iterator();\r
 273         while (hnci.hasNext()) {\r
 274             ip = hnci.next().getNetworkAddressAsString();\r
 275             Assert.assertTrue(ip.equals("192.168.0.8"));\r
 276         }\r
 277         \r
 278         // check active host DB\r
 279         hnci = this.hosttracker.getActiveStaticHosts().iterator();\r
 280         while (hnci.hasNext()) {\r
 281             ip = hnci.next().getNetworkAddressAsString();\r
 282             Assert.assertTrue(ip.equals("192.168.0.8"));\r
 283         }\r
 284         \r
 285         // check inactive host DB\r
 286         hnci = this.hosttracker.getInactiveStaticHosts().iterator();\r
 287         while (hnci.hasNext()) {\r
 288             ip = hnci.next().getNetworkAddressAsString();\r
 289             Assert.assertTrue(ip.equals("192.168.0.13"));\r
 290         }\r
 291     }\r
 292     \r
 293     \r
 294     \r
 295     @Test\r
 296     public void testHostFind() throws UnknownHostException {\r
 297         \r
 298         assertNotNull(this.invtoryListener);\r
 299 \r
 300         // create one node and two node connectors\r
 301         Node node1 = NodeCreator.createOFNode(1L);\r
 302         NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);\r
 303         NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);\r
 304         \r
 305         // test addStaticHost(), put into inactive host DB if not verifiable\r
 306         Status st = this.hosttracker.addStaticHost(\r
 307                 "192.168.0.8", "11:22:33:44:55:66", nc1_1, "0");\r
 308         st = this.hosttracker.addStaticHost(\r
 309                 "192.168.0.13", "11:22:33:44:55:77", nc1_2, "0");\r
 310         \r
 311         HostNodeConnector hnc_1 = this.hosttracker\r
 312                 .hostFind(InetAddress.getByName("192.168.0.8"));\r
 313         assertNull(hnc_1);\r
 314         \r
 315         this.invtoryListener.notifyNodeConnector(nc1_1,\r
 316                 UpdateType.ADDED, null);\r
 317 \r
 318         hnc_1 = this.hosttracker.hostFind(InetAddress.getByName("192.168.0.8"));\r
 319         assertNotNull(hnc_1);\r
 320         \r
 321     }\r
 322     \r
 323 }\r