-/*\r
- * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.\r
- *\r
- * This program and the accompanying materials are made available under the\r
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
- * and is available at http://www.eclipse.org/legal/epl-v10.html\r
- */\r
-\r
-package org.opendaylight.controller.hosttracker.internal;\r
-\r
-import java.net.InetAddress;\r
-import java.net.UnknownHostException;\r
-import java.util.ArrayList;\r
-import java.util.HashSet;\r
-import java.util.Iterator;\r
-import java.util.List;\r
-import java.util.Map;\r
-import java.util.Set;\r
-import java.util.Map.Entry;\r
-\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-import org.osgi.framework.ServiceReference;\r
-import org.osgi.framework.Bundle;\r
-import javax.inject.Inject;\r
-\r
-import org.eclipse.osgi.framework.console.CommandProvider;\r
-import org.junit.Assert;\r
-import org.junit.Test;\r
-import org.junit.Before;\r
-import org.junit.After;\r
-import org.junit.runner.RunWith;\r
-import org.opendaylight.controller.sal.core.Node;\r
-import org.opendaylight.controller.sal.core.NodeConnector;\r
-import org.opendaylight.controller.sal.core.UpdateType;\r
-import org.opendaylight.controller.sal.utils.NodeConnectorCreator;\r
-import org.opendaylight.controller.sal.utils.NodeCreator;\r
-import org.opendaylight.controller.sal.utils.Status;\r
-//import org.opendaylight.controller.hosttracker.*;\r
-import org.opendaylight.controller.hosttracker.IfIptoHost;\r
-import org.opendaylight.controller.hosttracker.IfHostListener;\r
-import org.opendaylight.controller.hosttracker.hostAware.HostNodeConnector;\r
-import org.opendaylight.controller.switchmanager.IInventoryListener;\r
-import org.opendaylight.controller.switchmanager.ISwitchManager;\r
-import org.opendaylight.controller.switchmanager.ISwitchManagerAware;\r
-import org.opendaylight.controller.topologymanager.ITopologyManagerAware;\r
-\r
-import org.ops4j.pax.exam.junit.PaxExam;\r
-import org.ops4j.pax.exam.util.Filter;\r
-import org.osgi.framework.BundleContext;\r
-import static org.junit.Assert.*;\r
-import org.ops4j.pax.exam.junit.Configuration;\r
-import static org.ops4j.pax.exam.CoreOptions.*;\r
-\r
-import org.ops4j.pax.exam.Option;\r
-import org.ops4j.pax.exam.util.PathUtils;\r
-import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;\r
-import org.ops4j.pax.exam.spi.reactors.PerClass;\r
-\r
-@RunWith(PaxExam.class)\r
-public class HostTrackerIT {\r
- private Logger log = LoggerFactory.getLogger(HostTrackerIT.class);\r
- // get the OSGI bundle context\r
- @Inject\r
- private BundleContext bc;\r
-\r
- private IfIptoHost hosttracker = null;\r
- private ISwitchManagerAware switchManagerAware = null;\r
- private IInventoryListener invtoryListener = null;\r
- private IfHostListener hostListener = null;\r
- private ITopologyManagerAware topologyManagerAware = null;\r
-\r
- // Configure the OSGi container\r
- @Configuration\r
- public Option[] config() {\r
- return options(\r
- //\r
- systemProperty("logback.configurationFile").value(\r
- "file:" + PathUtils.getBaseDir()\r
- + "/src/test/resources/logback.xml"),\r
- // To start OSGi console for inspection remotely\r
- systemProperty("osgi.console").value("2401"),\r
- // Set the systemPackages (used by clustering)\r
- systemPackages("sun.reflect", "sun.reflect.misc", "sun.misc"),\r
- // List framework bundles\r
- mavenBundle("equinoxSDK381", "org.eclipse.equinox.console",\r
- "1.0.0.v20120522-1841"),\r
- mavenBundle("equinoxSDK381", "org.eclipse.equinox.util",\r
- "1.0.400.v20120522-2049"),\r
- mavenBundle("equinoxSDK381", "org.eclipse.osgi.services",\r
- "3.3.100.v20120522-1822"),\r
- mavenBundle("equinoxSDK381", "org.eclipse.equinox.ds",\r
- "1.4.0.v20120522-1841"),\r
- mavenBundle("equinoxSDK381", "org.apache.felix.gogo.command",\r
- "0.8.0.v201108120515"),\r
- mavenBundle("equinoxSDK381", "org.apache.felix.gogo.runtime",\r
- "0.8.0.v201108120515"),\r
- mavenBundle("equinoxSDK381", "org.apache.felix.gogo.shell",\r
- "0.8.0.v201110170705"),\r
- // List logger bundles\r
- mavenBundle("org.slf4j", "slf4j-api").versionAsInProject(),\r
- mavenBundle("org.slf4j", "log4j-over-slf4j")\r
- .versionAsInProject(),\r
- mavenBundle("ch.qos.logback", "logback-core")\r
- .versionAsInProject(),\r
- mavenBundle("ch.qos.logback", "logback-classic")\r
- .versionAsInProject(),\r
-\r
- // List all the bundles on which the test case depends\r
- mavenBundle("org.opendaylight.controller", "sal")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller", "sal.implementation")\r
- .versionAsInProject(),\r
-\r
- // needed by statisticsmanager\r
- mavenBundle("org.opendaylight.controller", "containermanager")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller",\r
- "containermanager.implementation").versionAsInProject(),\r
-\r
- mavenBundle("org.opendaylight.controller",\r
- "clustering.services").versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller", "clustering.stub")\r
- .versionAsInProject(),\r
-\r
- // needed by forwardingrulesmanager\r
- mavenBundle("org.opendaylight.controller", "switchmanager")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller",\r
- "switchmanager.implementation").versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller", "configuration")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller",\r
- "configuration.implementation").versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller", "hosttracker")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller",\r
- "hosttracker.implementation").versionAsInProject(),\r
-\r
- // needed by hosttracker\r
- mavenBundle("org.opendaylight.controller", "topologymanager")\r
- .versionAsInProject(),\r
- mavenBundle("org.opendaylight.controller", "arphandler")\r
- .versionAsInProject(),\r
-\r
- mavenBundle("org.jboss.spec.javax.transaction",\r
- "jboss-transaction-api_1.1_spec").versionAsInProject(),\r
- mavenBundle("org.apache.commons", "commons-lang3")\r
- .versionAsInProject(),\r
- mavenBundle("org.apache.felix",\r
- "org.apache.felix.dependencymanager")\r
- .versionAsInProject(), junitBundles());\r
- }\r
-\r
- private String stateToString(int state) {\r
- switch (state) {\r
- case Bundle.ACTIVE:\r
- return "ACTIVE";\r
- case Bundle.INSTALLED:\r
- return "INSTALLED";\r
- case Bundle.RESOLVED:\r
- return "RESOLVED";\r
- case Bundle.UNINSTALLED:\r
- return "UNINSTALLED";\r
- default:\r
- return "Not CONVERTED";\r
- }\r
- }\r
-\r
- @Before\r
- public void areWeReady() {\r
- assertNotNull(bc);\r
- boolean debugit = false;\r
- Bundle b[] = bc.getBundles();\r
- for (int i = 0; i < b.length; i++) {\r
- int state = b[i].getState();\r
- if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) {\r
- log.debug("Bundle:" + b[i].getSymbolicName() + " state:"\r
- + stateToString(state));\r
- debugit = true;\r
- }\r
- }\r
- if (debugit) {\r
- log.debug("Do some debugging because some bundle is "\r
- + "unresolved");\r
- }\r
-\r
- // Assert if true, if false we are good to go!\r
- assertFalse(debugit);\r
-\r
- // Now lets create a hosttracker for testing purpose\r
- ServiceReference s = bc.getServiceReference(IfIptoHost.class.getName());\r
- if (s != null) {\r
- this.hosttracker = (IfIptoHost) bc.getService(s);\r
- this.switchManagerAware = (ISwitchManagerAware) this.hosttracker;\r
- this.invtoryListener = (IInventoryListener) this.hosttracker;\r
- this.hostListener = (IfHostListener) this.hosttracker;\r
- this.topologyManagerAware = (ITopologyManagerAware) this.hosttracker;\r
- }\r
-\r
- // If StatisticsManager is null, cannot run tests.\r
- assertNotNull(this.hosttracker);\r
- }\r
-\r
- @Test\r
- public void testStaticHost() throws UnknownHostException {\r
- String ip;\r
-\r
- assertNotNull(this.hosttracker);\r
-\r
- // create one node and two node connectors\r
- Node node1 = NodeCreator.createOFNode(1L);\r
- NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 1, node1);\r
- NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 2, node1);\r
-\r
- // test addStaticHost(), store into inactive host DB\r
- Status st = this.hosttracker.addStaticHost("192.168.0.8",\r
- "11:22:33:44:55:66", nc1_1, "0");\r
- Assert.assertTrue(st.isSuccess());\r
- st = this.hosttracker.addStaticHost("192.168.0.13",\r
- "11:22:33:44:55:77", nc1_2, "0");\r
- Assert.assertTrue(st.isSuccess());\r
-\r
- // check inactive DB\r
- Iterator<HostNodeConnector> hnci = this.hosttracker\r
- .getInactiveStaticHosts().iterator();\r
- while (hnci.hasNext()) {\r
- ip = hnci.next().getNetworkAddressAsString();\r
- Assert.assertTrue(ip.equals("192.168.0.8")\r
- || ip.equals("192.168.0.13"));\r
- }\r
-\r
- // check active host DB\r
- hnci = this.hosttracker.getActiveStaticHosts().iterator();\r
- Assert.assertFalse(hnci.hasNext());\r
-\r
- // test removeStaticHost()\r
- st = this.hosttracker.removeStaticHost("192.168.0.8");\r
- Assert.assertTrue(st.isSuccess());\r
-\r
- hnci = this.hosttracker.getInactiveStaticHosts().iterator();\r
- while (hnci.hasNext()) {\r
- ip = hnci.next().getNetworkAddressAsString();\r
- Assert.assertTrue(ip.equals("192.168.0.13"));\r
- }\r
- }\r
-\r
- @Test\r
- public void testNotifyNodeConnector() throws UnknownHostException {\r
- String ip;\r
-\r
- assertNotNull(this.invtoryListener);\r
-\r
- // create one node and two node connectors\r
- Node node1 = NodeCreator.createOFNode(1L);\r
- NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 1, node1);\r
- NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 2, node1);\r
-\r
- // test addStaticHost(), put into inactive host DB if not verifiable\r
- Status st = this.hosttracker.addStaticHost("192.168.0.8",\r
- "11:22:33:44:55:66", nc1_1, "0");\r
- st = this.hosttracker.addStaticHost("192.168.0.13",\r
- "11:22:33:44:55:77", nc1_2, "0");\r
-\r
- this.invtoryListener.notifyNodeConnector(nc1_1, UpdateType.ADDED, null);\r
-\r
- // check all host list\r
- Iterator<HostNodeConnector> hnci = this.hosttracker.getAllHosts()\r
- .iterator();\r
- while (hnci.hasNext()) {\r
- ip = hnci.next().getNetworkAddressAsString();\r
- Assert.assertTrue(ip.equals("192.168.0.8"));\r
- }\r
-\r
- // check active host DB\r
- hnci = this.hosttracker.getActiveStaticHosts().iterator();\r
- while (hnci.hasNext()) {\r
- ip = hnci.next().getNetworkAddressAsString();\r
- Assert.assertTrue(ip.equals("192.168.0.8"));\r
- }\r
-\r
- // check inactive host DB\r
- hnci = this.hosttracker.getInactiveStaticHosts().iterator();\r
- while (hnci.hasNext()) {\r
- ip = hnci.next().getNetworkAddressAsString();\r
- Assert.assertTrue(ip.equals("192.168.0.13"));\r
- }\r
- }\r
-\r
- @Test\r
- public void testHostFind() throws UnknownHostException {\r
-\r
- assertNotNull(this.invtoryListener);\r
-\r
- // create one node and two node connectors\r
- Node node1 = NodeCreator.createOFNode(1L);\r
- NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 1, node1);\r
- NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector(\r
- (short) 2, node1);\r
-\r
- // test addStaticHost(), put into inactive host DB if not verifiable\r
- Status st = this.hosttracker.addStaticHost("192.168.0.8",\r
- "11:22:33:44:55:66", nc1_1, "0");\r
- st = this.hosttracker.addStaticHost("192.168.0.13",\r
- "11:22:33:44:55:77", nc1_2, "0");\r
-\r
- HostNodeConnector hnc_1 = this.hosttracker.hostFind(InetAddress\r
- .getByName("192.168.0.8"));\r
- assertNull(hnc_1);\r
-\r
- this.invtoryListener.notifyNodeConnector(nc1_1, UpdateType.ADDED, null);\r
-\r
- hnc_1 = this.hosttracker.hostFind(InetAddress.getByName("192.168.0.8"));\r
- assertNotNull(hnc_1);\r
-\r
- }\r
-\r
-}\r
+/*
+ * 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.hosttracker.internal;
+
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.ops4j.pax.exam.CoreOptions.junitBundles;
+import static org.ops4j.pax.exam.CoreOptions.mavenBundle;
+import static org.ops4j.pax.exam.CoreOptions.options;
+import static org.ops4j.pax.exam.CoreOptions.systemPackages;
+import static org.ops4j.pax.exam.CoreOptions.systemProperty;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.util.Iterator;
+
+import javax.inject.Inject;
+
+import org.junit.Assert;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.opendaylight.controller.hosttracker.IfIptoHost;
+import org.opendaylight.controller.hosttracker.hostAware.HostNodeConnector;
+import org.opendaylight.controller.sal.core.Node;
+import org.opendaylight.controller.sal.core.NodeConnector;
+import org.opendaylight.controller.sal.core.UpdateType;
+import org.opendaylight.controller.sal.utils.NodeConnectorCreator;
+import org.opendaylight.controller.sal.utils.NodeCreator;
+import org.opendaylight.controller.sal.utils.Status;
+import org.opendaylight.controller.switchmanager.IInventoryListener;
+import org.ops4j.pax.exam.Option;
+import org.ops4j.pax.exam.junit.Configuration;
+import org.ops4j.pax.exam.junit.PaxExam;
+import org.ops4j.pax.exam.util.PathUtils;
+import org.osgi.framework.Bundle;
+import org.osgi.framework.BundleContext;
+import org.osgi.framework.ServiceReference;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+//import org.opendaylight.controller.hosttracker.*;
+
+@RunWith(PaxExam.class)
+public class HostTrackerIT {
+ private Logger log = LoggerFactory.getLogger(HostTrackerIT.class);
+ // get the OSGI bundle context
+ @Inject
+ private BundleContext bc;
+
+ private IfIptoHost hosttracker = null;
+ private IInventoryListener invtoryListener = null;
+ // Configure the OSGi container
+ @Configuration
+ public Option[] config() {
+ return options(
+
+ //
+ systemProperty("logback.configurationFile").value(
+ "file:" + PathUtils.getBaseDir() + "/src/test/resources/logback.xml"),
+ // To start OSGi console for inspection remotely
+ systemProperty("osgi.console").value("2401"),
+ // Set the systemPackages (used by clustering)
+ systemPackages("sun.reflect", "sun.reflect.misc", "sun.misc"),
+ // List framework bundles
+ mavenBundle("equinoxSDK381", "org.eclipse.equinox.console").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.eclipse.equinox.util").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.eclipse.osgi.services").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.eclipse.equinox.ds").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.apache.felix.gogo.command").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.apache.felix.gogo.runtime").versionAsInProject(),
+ mavenBundle("equinoxSDK381", "org.apache.felix.gogo.shell").versionAsInProject(),
+ // List logger bundles
+ mavenBundle("org.slf4j", "slf4j-api").versionAsInProject(),
+ mavenBundle("org.slf4j", "log4j-over-slf4j").versionAsInProject(),
+ mavenBundle("ch.qos.logback", "logback-core").versionAsInProject(),
+ mavenBundle("ch.qos.logback", "logback-classic").versionAsInProject(),
+
+ // List all the bundles on which the test case depends
+ mavenBundle("org.opendaylight.controller", "sal").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "sal.implementation").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "sal.connection").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "sal.connection.implementation").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "connectionmanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "connectionmanager.implementation").versionAsInProject(),
+
+ // needed by statisticsmanager
+ mavenBundle("org.opendaylight.controller", "containermanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "containermanager.implementation").versionAsInProject(),
+
+ mavenBundle("org.opendaylight.controller", "clustering.services").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "clustering.stub").versionAsInProject(),
+
+ // needed by forwardingrulesmanager
+ mavenBundle("org.opendaylight.controller", "switchmanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "forwardingrulesmanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "statisticsmanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "switchmanager.implementation").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "configuration").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "configuration.implementation").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "hosttracker").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "hosttracker.implementation").versionAsInProject(),
+
+ // needed by hosttracker
+ mavenBundle("org.opendaylight.controller", "topologymanager").versionAsInProject(),
+ mavenBundle("org.opendaylight.controller", "arphandler").versionAsInProject(),
+
+ mavenBundle("org.jboss.spec.javax.transaction", "jboss-transaction-api_1.1_spec").versionAsInProject(),
+ mavenBundle("org.apache.commons", "commons-lang3").versionAsInProject(),
+ mavenBundle("org.apache.felix", "org.apache.felix.dependencymanager").versionAsInProject(),
+ junitBundles());
+ }
+
+ private String stateToString(int state) {
+ switch (state) {
+ case Bundle.ACTIVE:
+ return "ACTIVE";
+ case Bundle.INSTALLED:
+ return "INSTALLED";
+ case Bundle.RESOLVED:
+ return "RESOLVED";
+ case Bundle.UNINSTALLED:
+ return "UNINSTALLED";
+ default:
+ return "Not CONVERTED";
+ }
+ }
+
+ @Before
+ public void areWeReady() {
+ assertNotNull(bc);
+ boolean debugit = false;
+ Bundle b[] = bc.getBundles();
+ for (int i = 0; i < b.length; i++) {
+ int state = b[i].getState();
+ if (state != Bundle.ACTIVE && state != Bundle.RESOLVED) {
+ log.debug("Bundle:" + b[i].getSymbolicName() + " state:" + stateToString(state));
+ debugit = true;
+ }
+ }
+ if (debugit) {
+ log.debug("Do some debugging because some bundle is " + "unresolved");
+ }
+
+ // Assert if true, if false we are good to go!
+ assertFalse(debugit);
+
+ // Now lets create a hosttracker for testing purpose
+ ServiceReference s = bc.getServiceReference(IfIptoHost.class.getName());
+ if (s != null) {
+ this.hosttracker = (IfIptoHost) bc.getService(s);
+ this.invtoryListener = (IInventoryListener) this.hosttracker;
+ }
+
+ // If StatisticsManager is null, cannot run tests.
+ assertNotNull(this.hosttracker);
+ }
+
+ @Test
+ public void testStaticHost() throws UnknownHostException {
+ String ip;
+
+ assertNotNull(this.hosttracker);
+
+ // create one node and two node connectors
+ Node node1 = NodeCreator.createOFNode(1L);
+ NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);
+ NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);
+
+ // test addStaticHost(), store into inactive host DB
+ Status st = this.hosttracker.addStaticHost("192.168.0.8", "11:22:33:44:55:66", nc1_1, "0");
+ Assert.assertTrue(st.isSuccess());
+ st = this.hosttracker.addStaticHost("192.168.0.13", "11:22:33:44:55:77", nc1_2, "0");
+ Assert.assertTrue(st.isSuccess());
+
+ // check inactive DB
+ Iterator<HostNodeConnector> hnci = this.hosttracker.getInactiveStaticHosts().iterator();
+ while (hnci.hasNext()) {
+ ip = hnci.next().getNetworkAddressAsString();
+ Assert.assertTrue(ip.equals("192.168.0.8") || ip.equals("192.168.0.13"));
+ }
+
+ // check active host DB
+ hnci = this.hosttracker.getActiveStaticHosts().iterator();
+ Assert.assertFalse(hnci.hasNext());
+
+ // test removeStaticHost()
+ st = this.hosttracker.removeStaticHost("192.168.0.8");
+ Assert.assertTrue(st.isSuccess());
+
+ hnci = this.hosttracker.getInactiveStaticHosts().iterator();
+ while (hnci.hasNext()) {
+ ip = hnci.next().getNetworkAddressAsString();
+ Assert.assertTrue(ip.equals("192.168.0.13"));
+ }
+ }
+
+ @Test
+ public void testNotifyNodeConnector() throws UnknownHostException {
+ String ip;
+
+ assertNotNull(this.invtoryListener);
+
+ // create one node and two node connectors
+ Node node1 = NodeCreator.createOFNode(1L);
+ NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);
+ NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);
+
+ // test addStaticHost(), put into inactive host DB if not verifiable
+ Status st = this.hosttracker.addStaticHost("192.168.0.8", "11:22:33:44:55:66", nc1_1, "0");
+ st = this.hosttracker.addStaticHost("192.168.0.13", "11:22:33:44:55:77", nc1_2, "0");
+
+ this.invtoryListener.notifyNodeConnector(nc1_1, UpdateType.ADDED, null);
+
+ // check all host list
+ Iterator<HostNodeConnector> hnci = this.hosttracker.getAllHosts().iterator();
+ while (hnci.hasNext()) {
+ ip = hnci.next().getNetworkAddressAsString();
+ Assert.assertTrue(ip.equals("192.168.0.8"));
+ }
+
+ // check active host DB
+ hnci = this.hosttracker.getActiveStaticHosts().iterator();
+ while (hnci.hasNext()) {
+ ip = hnci.next().getNetworkAddressAsString();
+ Assert.assertTrue(ip.equals("192.168.0.8"));
+ }
+
+ // check inactive host DB
+ hnci = this.hosttracker.getInactiveStaticHosts().iterator();
+ while (hnci.hasNext()) {
+ ip = hnci.next().getNetworkAddressAsString();
+ Assert.assertTrue(ip.equals("192.168.0.13"));
+ }
+ }
+
+ @Test
+ public void testHostFind() throws UnknownHostException {
+
+ assertNotNull(this.invtoryListener);
+
+ // create one node and two node connectors
+ Node node1 = NodeCreator.createOFNode(1L);
+ NodeConnector nc1_1 = NodeConnectorCreator.createOFNodeConnector((short) 1, node1);
+ NodeConnector nc1_2 = NodeConnectorCreator.createOFNodeConnector((short) 2, node1);
+
+ // test addStaticHost(), put into inactive host DB if not verifiable
+ Status st = this.hosttracker.addStaticHost("192.168.0.8", "11:22:33:44:55:66", nc1_1, "0");
+ st = this.hosttracker.addStaticHost("192.168.0.13", "11:22:33:44:55:77", nc1_2, "0");
+
+ HostNodeConnector hnc_1 = this.hosttracker.hostFind(InetAddress.getByName("192.168.0.8"));
+ assertNull(hnc_1);
+
+ this.invtoryListener.notifyNodeConnector(nc1_1, UpdateType.ADDED, null);
+
+ hnc_1 = this.hosttracker.hostFind(InetAddress.getByName("192.168.0.8"));
+ assertNotNull(hnc_1);
+
+ }
+
+}
Code Review / controller.git / blobdiff