+++ /dev/null
-/*
- * Copyright (c) 2016 NEC Corporation 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.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.concurrent.Executors;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.RejectedExecutionException;
-import java.util.concurrent.ThreadFactory;
-
-import com.google.common.base.Preconditions;
-import com.google.common.util.concurrent.ThreadFactoryBuilder;
-
-import org.opendaylight.netvirt.openstack.netvirt.api.Action;
-import org.opendaylight.netvirt.openstack.netvirt.api.ArpProvider;
-import org.opendaylight.netvirt.openstack.netvirt.api.ConfigurationService;
-import org.opendaylight.netvirt.openstack.netvirt.api.NodeCacheManager;
-import org.opendaylight.netvirt.openstack.netvirt.api.Status;
-import org.opendaylight.netvirt.openstack.netvirt.api.StatusCode;
-import org.opendaylight.netvirt.openstack.netvirt.api.TenantNetworkManager;
-import org.opendaylight.netvirt.openstack.netvirt.translator.NeutronNetwork;
-import org.opendaylight.netvirt.openstack.netvirt.translator.crud.INeutronNetworkCRUD;
-import org.opendaylight.netvirt.openstack.netvirt.translator.crud.INeutronPortCRUD;
-import org.opendaylight.netvirt.openstack.netvirt.api.Southbound;
-import org.opendaylight.netvirt.openstack.netvirt.ConfigInterface;
-import org.opendaylight.netvirt.openstack.netvirt.translator.NeutronPort;
-import org.opendaylight.netvirt.openstack.netvirt.translator.Neutron_IPs;
-import org.opendaylight.netvirt.utils.servicehelper.ServiceHelper;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.OvsdbTerminationPointAugmentation;
-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;
-
-/**
- * ARP flows programmed for Neutron port.
- */
-public class DistributedArpService implements ConfigInterface {
-
- private static final Logger LOG = LoggerFactory.getLogger(DistributedArpService.class);
- private static final String DHCP_DEVICE_OWNER = "network:dhcp";
- private static final String ROUTER_INTERFACE_DEVICE_OWNER = "network:router_interface";
- private static final int NUM_THREADS = 5;
- // The implementation for each of these services is resolved by the OSGi Service Manager
- private volatile ConfigurationService configurationService;
- private volatile TenantNetworkManager tenantNetworkManager;
- private volatile NodeCacheManager nodeCacheManager;
- private volatile INeutronNetworkCRUD neutronNetworkCache;
- private volatile INeutronPortCRUD neutronPortCache;
- private volatile ArpProvider arpProvider;
- private volatile NeutronL3Adapter neutronL3Adapter;
-
- private Southbound southbound;
- private Boolean flgDistributedARPEnabled = true;
-
- private HashMap<String, List<Neutron_IPs>> dhcpPortIpCache = new HashMap();
-
- static ThreadFactory threadFactory = new ThreadFactoryBuilder()
- .setNameFormat("DistributedArp-%d").build();
- static ExecutorService executor = Executors.newFixedThreadPool(NUM_THREADS, threadFactory);
-
-
- private void initMembers() {
- Preconditions.checkNotNull(configurationService);
- if (configurationService.isDistributedArpDisabled()) {
- this.flgDistributedARPEnabled = false;
- LOG.debug("Distributed ARP responder is disabled");
- } else {
- LOG.debug("Distributed ARP responder is enabled");
- }
- }
-
- /**
- * Process the port event to write Arp rules for neutron ports.
- *
- * @param action the {@link Action} action to be handled.
- * @param isMigratedPort true, if the port is migrated else false.
- * @param bridgeNode the node for the port.
- * @param neutronPort An instance of NeutronPort object.
- */
- public void handlePortEvent(NeutronPort neutronPort, Node bridgeNode, boolean isMigratedPort, Action action) {
- LOG.debug("neutronPort Event {} action event {} ", neutronPort, action);
- this.handleNeutronPortForArp(neutronPort, bridgeNode, isMigratedPort, action);
- }
-
- /**
- * Arp rules are added/removed based on neutron port event
- *
- */
- boolean programStaticRuleStage1(Long dpid, String segOrOfPort,
- String macAddress, String ipStr,
- Action action) {
- if (action == Action.DELETE ) {
- LOG.trace("Deleting Flow : programStaticArpStage1 dpid {} segOrOfPort {} mac {} ip {} action {}",
- dpid, segOrOfPort, macAddress, ipStr, action);
- }
- if (action == Action.ADD) {
- LOG.trace("Adding Flow : programStaticArpStage1 dpid {} segOrOfPort {} mac {} ip {} action {}",
- dpid, segOrOfPort, macAddress, ipStr, action);
- }
-
- Status status = this.programStaticRuleStage2(dpid, segOrOfPort, macAddress, ipStr, action);
- return status.isSuccess();
- }
-
- /**
- * Arp rules are programmed by invoke arpProvider
- *
- */
- private Status programStaticRuleStage2(Long dpid,
- String segOrOfPort,
- String macAddress,
- String address,
- Action action) {
- Status status;
- try {
- InetAddress inetAddress = InetAddress.getByName(address);
- status = arpProvider == null ?
- new Status(StatusCode.SUCCESS) :
- arpProvider.programStaticArpEntry(dpid, segOrOfPort,
- macAddress, inetAddress, action);
- } catch (UnknownHostException e) {
- status = new Status(StatusCode.BADREQUEST);
- }
-
- if (status.isSuccess()) {
- LOG.debug("programStaticRuleStage2 {} for mac:{} addr:{} dpid:{} segOrOfPort:{} action:{}",
- arpProvider == null ? "skipped" : "programmed",
- macAddress, address, dpid, segOrOfPort, action);
- } else {
- LOG.warn("programStaticRuleStage2 failed for mac:{} addr:{} dpid:{} segOrOfPort:{} action:{} status:{}",
- macAddress, address, dpid, segOrOfPort, action, status);
- }
- return status;
- }
-
- /**
- * Write Arp rules based on event for neutron port.
- *
- * @param action the {@link Action} action to be handled.
- * @param isMigratedPort true, if the port is migrated else false.
- * @param bridgeNode the node for the port.
- * @param neutronPort An instance of NeutronPort object.
- */
- private void handleNeutronPortForArp(NeutronPort neutronPort, Node bridgeNode, boolean isMigratedPort, Action action) {
- if (!flgDistributedARPEnabled) {
- return;
- }
-
- //treat UPDATE as ADD
- final Action actionToPerform = action == Action.DELETE ? Action.DELETE : Action.ADD;
- final String providerSegmentationId = getSegmentationId(neutronPort);
- if (providerSegmentationId == null || providerSegmentationId.isEmpty()) {
- return;
- }
- List<Node> nodes = nodeCacheManager.getBridgeNodes();
- if (nodes.isEmpty()) {
- LOG.trace("updateL3ForNeutronPort has no nodes to work with");
- }
- String owner = neutronPort.getDeviceOwner();
- boolean isDhcpPort = owner != null && owner.equals(DHCP_DEVICE_OWNER);
- for (Node node : nodes) {
- if(actionToPerform == Action.DELETE && !isDhcpPort &&
- (isMigratedPort && !bridgeNode.getNodeId().equals(node.getNodeId()))) {
- continue;
- }
- handleArpRule(node, neutronPort, providerSegmentationId, isMigratedPort, actionToPerform);
- }
- }
-
- private void handleArpRule(Node node, NeutronPort neutronPort,
- String providerSegmentationId, boolean isMigratedPort, Action actionToPerform) {
- String owner = neutronPort.getDeviceOwner();
- boolean isRouterInterface = owner != null && owner.equals(ROUTER_INTERFACE_DEVICE_OWNER);
- boolean isDhcpPort = owner != null && owner.equals(DHCP_DEVICE_OWNER);
- List<Neutron_IPs> fixedIps = neutronPort.getFixedIPs();
- if((null == fixedIps || fixedIps.isEmpty())
- && actionToPerform == Action.DELETE && isDhcpPort){
- fixedIps = dhcpPortIpCache.get(neutronPort.getPortUUID());
- if(fixedIps == null) {
- return;
- }
- }
- List <NeutronPort> neutronPortList = new ArrayList();
- // Arp rule is only needed when segmentation exists in the given node (bug 4752)
- // or in case the port is a router interface
- boolean isTenantNetworkPresentInNode = getNeutronPortsForNode(node, neutronPortList, providerSegmentationId);
- boolean arpNeeded = isRouterInterface || isTenantNetworkPresentInNode;
- final Action actionForNode = arpNeeded ? actionToPerform : Action.DELETE;
- NeutronPort existingPort = null;
- if (neutronPortList.size() == 1) {
- existingPort = neutronPortList.get(0);
- }
- final String macAddress = neutronPort.getMacAddress();
- if (macAddress == null || macAddress.isEmpty()) {
- // done: go no further w/out all the info needed...
- return;
- }
- final Long dpid = getDatapathIdIntegrationBridge(node);
- if (dpid == null) {
- return;
- }
- if (arpNeeded) {
- // For a node Arp rule is added for all ports only when the list of NeutronPorts size is 1.
- // If not Arp is added for the current port only (bug 6998)
- if (neutronPortList.size() == 1 && neutronPort.getPortUUID().equalsIgnoreCase(existingPort.getPortUUID())) {
- for (NeutronPort port : neutronPortCache.getAllPorts()) {
- final String portSegmentationId = getSegmentationId(port);
- if (portSegmentationId != null && portSegmentationId.equals(providerSegmentationId)) {
- final String portMacAddress = port.getMacAddress();
- for (Neutron_IPs neutronIPAddr : port.getFixedIPs()) {
- final String portIpAddress = neutronIPAddr.getIpAddress();
- try {
- executor.submit(() ->
- programStaticRuleStage1(dpid, providerSegmentationId, portMacAddress,
- portIpAddress, actionForNode));
- } catch (RejectedExecutionException ex) {
- LOG.error("handleArpRule : unable to accept execution.", ex);
- programStaticRuleStage1(dpid, providerSegmentationId, portMacAddress,
- portIpAddress, actionForNode);
- }
- }
- }
- }
- } else {
- if(!isMigratedPort) {
- for (Neutron_IPs neutronIPAddr : neutronPort.getFixedIPs()) {
- final String ipAddress = neutronIPAddr.getIpAddress();
- try {
- executor.submit(() ->
- programStaticRuleStage1(dpid, providerSegmentationId, macAddress,
- ipAddress, actionForNode));
- } catch (RejectedExecutionException ex) {
- LOG.error("handleArpRule : unable to accept execution.", ex);
- programStaticRuleStage1(dpid, providerSegmentationId, macAddress,
- ipAddress, actionForNode);
- }
- }
- }
- }
- } else {
- if (actionToPerform == Action.DELETE) {
- // Arp flows for DHCP port should remove from control node
- // when network removed (bug 7333).
- if (isDhcpPort) {
- for (Neutron_IPs neutronIP : fixedIps) {
- final String dhcpIpAddress = neutronIP.getIpAddress();
- if (dhcpIpAddress.isEmpty()) {
- continue;
- }
- try {
- executor.submit(() ->
- programStaticRuleStage1(dpid, providerSegmentationId, macAddress,
- dhcpIpAddress, actionToPerform));
- } catch (RejectedExecutionException ex) {
- LOG.error("handleArpRule : unable to accept execution.", ex);
- programStaticRuleStage1(dpid, providerSegmentationId, macAddress,
- dhcpIpAddress, actionToPerform);
- }
- }
- }
- for (NeutronPort delPort : neutronL3Adapter.getPortCleanupCache().values()) {
- if (!delPort.getDeviceOwner().equalsIgnoreCase(ROUTER_INTERFACE_DEVICE_OWNER)) {
- final String delMacAddress = delPort.getMacAddress();
- if (null == delMacAddress || delMacAddress.isEmpty()) {
- continue;
- }
- for (Neutron_IPs neutronIPAddr : delPort.getFixedIPs()) {
- final String delIpAddress = neutronIPAddr.getIpAddress();
- if (null == delIpAddress || delIpAddress.isEmpty()) {
- continue;
- }
- try {
- executor.submit(() ->
- programStaticRuleStage1(dpid, providerSegmentationId, delMacAddress,
- delIpAddress, actionToPerform));
- } catch (RejectedExecutionException ex) {
- LOG.error("handleArpRule : unable to accept execution.", ex);
- programStaticRuleStage1(dpid, providerSegmentationId, delMacAddress,
- delIpAddress, actionToPerform);
- }
- }
- }
- }
- }
- }
- if(isDhcpPort && actionToPerform == Action.ADD){
- dhcpPortIpCache.put(neutronPort.getPortUUID(), fixedIps);
- } else if (isDhcpPort && actionToPerform == Action.DELETE) {
- dhcpPortIpCache.remove(neutronPort.getPortUUID());
- }
- }
-
- /**
- * Check if node is integration bridge, then return its datapathID.
- * @param node An instance of Node object.
- */
- private Long getDatapathIdIntegrationBridge(Node node) {
- if (southbound.getBridge(node, configurationService.getIntegrationBridgeName()) != null) {
- return southbound.getDataPathId(node);
- }
- return null;
- }
-
- /**
- * Process the event.
- *
- * @param bridgeNode An instance of Node object.
- * @param intf An {@link org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105
- * .OvsdbTerminationPointAugmentation} instance of OvsdbTerminationPointAugmentation object.
- * @param neutronNetwork An {@link NeutronNetwork} instance of NeutronNetwork
- * object.
- * @param isMigratedPort true, if the port is migrated else false.
- * @param action the {@link Action} action to be handled.
- */
- public void processInterfaceEvent(final Node bridgeNode, final OvsdbTerminationPointAugmentation intf,
- final NeutronNetwork neutronNetwork, boolean isMigratedPort, Action action) {
- LOG.debug("southbound interface {} node:{} interface:{}, neutronNetwork:{}",
- action, bridgeNode.getNodeId().getValue(), intf.getName(), neutronNetwork);
- final NeutronPort neutronPort = tenantNetworkManager.getTenantPort(intf);
- if (neutronPort != null) {
- this.handlePortEvent(neutronPort, bridgeNode, isMigratedPort, action);
- }
- }
-
- @Override
- public void setDependencies(ServiceReference serviceReference) {
- tenantNetworkManager =
- (TenantNetworkManager) ServiceHelper.getGlobalInstance(TenantNetworkManager.class, this);
- configurationService =
- (ConfigurationService) ServiceHelper.getGlobalInstance(ConfigurationService.class, this);
- arpProvider =
- (ArpProvider) ServiceHelper.getGlobalInstance(ArpProvider.class, this);
- nodeCacheManager =
- (NodeCacheManager) ServiceHelper.getGlobalInstance(NodeCacheManager.class, this);
- southbound =
- (Southbound) ServiceHelper.getGlobalInstance(Southbound.class, this);
- neutronL3Adapter =
- (NeutronL3Adapter) ServiceHelper.getGlobalInstance(NeutronL3Adapter.class, this);
- initMembers();
- }
-
- @Override
- public void setDependencies(Object impl) {
- if (impl instanceof INeutronNetworkCRUD) {
- neutronNetworkCache = (INeutronNetworkCRUD)impl;
- } else if (impl instanceof INeutronPortCRUD) {
- neutronPortCache = (INeutronPortCRUD)impl;
- } else if (impl instanceof ArpProvider) {
- arpProvider = (ArpProvider)impl;
- }
- }
-
- private boolean isInterfacePresentInTenantNetwork (String portId, String networkId) {
- NeutronPort neutronPort = neutronPortCache.getPort(portId);
- return neutronPort != null && neutronPort.getNetworkUUID().equalsIgnoreCase(networkId);
- }
-
- /**
- * Populates the list of neutron ports for node and
- * check whether the segId is available on node or not.
- *
- * @param Node An instance of Node object.
- * @param List<neutronPort> An instances list of NeutronPort object.
- * @param String value for segmentationId.
- */
- private boolean getNeutronPortsForNode(Node node, List<NeutronPort> neutronPortList, String segmentationId) {
- List<OvsdbTerminationPointAugmentation> ports = southbound.readTerminationPointAugmentations(node);
- boolean isTenantNetworkPresentInNode = false;
- String networkId = tenantNetworkManager.getNetworkId(segmentationId);
- for (OvsdbTerminationPointAugmentation port : ports) {
- if (networkId != null) {
- String ifaceId = southbound.getInterfaceExternalIdsValue(port, "iface-id");
- if (ifaceId != null && isInterfacePresentInTenantNetwork(ifaceId, networkId)) {
- LOG.debug("Tenant Network {} with Segmentation-id {} is present in Node {} / Interface {}",
- networkId, segmentationId, node, port);
- isTenantNetworkPresentInNode = true;
- }
- }
- NeutronPort neutronPort = tenantNetworkManager.getTenantPort(port);
- if (neutronPort != null) {
- final String portSegmentationId = getSegmentationId(neutronPort);
- if (portSegmentationId != null && portSegmentationId.equals(segmentationId)) {
- neutronPortList.add(neutronPort);
- }
- }
- }
- return isTenantNetworkPresentInNode;
- }
-
- /**
- * To get segmentationId.
- *
- * @param neutronPort An instance of NeutronPort object
- */
- private String getSegmentationId(NeutronPort neutronPort) {
- final String networkUUID = neutronPort.getNetworkUUID();
- NeutronNetwork neutronNetwork = neutronNetworkCache.getNetwork(networkUUID);
- if (null == neutronNetwork) {
- neutronNetwork = neutronL3Adapter.getNetworkFromCleanupCache(networkUUID);
- }
- final String portSegmentationId = neutronNetwork != null ?
- neutronNetwork.getProviderSegmentationID() : null;
- return portSegmentationId;
- }
-}
Code Review / netvirt.git / blobdiff