/*
- * Copyright (C) 2013 Red Hat, Inc.
+ * Copyright (c) 2013, 2015 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
- *
- * Authors : Madhu Venugopal, Brent Salisbury, Sam Hague, Dave Tucker
*/
+
package org.opendaylight.ovsdb.openstack.netvirt.impl;
import com.google.common.collect.Maps;
import org.apache.commons.lang3.tuple.ImmutablePair;
import org.apache.commons.lang3.tuple.Pair;
import org.opendaylight.ovsdb.openstack.netvirt.ConfigInterface;
-import org.opendaylight.ovsdb.openstack.netvirt.MdsalUtils;
import org.opendaylight.ovsdb.openstack.netvirt.api.ConfigurationService;
import org.opendaylight.ovsdb.openstack.netvirt.api.Constants;
import org.opendaylight.ovsdb.openstack.netvirt.api.OvsdbTables;
+import org.opendaylight.ovsdb.openstack.netvirt.api.Southbound;
import org.opendaylight.ovsdb.utils.config.ConfigProperties;
+import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
-import org.osgi.framework.BundleContext;
+
import org.osgi.framework.ServiceReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class ConfigurationServiceImpl implements ConfigurationService, ConfigInterface {
- static final Logger logger = LoggerFactory.getLogger(ConfigurationServiceImpl.class);
+ private static final Logger LOG = LoggerFactory.getLogger(ConfigurationServiceImpl.class);
private String integrationBridgeName;
private String networkBridgeName;
private Map<Pair<String, String>, String> patchPortNames = Maps.newHashMap();
private String providerMappingsKey;
private String providerMapping;
+ private Southbound southbound;
public ConfigurationServiceImpl() {
tunnelEndpointKey = Constants.TUNNEL_ENDPOINT_KEY;
Constants.PATCH_PORT_TO_NETWORK_BRIDGE_NAME);
patchPortNames.put(new ImmutablePair<>(networkBridgeName, integrationBridgeName),
Constants.PATCH_PORT_TO_INTEGRATION_BRIDGE_NAME);
+ patchPortNames.put(new ImmutablePair<>(integrationBridgeName, externalBridgeName),
+ Constants.PATCH_PORT_TO_EXTERNAL_BRIDGE_NAME);
+ patchPortNames.put(new ImmutablePair<>(externalBridgeName, integrationBridgeName),
+ Constants.PATCH_PORT_TO_INTEGRATION_BRIDGE_NAME);
providerMappingsKey = Constants.PROVIDER_MAPPINGS_KEY;
providerMapping = Constants.PROVIDER_MAPPING;
}
@Override
public InetAddress getTunnelEndPoint(Node node) {
InetAddress address = null;
- String tunnelEndpoint = MdsalUtils.getOtherConfig(node, OvsdbTables.OPENVSWITCH, tunnelEndpointKey);
+ String tunnelEndpoint = southbound.getOtherConfig(node, OvsdbTables.OPENVSWITCH, tunnelEndpointKey);
if (tunnelEndpoint != null) {
try {
address = InetAddress.getByName(tunnelEndpoint);
+ LOG.debug("Tunnel Endpoint for Node {} {}", node, address.getHostAddress());
} catch (UnknownHostException e) {
- logger.error("Error populating Tunnel Endpoint for Node {} ", node, e);
+ LOG.error("Error populating Tunnel Endpoint for Node {} ", node, e);
}
- logger.debug("Tunnel Endpoint for Node {} {}", node, address.getHostAddress());
}
return address;
}
return Constants.OPENFLOW13;
}
+ @Override
+ public boolean isL3ForwardingEnabled() {
+ final String enabledPropertyStr = ConfigProperties.getProperty(this.getClass(), "ovsdb.l3.fwd.enabled");
+ return enabledPropertyStr != null && enabledPropertyStr.equalsIgnoreCase("yes");
+ }
+
+ @Override
+ public boolean isDistributedArpDisabled() {
+ final String strARPDisabled = ConfigProperties.getProperty(this.getClass(), "ovsdb.l3.arp.responder.disabled");
+ return strARPDisabled != null && strARPDisabled.equalsIgnoreCase("yes");
+ }
+
@Override
public String getDefaultGatewayMacAddress(Node node) {
String l3gatewayForNode = null;
if (node != null) {
l3gatewayForNode = ConfigProperties.getProperty(this.getClass(),
"ovsdb.l3gateway.mac." + node.getNodeId().getValue());
- if (l3gatewayForNode == null) {
- l3gatewayForNode = ConfigProperties.getProperty(this.getClass(), "ovsdb.l3gateway.mac");
- }
+ }
+ if (l3gatewayForNode == null) {
+ l3gatewayForNode = ConfigProperties.getProperty(this.getClass(), "ovsdb.l3gateway.mac");
}
return l3gatewayForNode;
}
@Override
- public void setDependencies(BundleContext bundleContext, ServiceReference serviceReference) {
+ public boolean isUserSpaceEnabled() {
+ final String enabledPropertyStr = ConfigProperties.getProperty(this.getClass(), "ovsdb.userspace.enabled");
+ return enabledPropertyStr != null && enabledPropertyStr.equalsIgnoreCase("yes");
+ }
+
+ @Override
+ public void setDependencies(ServiceReference serviceReference) {
+ southbound =
+ (Southbound) ServiceHelper.getGlobalInstance(Southbound.class, this);
}
@Override