+++ /dev/null
-/*
- * Copyright © 2016 Red Hat, 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.netvirt.netvirt.it;
-
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
-import static org.ops4j.pax.exam.CoreOptions.composite;
-import static org.ops4j.pax.exam.CoreOptions.maven;
-import static org.ops4j.pax.exam.CoreOptions.mavenBundle;
-import static org.ops4j.pax.exam.CoreOptions.propagateSystemProperties;
-import static org.ops4j.pax.exam.CoreOptions.vmOption;
-import static org.ops4j.pax.exam.CoreOptions.wrappedBundle;
-import static org.ops4j.pax.exam.MavenUtils.asInProject;
-import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.configureConsole;
-import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.editConfigurationFilePut;
-import static org.ops4j.pax.exam.karaf.options.KarafDistributionOption.keepRuntimeFolder;
-
-import java.util.ArrayList;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Properties;
-import java.util.concurrent.atomic.AtomicBoolean;
-import javax.inject.Inject;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import org.junit.runner.RunWith;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.mdsal.it.base.AbstractMdsalTestBase;
-import org.opendaylight.netvirt.openstack.netvirt.NeutronModelsDataStoreHelper;
-import org.opendaylight.netvirt.openstack.netvirt.translator.crud.NeutronNetwork;
-import org.opendaylight.netvirt.utils.netvirt.it.utils.ItConstants;
-import org.opendaylight.netvirt.utils.netvirt.it.utils.NetvirtItUtils;
-import org.opendaylight.netvirt.utils.neutron.utils.NeutronUtils;
-import org.opendaylight.ovsdb.utils.mdsal.utils.MdsalUtils;
-import org.opendaylight.ovsdb.utils.mdsal.utils.NotifyingDataChangeListener;
-import org.opendaylight.ovsdb.utils.southbound.utils.SouthboundUtils;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.networks.rev150712.networks.attributes.networks.Network;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import org.ops4j.pax.exam.Configuration;
-import org.ops4j.pax.exam.Option;
-import org.ops4j.pax.exam.junit.PaxExam;
-import org.ops4j.pax.exam.karaf.options.LogLevelOption;
-import org.ops4j.pax.exam.options.MavenUrlReference;
-import org.ops4j.pax.exam.spi.reactors.ExamReactorStrategy;
-import org.ops4j.pax.exam.spi.reactors.PerClass;
-import org.ops4j.pax.exam.util.Filter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@RunWith(PaxExam.class)
-@ExamReactorStrategy(PerClass.class)
-public class NetvirtIT extends AbstractMdsalTestBase {
- private static final Logger LOG = LoggerFactory.getLogger(NetvirtIT.class);
- private static final String FEATURE = "odl-netvirt-it";
- private static NetvirtItUtils itUtils;
- private static String addressStr;
- private static String portStr;
- private static String connectionType;
- private static String controllerStr;
- private static AtomicBoolean setup = new AtomicBoolean(false);
- private static MdsalUtils mdsalUtils = null;
- private static SouthboundUtils southboundUtils;
- private static NeutronUtils neutronUtils = new NeutronUtils();
- private static NeutronModelsDataStoreHelper neutronModelsDataStoreHelper;
- private static final String NETWORK_TYPE_VXLAN = "vxlan";
- @Inject @Filter(timeout=60000)
- private static DataBroker dataBroker = null;
-
-
- @Override
- public String getModuleName() {
- return "netvirt-neutron";
- }
-
- @Override
- public String getInstanceName() { return "netvirt-neutron"; }
-
- @Override
- public MavenUrlReference getFeatureRepo() {
- return maven()
- .groupId("org.opendaylight.netvirt")
- .artifactId("features-netvirt")
- .classifier("features")
- .type("xml")
- .versionAsInProject();
- }
-
- @Override
- public String getFeatureName() {
- return FEATURE;
- }
-
- @Configuration
- @Override
- public Option[] config() {
- Option[] parentOptions = super.config();
- Option[] propertiesOptions = getPropertiesOptions();
- Option[] otherOptions = getOtherOptions();
- Option[] options = new Option[parentOptions.length + propertiesOptions.length + otherOptions.length];
- System.arraycopy(parentOptions, 0, options, 0, parentOptions.length);
- System.arraycopy(propertiesOptions, 0, options, parentOptions.length, propertiesOptions.length);
- System.arraycopy(otherOptions, 0, options, parentOptions.length + propertiesOptions.length,
- otherOptions.length);
- return options;
- }
-
- private Option[] getOtherOptions() {
- return new Option[] {
- wrappedBundle(
- mavenBundle("org.opendaylight.netvirt", "utils.mdsal-openflow")
- .version(asInProject())
- .type("jar")),
- configureConsole().startLocalConsole(),
- //vmOption("-verbose:class"),
- vmOption("-javaagent:../jars/org.jacoco.agent.jar=destfile=../../jacoco-it.exec"),
- keepRuntimeFolder()
- };
- }
-
- private Option[] getPropertiesOptions() {
- return new Option[] {
- propagateSystemProperties(ItConstants.SERVER_IPADDRESS, ItConstants.SERVER_PORT,
- ItConstants.CONNECTION_TYPE, ItConstants.CONTROLLER_IPADDRESS,
- ItConstants.USERSPACE_ENABLED),
- };
- }
-
- @Override
- public Option getLoggingOption() {
- return composite(
- editConfigurationFilePut(ItConstants.ORG_OPS4J_PAX_LOGGING_CFG,
- "log4j.logger.org.opendaylight.ovsdb",
- LogLevelOption.LogLevel.TRACE.name()),
- editConfigurationFilePut(ItConstants.ORG_OPS4J_PAX_LOGGING_CFG,
- logConfiguration(NetvirtIT.class),
- LogLevelOption.LogLevel.INFO.name()),
- editConfigurationFilePut(ItConstants.ORG_OPS4J_PAX_LOGGING_CFG,
- "log4j.logger.org.opendaylight.neutron",
- LogLevelOption.LogLevel.TRACE.name()),
- super.getLoggingOption());
- }
-
- protected String usage() {
- return "Integration Test needs a valid connection configuration as follows :\n"
- + "active connection : mvn -Dovsdbserver.ipaddress=x.x.x.x -Dovsdbserver.port=yyyy verify\n"
- + "passive connection : mvn -Dovsdbserver.connection=passive verify\n";
- }
-
- private void getProperties() {
- Properties props = System.getProperties();
- addressStr = props.getProperty(ItConstants.SERVER_IPADDRESS);
- portStr = props.getProperty(ItConstants.SERVER_PORT, ItConstants.DEFAULT_SERVER_PORT);
- connectionType = props.getProperty(ItConstants.CONNECTION_TYPE, "active");
- controllerStr = props.getProperty(ItConstants.CONTROLLER_IPADDRESS, "0.0.0.0");
- String userSpaceEnabled = props.getProperty(ItConstants.USERSPACE_ENABLED, "no");
- LOG.info("setUp: Using the following properties: mode= {}, ip:port= {}:{}, controller ip: {}, " +
- "userspace.enabled: {}",
- connectionType, addressStr, portStr, controllerStr, userSpaceEnabled);
- if (connectionType.equalsIgnoreCase(ItConstants.CONNECTION_TYPE_ACTIVE)) {
- if (addressStr == null) {
- fail(usage());
- }
- }
- }
-
- @After
- public void teardown() {
- closeWaitFors();
- }
-
- @Before
- @Override
- public void setup() throws InterruptedException {
- if (setup.get()) {
- LOG.info("Skipping setUp, already initialized");
- return;
- }
-
- try {
- super.setup();
- } catch (Exception e) {
- LOG.warn("Failed to setup test", e);
- fail("Failed to setup test: " + e);
- }
-
- getProperties();
-
- if (connectionType.equalsIgnoreCase(ItConstants.CONNECTION_TYPE_ACTIVE)) {
- if (addressStr == null) {
- fail(usage());
- }
- }
-
- assertNotNull("dataBroker should not be null", dataBroker);
- itUtils = new NetvirtItUtils(dataBroker);
- mdsalUtils = new MdsalUtils(dataBroker);
- assertNotNull("mdsalUtils should not be null", mdsalUtils);
- // TODO: Not used yet since openstack is not running to write the netvirt:1 to mdsal
- // Only need neutron northbound right now
- //assertTrue("Did not find " + ItConstants.NETVIRT_TOPOLOGY_ID, itUtils.getNetvirtTopology());
- southboundUtils = new SouthboundUtils(mdsalUtils);
- neutronModelsDataStoreHelper = new NeutronModelsDataStoreHelper(dataBroker);
- setup.set(true);
- }
-
- @Test
- public void testNetvirtFeatureLoad() {
- assertTrue("Feature " + FEATURE + " was not loaded", true);
- }
-
- private List<NotifyingDataChangeListener> waitList = new ArrayList<>();
- private void closeWaitFors() {
- for (Iterator<NotifyingDataChangeListener> iterator = waitList.iterator(); iterator.hasNext();) {
- NotifyingDataChangeListener listener = iterator.next();
- iterator.remove();
- try {
- listener.close();
- } catch (Exception ex) {
- LOG.warn("Failed to close registration {}", listener, ex);
- }
- }
- LOG.info("waitList size {}", waitList.size());
- }
-
- @Test
- public void testNetvirtNeutron() throws InterruptedException {
- final String networkId = "521e29d6-67b8-4b3c-8633-027d21195111";
- final String tenantId = "521e29d6-67b8-4b3c-8633-027d21195100";
-
- InstanceIdentifier<Network> path = neutronModelsDataStoreHelper.getNeutronNetworkPath(new Uuid(networkId));
- final NotifyingDataChangeListener networkOperationalListener =
- new NotifyingDataChangeListener(LogicalDatastoreType.CONFIGURATION, path, waitList);
- networkOperationalListener.registerDataChangeListener(dataBroker);
-
- NeutronNetwork nn = neutronUtils.createNeutronNetwork(networkId, tenantId,
- NETWORK_TYPE_VXLAN, "100");
-
- networkOperationalListener.waitForCreation();
-
- Network network = mdsalUtils.read(LogicalDatastoreType.CONFIGURATION, path);
- assertNotNull("the network was not found in mdsal", network);
- }
-}
Code Review / netvirt.git / blobdiff