+++ /dev/null
-/*
- * 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
- */
-
-package org.opendaylight.netvirt.openstack.netvirt.impl;
-
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.HashMap;
-import java.util.Map;
-import org.apache.commons.lang3.tuple.ImmutablePair;
-import org.apache.commons.lang3.tuple.Pair;
-import org.opendaylight.netvirt.openstack.netvirt.ConfigInterface;
-import org.opendaylight.netvirt.openstack.netvirt.api.ConfigurationService;
-import org.opendaylight.netvirt.openstack.netvirt.api.Constants;
-import org.opendaylight.netvirt.openstack.netvirt.api.OvsdbTables;
-import org.opendaylight.netvirt.openstack.netvirt.api.Southbound;
-import org.opendaylight.netvirt.utils.config.ConfigProperties;
-import org.opendaylight.netvirt.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.ServiceReference;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class ConfigurationServiceImpl implements ConfigurationService, ConfigInterface {
- private static final Logger LOG = LoggerFactory.getLogger(ConfigurationServiceImpl.class);
-
- private String integrationBridgeName;
- private String networkBridgeName;
- private String externalBridgeName;
- private String tunnelEndpointKey;
-
- private Map<Pair<String, String>, String> patchPortNames = new HashMap<>();
- private String providerMappingsKey;
- private String providerMapping;
- private Southbound southbound;
-
- public ConfigurationServiceImpl() {
- tunnelEndpointKey = Constants.TUNNEL_ENDPOINT_KEY;
- integrationBridgeName = Constants.INTEGRATION_BRIDGE;
- networkBridgeName = Constants.NETWORK_BRIDGE;
- externalBridgeName = Constants.EXTERNAL_BRIDGE;
- patchPortNames.put(new ImmutablePair<>(integrationBridgeName, networkBridgeName),
- 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 String getIntegrationBridgeName() {
- return integrationBridgeName;
- }
-
- @Override
- public void setIntegrationBridgeName(String integrationBridgeName) {
- this.integrationBridgeName = integrationBridgeName;
- }
-
- @Override
- public String getNetworkBridgeName() {
- return networkBridgeName;
- }
-
- @Override
- public void setNetworkBridgeName(String networkBridgeName) {
- this.networkBridgeName = networkBridgeName;
- }
-
- @Override
- public String getExternalBridgeName() {
- return externalBridgeName;
- }
-
- @Override
- public void setExternalBridgeName(String externalBridgeName) {
- this.externalBridgeName = externalBridgeName;
- }
-
- @Override
- public String getTunnelEndpointKey() {
- return tunnelEndpointKey;
- }
-
- @Override
- public void setTunnelEndpointKey(String tunnelEndpointKey) {
- this.tunnelEndpointKey = tunnelEndpointKey;
- }
-
- @Override
- public String getProviderMappingsKey() {
- return providerMappingsKey;
- }
-
- @Override
- public void setProviderMappingsKey(String providerMappingsKey) {
- this.providerMappingsKey = providerMappingsKey;
- }
-
- @Override
- public Map<Pair<String, String>, String> getPatchPortNames() {
- return patchPortNames;
- }
-
- @Override
- public void setPatchPortNames(Map<Pair<String, String>, String> patchPortNames) {
- this.patchPortNames = patchPortNames;
- }
-
- @Override
- public String getPatchPortName(Pair portTuple){
- return this.patchPortNames.get(portTuple);
- }
-
- @Override
- public String getDefaultProviderMapping() {
- return providerMapping;
- }
-
- @Override
- public void setDefaultProviderMapping(String providerMapping) {
- this.providerMapping = providerMapping;
- }
-
- @Override
- public InetAddress getTunnelEndPoint(Node node) {
- InetAddress address = null;
- 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) {
- LOG.error("Error populating Tunnel Endpoint for Node {} ", node, e);
- }
- }
- return address;
- }
-
- @Override
- public String getOpenflowVersion(Node node) {
- 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 boolean isRemoteMacLearnEnabled() {
- final String enabledPropertyStr = ConfigProperties.getProperty(this.getClass(), "ovsdb.remotemac.learn.enabled");
- return enabledPropertyStr != null && enabledPropertyStr.equalsIgnoreCase("yes");
- }
-
- @Override
- public boolean isL3MultipleExternalNetworkEnabled() {
- final String enabledPropertyStr = ConfigProperties.getProperty(this.getClass(), "ovsdb.l3.multiple.network.enabled");
- return enabledPropertyStr != null && enabledPropertyStr.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");
- }
- return l3gatewayForNode;
- }
-
- @Override
- 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
- public void setDependencies(Object impl) {
- }
-}
Code Review / netvirt.git / blobdiff