X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=interfacemanager%2Finterfacemanager-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fgenius%2Finterfacemanager%2FIfmUtil.java;h=4537e3cb3c1656e9ca34756abbe71c1e5d86b357;hb=3c0976cd13ecc0991829ebc38e874317d8836ca8;hp=7029755b184dd3ec5320d0be69555798be6a8956;hpb=4d40e4df2aecf56fde2fb00906693f58161265f1;p=genius.git diff --git a/interfacemanager/interfacemanager-impl/src/main/java/org/opendaylight/genius/interfacemanager/IfmUtil.java b/interfacemanager/interfacemanager-impl/src/main/java/org/opendaylight/genius/interfacemanager/IfmUtil.java index 7029755b1..4537e3cb3 100755 --- a/interfacemanager/interfacemanager-impl/src/main/java/org/opendaylight/genius/interfacemanager/IfmUtil.java +++ b/interfacemanager/interfacemanager-impl/src/main/java/org/opendaylight/genius/interfacemanager/IfmUtil.java @@ -1,5 +1,5 @@ /* - * Copyright (c) 2016 Ericsson India Global Services Pvt Ltd. and others. All rights reserved. + * Copyright (c) 2016, 2017 Ericsson India Global Services Pvt Ltd. 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, @@ -7,14 +7,20 @@ */ package org.opendaylight.genius.interfacemanager; +import static org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.GRE_TRUNK_INTERFACE; +import static org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.MPLS_OVER_GRE; +import static org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.VLAN_INTERFACE; +import static org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.VXLAN_TRUNK_INTERFACE; + import com.google.common.base.Optional; import com.google.common.collect.ImmutableMap; +import com.google.common.util.concurrent.ListenableFuture; import java.math.BigInteger; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; -import com.google.common.util.concurrent.ListenableFuture; +import org.apache.commons.lang3.BooleanUtils; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction; import org.opendaylight.controller.md.sal.binding.api.WriteTransaction; @@ -24,13 +30,21 @@ import org.opendaylight.genius.interfacemanager.commons.InterfaceManagerCommonUt import org.opendaylight.genius.interfacemanager.globals.InterfaceInfo; import org.opendaylight.genius.interfacemanager.globals.VlanInterfaceInfo; import org.opendaylight.genius.interfacemanager.servicebindings.flowbased.utilities.FlowBasedServicesUtils; -import org.opendaylight.genius.mdsalutil.ActionType; import org.opendaylight.genius.mdsalutil.ActionInfo; import org.opendaylight.genius.mdsalutil.MDSALUtil; import org.opendaylight.genius.mdsalutil.MetaDataUtil; import org.opendaylight.genius.mdsalutil.NwConstants; +import org.opendaylight.genius.mdsalutil.actions.ActionNxResubmit; +import org.opendaylight.genius.mdsalutil.actions.ActionOutput; +import org.opendaylight.genius.mdsalutil.actions.ActionPushVlan; +import org.opendaylight.genius.mdsalutil.actions.ActionRegLoad; +import org.opendaylight.genius.mdsalutil.actions.ActionSetFieldTunnelId; +import org.opendaylight.genius.mdsalutil.actions.ActionSetFieldVlanVid; +import org.opendaylight.genius.mdsalutil.actions.ActionSetTunnelDestinationIp; +import org.opendaylight.genius.mdsalutil.actions.ActionSetTunnelSourceIp; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.L2vlan; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.iana._if.type.rev140508.Tunnel; +import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Uri; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface; @@ -54,6 +68,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfL2vlan.L2vlanMode; import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.IfTunnel; import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefs; +import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.ParentRefsBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeBase; import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeGre; import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.rev160406.TunnelTypeMplsOverGre; @@ -67,11 +82,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.ser import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.interfacemanager.servicebinding.rev160406.service.bindings.services.info.BoundServicesKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorKey; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey; +import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg6; import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ovsdb.rev150105.DatapathId; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; @@ -80,19 +91,15 @@ import org.opendaylight.yangtools.yang.common.RpcResult; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import static org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.VLAN_INTERFACE; - public class IfmUtil { private static final Logger LOG = LoggerFactory.getLogger(IfmUtil.class); private static final int INVALID_ID = 0; - private static final ImmutableMap, InterfaceInfo.InterfaceType> TUNNEL_TYPE_MAP = - new ImmutableMap.Builder, InterfaceInfo.InterfaceType>() - .put(TunnelTypeGre.class, InterfaceInfo.InterfaceType.GRE_TRUNK_INTERFACE) - .put(TunnelTypeMplsOverGre.class, InterfaceInfo.InterfaceType.MPLS_OVER_GRE) - .put(TunnelTypeVxlan.class, InterfaceInfo.InterfaceType.VXLAN_TRUNK_INTERFACE) - .put(TunnelTypeVxlanGpe.class, InterfaceInfo.InterfaceType.VXLAN_TRUNK_INTERFACE) - .build(); + private static final ImmutableMap, InterfaceInfo.InterfaceType> + TUNNEL_TYPE_MAP = new ImmutableMap.Builder, InterfaceInfo.InterfaceType>() + .put(TunnelTypeGre.class, GRE_TRUNK_INTERFACE).put(TunnelTypeMplsOverGre.class, MPLS_OVER_GRE) + .put(TunnelTypeVxlan.class, VXLAN_TRUNK_INTERFACE).put(TunnelTypeVxlanGpe.class, VXLAN_TRUNK_INTERFACE) + .build(); public static BigInteger getDpnFromNodeConnectorId(NodeConnectorId portId) { /* @@ -102,26 +109,15 @@ public class IfmUtil { return new BigInteger(split[1]); } - public static BigInteger getDpnFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState){ + public static BigInteger getDpnFromInterface( + org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.Interface ifState) { NodeConnectorId ncId = getNodeConnectorIdFromInterface(ifState); - if(ncId != null){ + if (ncId != null) { return getDpnFromNodeConnectorId(ncId); } return null; } - public static String getPortNoFromInterfaceName(String ifaceName, DataBroker broker) { - org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState = - InterfaceManagerCommonUtils.getInterfaceStateFromOperDS(ifaceName, broker); - - if(ifState == null){ - throw new NullPointerException("Interface information not present in oper DS for " +ifaceName); - } - String lowerLayerIf = ifState.getLowerLayerIf().get(0); - NodeConnectorId nodeConnectorId = new NodeConnectorId(lowerLayerIf); - String portNo = IfmUtil.getPortNoFromNodeConnectorId(nodeConnectorId); - - return portNo; - } public static String getPortNoFromNodeConnectorId(NodeConnectorId portId) { /* @@ -131,89 +127,82 @@ public class IfmUtil { return split[2]; } + public static Long getPortNumberFromNodeConnectorId(NodeConnectorId portId) { + String portNo = getPortNoFromNodeConnectorId(portId); + try { + return Long.valueOf(portNo); + } catch (NumberFormatException ex) { + LOG.trace("Unable to retrieve port number from nodeconnector id for {}", portId); + } + return IfmConstants.INVALID_PORT_NO; + } + public static NodeId buildDpnNodeId(BigInteger dpnId) { return new NodeId(IfmConstants.OF_URI_PREFIX + dpnId); } public static InstanceIdentifier buildId(String interfaceName) { - //TODO Make this generic and move to AbstractDataChangeListener or Utils. - InstanceIdentifierBuilder idBuilder = - InstanceIdentifier.builder(Interfaces.class).child(Interface.class, new InterfaceKey(interfaceName)); - InstanceIdentifier id = idBuilder.build(); - return id; - } - - public static InstanceIdentifier buildStateInterfaceId(String interfaceName) { - InstanceIdentifierBuilder idBuilder = - InstanceIdentifier.builder(InterfacesState.class) - .child(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.class, - new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey(interfaceName)); - InstanceIdentifier id = idBuilder.build(); + // TODO Make this generic and move to AbstractDataChangeListener or + // Utils. + InstanceIdentifierBuilder idBuilder = InstanceIdentifier.builder(Interfaces.class) + .child(Interface.class, new InterfaceKey(interfaceName)); + return idBuilder.build(); + } + + public static InstanceIdentifier buildStateInterfaceId( + String interfaceName) { + InstanceIdentifierBuilder idBuilder = InstanceIdentifier + .builder(InterfacesState.class) + .child(org.opendaylight.yang.gen.v1.urn + .ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface.class, + new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.InterfaceKey( + interfaceName)); + InstanceIdentifier id = idBuilder + .build(); return id; } - public static org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey getStateInterfaceKeyFromName( + public static org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.InterfaceKey getStateInterfaceKeyFromName( String name) { - return new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey(name); + return new org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.InterfaceKey( + name); } - public static InstanceIdentifier getPoolId(String poolName){ - InstanceIdentifier.InstanceIdentifierBuilder idBuilder = - InstanceIdentifier.builder(IdPools.class).child(IdPool.class, new IdPoolKey(poolName)); - InstanceIdentifier id = idBuilder.build(); - return id; - } - - public static List getPortNameAndSuffixFromInterfaceName(String intfName) { - List strList = new ArrayList<>(2); - int index = intfName.indexOf(":"); - if (index != -1) { - strList.add(0, intfName.substring(0, index)); - strList.add(1, intfName.substring(index)); - } - return strList; + public static InstanceIdentifier getPoolId(String poolName) { + return InstanceIdentifier.builder(IdPools.class).child(IdPool.class, new IdPoolKey(poolName)).build(); } public static long getGroupId(long ifIndex, InterfaceInfo.InterfaceType infType) { if (infType == InterfaceInfo.InterfaceType.LOGICAL_GROUP_INTERFACE) { return ifIndex + IfmConstants.LOGICAL_GROUP_START; - } - else if (infType == VLAN_INTERFACE) { + } else if (infType == VLAN_INTERFACE) { return ifIndex + IfmConstants.VLAN_GROUP_START; } else { return ifIndex + IfmConstants.TRUNK_GROUP_START; } } - public static List getDpIdPortNameAndSuffixFromInterfaceName(String intfName) { - List strList = new ArrayList<>(3); - int index1 = intfName.indexOf(":"); - if (index1 != -1) { - int index2 = intfName.indexOf(":", index1 + 1 ); - strList.add(0, intfName.substring(0, index1)); - if (index2 != -1) { - strList.add(1, intfName.substring(index1, index2)); - strList.add(2, intfName.substring(index2)); - } else { - strList.add(1, intfName.substring(index1)); - strList.add(2, ""); - } - } - return strList; - } - public static Optional read(LogicalDatastoreType datastoreType, - InstanceIdentifier path, DataBroker broker) { + InstanceIdentifier path, DataBroker broker) { try (ReadOnlyTransaction tx = broker.newReadOnlyTransaction()) { return tx.read(datastoreType, path).get(); - } catch (Exception e) { + } catch (InterruptedException | ExecutionException e) { + LOG.error("Cannot read identifier", e); throw new RuntimeException(e); } } public static List getEgressActionsForInterface(String interfaceName, Long tunnelKey, Integer actionKey, - DataBroker dataBroker, Boolean isDefaultEgress) { - List listActionInfo = getEgressActionInfosForInterface(interfaceName, tunnelKey, actionKey==null?0:actionKey, dataBroker, isDefaultEgress); + DataBroker dataBroker, Boolean isDefaultEgress) { + List listActionInfo = getEgressActionInfosForInterface(interfaceName, tunnelKey, + actionKey == null ? 0 : actionKey, dataBroker, isDefaultEgress); List actionsList = new ArrayList<>(); for (ActionInfo actionInfo : listActionInfo) { actionsList.add(actionInfo.buildAction()); @@ -222,55 +211,55 @@ public class IfmUtil { } public static List getEgressInstructionsForInterface(String interfaceName, Long tunnelKey, - DataBroker dataBroker, Boolean isDefaultEgress) { + DataBroker dataBroker, Boolean isDefaultEgress) { List instructions = new ArrayList<>(); - List actionList = MDSALUtil.buildActions(getEgressActionInfosForInterface( - interfaceName, tunnelKey, 0, dataBroker, isDefaultEgress)); + List actionList = MDSALUtil.buildActions( + getEgressActionInfosForInterface(interfaceName, tunnelKey, 0, dataBroker, isDefaultEgress)); instructions.add(MDSALUtil.buildApplyActionsInstruction(actionList)); - return instructions; + return instructions; } public static List getEgressInstructionsForInterface(Interface interfaceInfo, String portNo, - Long tunnelKey, boolean isDefaultEgress, int ifIndex) { + Long tunnelKey, boolean isDefaultEgress, int ifIndex) { List instructions = new ArrayList<>(); InterfaceInfo.InterfaceType ifaceType = getInterfaceType(interfaceInfo); - List actionList = MDSALUtil.buildActions( - getEgressActionInfosForInterface(interfaceInfo, portNo, ifaceType, tunnelKey, 0, isDefaultEgress, ifIndex)); + List actionList = MDSALUtil.buildActions(getEgressActionInfosForInterface(interfaceInfo, portNo, + ifaceType, tunnelKey, 0, isDefaultEgress, ifIndex)); instructions.add(MDSALUtil.buildApplyActionsInstruction(actionList)); - return instructions; + return instructions; } - - public static List getEgressActionInfosForInterface(String interfaceName, - int actionKeyStart, - DataBroker dataBroker, - Boolean isDefaultEgress) { + public static List getEgressActionInfosForInterface(String interfaceName, int actionKeyStart, + DataBroker dataBroker, Boolean isDefaultEgress) { return getEgressActionInfosForInterface(interfaceName, null, actionKeyStart, dataBroker, isDefaultEgress); } /** - * Returns a list of Actions to be taken when sending a packet over an interface + * Returns a list of Actions to be taken when sending a packet over an + * interface. * * @param interfaceName - * @param tunnelKey Optional. + * name of the interface + * @param tunnelKey + * Optional. * @param actionKeyStart + * action key * @param dataBroker - * @return + * databroker + * @return list of actions */ - public static List getEgressActionInfosForInterface(String interfaceName, - Long tunnelKey, - int actionKeyStart, - DataBroker dataBroker, - Boolean isDefaultEgress) { + public static List getEgressActionInfosForInterface(String interfaceName, Long tunnelKey, + int actionKeyStart, DataBroker dataBroker, Boolean isDefaultEgress) { Interface interfaceInfo = InterfaceManagerCommonUtils.getInterfaceFromConfigDS(new InterfaceKey(interfaceName), dataBroker); - if(interfaceInfo == null){ - throw new NullPointerException("Interface information not present in config DS for " +interfaceName); + if (interfaceInfo == null) { + throw new NullPointerException("Interface information not present in config DS for " + interfaceName); } - org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState = - InterfaceManagerCommonUtils.getInterfaceStateFromOperDS(interfaceName, dataBroker); - if(ifState == null){ - throw new NullPointerException("Interface information not present in oper DS for " +interfaceName); + org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.Interface ifState = InterfaceManagerCommonUtils + .getInterfaceStateFromOperDS(interfaceName, dataBroker); + if (ifState == null) { + throw new NullPointerException("Interface information not present in oper DS for " + interfaceName); } String lowerLayerIf = ifState.getLowerLayerIf().get(0); NodeConnectorId nodeConnectorId = new NodeConnectorId(lowerLayerIf); @@ -281,53 +270,75 @@ public class IfmUtil { isDefaultEgress, ifState.getIfIndex()); } - - public static List getEgressActionInfosForInterface(Interface interfaceInfo, - String portNo, - InterfaceInfo.InterfaceType ifaceType, - Long tunnelKey, - int actionKeyStart, - boolean isDefaultEgress, - int ifIndex) { + /** + * Returns the list of egress actions for a given interface. + * + * @param interfaceInfo the interface to look up + * @param portNo port number + * @param ifaceType the type of the interface + * @param tunnelKey the tunnel key + * @param actionKeyStart the start for the first key assigned for the new actions + * @param isDefaultEgress if it is the default egress + * @param ifIndex interface index + * @return list of actions for the interface + */ + // The following suppression is for javac, not for checkstyle + @SuppressWarnings("fallthrough") + public static List getEgressActionInfosForInterface(Interface interfaceInfo, String portNo, + InterfaceInfo.InterfaceType ifaceType, Long tunnelKey, int actionKeyStart, boolean isDefaultEgress, + int ifIndex) { List result = new ArrayList<>(); switch (ifaceType) { + case MPLS_OVER_GRE: + // fall through + case GRE_TRUNK_INTERFACE: + if (!isDefaultEgress) { + // TODO tunnel_id to encode GRE key, once it is supported + // Until then, tunnel_id should be "cleaned", otherwise it + // stores the value coming from a VXLAN tunnel + if (tunnelKey == null) { + tunnelKey = 0L; + } + } + // fall through + case VXLAN_TRUNK_INTERFACE: + if (!isDefaultEgress) { + if (tunnelKey != null) { + result.add(new ActionSetFieldTunnelId(actionKeyStart++, BigInteger.valueOf(tunnelKey))); + } + + IfTunnel ifTunnel = interfaceInfo.getAugmentation(IfTunnel.class); + if (BooleanUtils.isTrue(ifTunnel.isTunnelRemoteIpFlow())) { + result.add(new ActionSetTunnelDestinationIp(actionKeyStart++, ifTunnel.getTunnelDestination())); + } + if (BooleanUtils.isTrue(ifTunnel.isTunnelSourceIpFlow())) { + result.add(new ActionSetTunnelSourceIp(actionKeyStart++, ifTunnel.getTunnelSource())); + } + } + // fall through case VLAN_INTERFACE: - if(isDefaultEgress) { + if (isDefaultEgress) { IfL2vlan vlanIface = interfaceInfo.getAugmentation(IfL2vlan.class); LOG.trace("L2Vlan: {}", vlanIface); boolean isVlanTransparent = false; - long vlanVid = 0; + int vlanVid = 0; if (vlanIface != null) { vlanVid = vlanIface.getVlanId() == null ? 0 : vlanIface.getVlanId().getValue(); isVlanTransparent = vlanIface.getL2vlanMode() == IfL2vlan.L2vlanMode.Transparent; } if (vlanVid != 0 && !isVlanTransparent) { - result.add(new ActionInfo(ActionType.push_vlan, new String[]{}, actionKeyStart++)); - result.add(new ActionInfo(ActionType.set_field_vlan_vid, - new String[]{Long.toString(vlanVid)}, actionKeyStart++)); + result.add(new ActionPushVlan(actionKeyStart++)); + result.add(new ActionSetFieldVlanVid(actionKeyStart++, vlanVid)); } - result.add(new ActionInfo(ActionType.output, new String[]{portNo}, actionKeyStart++)); - }else{ - long regValue = MetaDataUtil.getReg6ValueForLPortDispatcher(ifIndex, NwConstants.DEFAULT_SERVICE_INDEX); - result.add(new ActionInfo(ActionType.nx_load_reg_6, - new String[]{Integer.toString(IfmConstants.REG6_START_INDEX), Integer.toString(IfmConstants.REG6_END_INDEX), - Long.toString(regValue)}, actionKeyStart++)); - result.add(new ActionInfo(ActionType.nx_resubmit, - new String[]{Short.toString(NwConstants.EGRESS_LPORT_DISPATCHER_TABLE)}, actionKeyStart++)); + result.add(new ActionOutput(actionKeyStart++, new Uri(portNo))); + } else { + long regValue = + MetaDataUtil.getReg6ValueForLPortDispatcher(ifIndex, NwConstants.DEFAULT_SERVICE_INDEX); + result.add(new ActionRegLoad(actionKeyStart++, NxmNxReg6.class, IfmConstants.REG6_START_INDEX, + IfmConstants.REG6_END_INDEX, regValue)); + result.add(new ActionNxResubmit(actionKeyStart++, NwConstants.EGRESS_LPORT_DISPATCHER_TABLE)); } break; - case MPLS_OVER_GRE: - case VXLAN_TRUNK_INTERFACE: - case GRE_TRUNK_INTERFACE: - //TODO tunnel_id to encode GRE key, once it is supported - // Until then, tunnel_id should be "cleaned", otherwise it stores the value coming from a VXLAN tunnel - if (tunnelKey == null) - tunnelKey = 0L; - result.add(new ActionInfo(ActionType.set_field_tunnel_id, - new BigInteger[]{BigInteger.valueOf(tunnelKey)},actionKeyStart++)); - result.add(new ActionInfo(ActionType.output, new String[]{portNo}, actionKeyStart++)); - break; - default: LOG.warn("Interface Type {} not handled yet", ifaceType); break; @@ -336,7 +347,7 @@ public class IfmUtil { } public static NodeId getNodeIdFromNodeConnectorId(NodeConnectorId ncId) { - return new NodeId(ncId.getValue().substring(0,ncId.getValue().lastIndexOf(":"))); + return new NodeId(ncId.getValue().substring(0, ncId.getValue().lastIndexOf(":"))); } public static BigInteger[] mergeOpenflowMetadataWriteInstructions(List instructions) { @@ -345,9 +356,11 @@ public class IfmUtil { if (instructions != null && !instructions.isEmpty()) { // check if metadata write instruction is present for (Instruction instruction : instructions) { - org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.Instruction actualInstruction = instruction.getInstruction(); + org.opendaylight.yang.gen.v1.urn.opendaylight.flow + .types.rev131026.instruction.Instruction actualInstruction = instruction + .getInstruction(); if (actualInstruction instanceof WriteMetadataCase) { - WriteMetadataCase writeMetaDataInstruction = (WriteMetadataCase) actualInstruction ; + WriteMetadataCase writeMetaDataInstruction = (WriteMetadataCase) actualInstruction; WriteMetadata availableMetaData = writeMetaDataInstruction.getWriteMetadata(); metadata = metadata.or(availableMetaData.getMetadata()); metadataMask = metadataMask.or(availableMetaData.getMetadataMask()); @@ -358,45 +371,40 @@ public class IfmUtil { } public static Integer allocateId(IdManagerService idManager, String poolName, String idKey) { - AllocateIdInput getIdInput = new AllocateIdInputBuilder() - .setPoolName(poolName) - .setIdKey(idKey).build(); + AllocateIdInput getIdInput = new AllocateIdInputBuilder().setPoolName(poolName).setIdKey(idKey).build(); try { Future> result = idManager.allocateId(getIdInput); RpcResult rpcResult = result.get(); - if(rpcResult.isSuccessful()) { + if (rpcResult.isSuccessful()) { return rpcResult.getResult().getIdValue().intValue(); } else { LOG.warn("RPC Call to Get Unique Id returned with Errors {}", rpcResult.getErrors()); } } catch (InterruptedException | ExecutionException e) { - LOG.warn("Exception when getting Unique Id",e); + LOG.warn("Exception when getting Unique Id", e); } return INVALID_ID; } public static void releaseId(IdManagerService idManager, String poolName, String idKey) { - ReleaseIdInput idInput = new ReleaseIdInputBuilder() - .setPoolName(poolName) - .setIdKey(idKey).build(); + ReleaseIdInput idInput = new ReleaseIdInputBuilder().setPoolName(poolName).setIdKey(idKey).build(); try { Future> result = idManager.releaseId(idInput); RpcResult rpcResult = result.get(); - if(!rpcResult.isSuccessful()) { - LOG.warn("RPC Call to release Id {} with Key {} returned with Errors {}", - idKey, rpcResult.getErrors()); + if (!rpcResult.isSuccessful()) { + LOG.warn("RPC Call to release Id {} with Key {} returned with Errors {}", idKey, rpcResult.getErrors()); } } catch (InterruptedException | ExecutionException e) { LOG.warn("Exception when releasing Id for key {}", idKey, e); } } - public static BigInteger getDpnId(DatapathId datapathId){ + public static BigInteger getDpnId(DatapathId datapathId) { if (datapathId != null) { - // Adding logs for a random issue spotted during datapath id conversion + // Adding logs for a random issue spotted during datapath id + // conversion String dpIdStr = datapathId.getValue().replace(":", ""); - BigInteger dpnId = new BigInteger(dpIdStr, 16); - return dpnId; + return new BigInteger(dpIdStr, 16); } return null; } @@ -405,17 +413,10 @@ public class IfmUtil { return FlowBasedServicesUtils.getNodeConnectorIdFromInterface(interfaceName, dataBroker); } - public static String getPortName(DataBroker dataBroker, NodeConnectorId ncId){ - InstanceIdentifier ncIdentifier = - InstanceIdentifier.builder(Nodes.class) - .child(Node.class, new NodeKey(getNodeIdFromNodeConnectorId(ncId))) - .child(NodeConnector.class, new NodeConnectorKey(ncId)).build(); - return read(LogicalDatastoreType.OPERATIONAL, ncIdentifier, dataBroker).transform( - nc -> nc.getAugmentation(FlowCapableNodeConnector.class).getName()).orNull(); - } - - public static NodeConnectorId getNodeConnectorIdFromInterface(org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState){ - if(ifState != null) { + public static NodeConnectorId getNodeConnectorIdFromInterface( + org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang + .ietf.interfaces.rev140508.interfaces.state.Interface ifState) { + if (ifState != null) { List ofportIds = ifState.getLowerLayerIf(); return new NodeConnectorId(ofportIds.get(0)); } @@ -423,15 +424,18 @@ public class IfmUtil { } public static InterfaceInfo.InterfaceType getInterfaceType(Interface iface) { - InterfaceInfo.InterfaceType interfaceType = org.opendaylight.genius.interfacemanager.globals.InterfaceInfo.InterfaceType.UNKNOWN_INTERFACE; - Class ifType = iface + InterfaceInfo.InterfaceType interfaceType = org.opendaylight + .genius.interfacemanager.globals.InterfaceInfo.InterfaceType.UNKNOWN_INTERFACE; + Class ifType = iface .getType(); if (ifType.isAssignableFrom(L2vlan.class)) { interfaceType = VLAN_INTERFACE; } else if (ifType.isAssignableFrom(Tunnel.class)) { IfTunnel ifTunnel = iface.getAugmentation(IfTunnel.class); - Class tunnelType = ifTunnel + Class tunnelType = ifTunnel .getTunnelInterfaceType(); interfaceType = TUNNEL_TYPE_MAP.get(tunnelType); } @@ -439,14 +443,13 @@ public class IfmUtil { } public static VlanInterfaceInfo getVlanInterfaceInfo(String interfaceName, Interface iface, BigInteger dpId) { - short vlanId = 0; String portName = null; IfL2vlan vlanIface = iface.getAugmentation(IfL2vlan.class); ParentRefs parentRefs = iface.getAugmentation(ParentRefs.class); if (parentRefs != null && parentRefs.getParentInterface() != null) { portName = parentRefs.getParentInterface(); - }else { + } else { LOG.warn("Portname set to null since parentRef is Null"); } VlanInterfaceInfo vlanInterfaceInfo = new VlanInterfaceInfo(dpId, portName, vlanId); @@ -475,42 +478,59 @@ public class IfmUtil { return new BigInteger("FFFF", 16).and(BigInteger.valueOf(portNumber)); } - public static String generateMacAddress(long portNo){ + public static String generateMacAddress(long portNo) { String unformattedMAC = getDeadBeefBytesForMac().or(fillPortNumberToMac(portNo)).toString(16); - return unformattedMAC.replaceAll("(.{2})", "$1"+IfmConstants.MAC_SEPARATOR). - substring(0, IfmConstants.MAC_STRING_LENGTH); + return unformattedMAC.replaceAll("(.{2})", "$1" + IfmConstants.MAC_SEPARATOR).substring(0, + IfmConstants.MAC_STRING_LENGTH); } - public static PhysAddress getPhyAddress(long portNo, FlowCapableNodeConnector flowCapableNodeConnector){ + public static PhysAddress getPhyAddress(long portNo, FlowCapableNodeConnector flowCapableNodeConnector) { String southboundMacAddress = flowCapableNodeConnector.getHardwareAddress().getValue(); - if(IfmConstants.INVALID_MAC.equals(southboundMacAddress)){ - LOG.debug("Invalid MAC Address received for {}, generating MAC Address", flowCapableNodeConnector.getName()); + if (IfmConstants.INVALID_MAC.equals(southboundMacAddress)) { + LOG.debug("Invalid MAC Address received for {}, generating MAC Address", + flowCapableNodeConnector.getName()); southboundMacAddress = generateMacAddress(portNo); } return new PhysAddress(southboundMacAddress); } - public static void bindService(WriteTransaction t, String interfaceName, BoundServices serviceInfo, - Class serviceMode){ - LOG.info("Binding Service {} for : {}", serviceInfo.getServiceName(), interfaceName); - InstanceIdentifier boundServicesInstanceIdentifier = InstanceIdentifier.builder(ServiceBindings.class) + public static void updateInterfaceParentRef(WriteTransaction writeTransaction, String interfaceName, + String parentInterface) { + InstanceIdentifier parentRefIdentifier = InstanceIdentifier.builder(Interfaces.class) + .child(Interface.class, new InterfaceKey(interfaceName)).augmentation(ParentRefs.class).build(); + ParentRefs parentRefs = new ParentRefsBuilder().setParentInterface(parentInterface).build(); + writeTransaction.merge(LogicalDatastoreType.CONFIGURATION, parentRefIdentifier, parentRefs); + LOG.debug( + "Updating parentRefInterface for interfaceName {}. " + + "interfaceKey {}, with parentRef augmentation pointing to {}", + interfaceName, new InterfaceKey(interfaceName), parentInterface); + } + + public static InstanceIdentifier buildBoundServicesIId(short servicePriority, String interfaceName, + Class serviceMode) { + return InstanceIdentifier.builder(ServiceBindings.class) .child(ServicesInfo.class, new ServicesInfoKey(interfaceName, serviceMode)) - .child(BoundServices.class, new BoundServicesKey(serviceInfo.getServicePriority())).build(); - t.put(LogicalDatastoreType.CONFIGURATION, boundServicesInstanceIdentifier, serviceInfo, true); + .child(BoundServices.class, new BoundServicesKey(servicePriority)).build(); } - public static void unbindService(DataBroker dataBroker, String interfaceName, InstanceIdentifier - boundServicesInstanceIdentifier){ + public static void bindService(WriteTransaction writeTransaction, String interfaceName, BoundServices serviceInfo, + Class serviceMode) { + LOG.info("Binding Service {} for : {}", serviceInfo.getServiceName(), interfaceName); + InstanceIdentifier boundServicesInstanceIdentifier = buildBoundServicesIId( + serviceInfo.getServicePriority(), interfaceName, serviceMode); + writeTransaction.put(LogicalDatastoreType.CONFIGURATION, boundServicesInstanceIdentifier, serviceInfo, true); + } + + public static void unbindService(DataBroker dataBroker, String interfaceName, + InstanceIdentifier boundServicesInstanceIdentifier) { LOG.info("Unbinding Service from : {}", interfaceName); DataStoreJobCoordinator dataStoreJobCoordinator = DataStoreJobCoordinator.getInstance(); - dataStoreJobCoordinator.enqueueJob(interfaceName, - () -> { - WriteTransaction t = dataBroker.newWriteOnlyTransaction(); - t.delete(LogicalDatastoreType.CONFIGURATION, boundServicesInstanceIdentifier); - List> futures = new ArrayList<>(); - futures.add(t.submit()); - return futures; - } - ); + dataStoreJobCoordinator.enqueueJob(interfaceName, () -> { + WriteTransaction writeTransaction = dataBroker.newWriteOnlyTransaction(); + writeTransaction.delete(LogicalDatastoreType.CONFIGURATION, boundServicesInstanceIdentifier); + List> futures = new ArrayList<>(); + futures.add(writeTransaction.submit()); + return futures; + }); } }