X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=interfacemgr%2Finterfacemgr-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Finterfacemgr%2Frpcservice%2FInterfaceManagerRpcService.java;h=53523c7b8f4af3fcb6e30ea01f97d3b98c268020;hb=9c0e16907ffb4d6c79ea397885f9dfed738dc848;hp=ef70eb84f414701a31ea4f4296e56dd5cbcb32c3;hpb=9f4df02dabc7024ddf94562f7f3e997717fd80b4;p=vpnservice.git diff --git a/interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/rpcservice/InterfaceManagerRpcService.java b/interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/rpcservice/InterfaceManagerRpcService.java index ef70eb84..53523c7b 100644 --- a/interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/rpcservice/InterfaceManagerRpcService.java +++ b/interfacemgr/interfacemgr-impl/src/main/java/org/opendaylight/vpnservice/interfacemgr/rpcservice/InterfaceManagerRpcService.java @@ -1,5 +1,5 @@ /* - * Copyright (c) 2015 Ericsson India Global Services Pvt Ltd. and others. All rights reserved. + * Copyright (c) 2015 - 2016 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, @@ -9,9 +9,14 @@ package org.opendaylight.vpnservice.interfacemgr.rpcservice; import com.google.common.base.Optional; +import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; +import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.SettableFuture; import org.opendaylight.controller.md.sal.binding.api.DataBroker; +import org.opendaylight.controller.md.sal.binding.api.WriteTransaction; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; +import org.opendaylight.vpnservice.interfacemgr.IfmConstants; import org.opendaylight.vpnservice.interfacemgr.IfmUtil; import org.opendaylight.vpnservice.interfacemgr.commons.InterfaceManagerCommonUtils; import org.opendaylight.vpnservice.interfacemgr.commons.InterfaceMetaUtils; @@ -19,35 +24,34 @@ import org.opendaylight.vpnservice.mdsalutil.ActionInfo; import org.opendaylight.vpnservice.mdsalutil.ActionType; import org.opendaylight.vpnservice.mdsalutil.InstructionInfo; import org.opendaylight.vpnservice.mdsalutil.InstructionType; +import org.opendaylight.vpnservice.mdsalutil.MDSALUtil; +import org.opendaylight.vpnservice.mdsalutil.MatchFieldType; +import org.opendaylight.vpnservice.mdsalutil.MatchInfo; +import org.opendaylight.vpnservice.mdsalutil.NwConstants; +import org.opendaylight.vpnservice.mdsalutil.interfaces.IMdsalApiManager; 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.interfaces.rev140508.InterfaceType; +import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.IfL2vlan; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface; import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action; +import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction; 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.nodes.Node; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.IfIndexesInterfaceMap; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.InterfaceChildInfo; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._if.indexes._interface.map.IfIndexInterface; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._if.indexes._interface.map.IfIndexInterfaceKey; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._interface.child.info.InterfaceParentEntry; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._interface.child.info.InterfaceParentEntryKey; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._interface.child.info._interface.parent.entry.InterfaceChildEntry; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007._interface.child.info._interface.parent.entry.InterfaceChildEntryKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.bridge._interface.info.BridgeEntry; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.bridge._interface.info.BridgeEntryKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.meta.rev151007.bridge._interface.info.bridge.entry.BridgeInterfaceEntry; -import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.IfL2vlan; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.IfTunnel; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.ParentRefs; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.TunnelTypeBase; +import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rev150331.TunnelTypeMplsOverGre; import org.opendaylight.yang.gen.v1.urn.opendaylight.vpnservice.interfacemgr.rpcs.rev151003.*; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yangtools.yang.common.RpcError; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import org.slf4j.Logger; @@ -62,8 +66,12 @@ import java.util.concurrent.Future; public class InterfaceManagerRpcService implements OdlInterfaceRpcService { private static final Logger LOG = LoggerFactory.getLogger(InterfaceManagerRpcService.class); DataBroker dataBroker; - public InterfaceManagerRpcService(DataBroker dataBroker) { + IMdsalApiManager mdsalMgr; + + + public InterfaceManagerRpcService(DataBroker dataBroker, IMdsalApiManager mdsalMgr) { this.dataBroker = dataBroker; + this.mdsalMgr = mdsalMgr; } @Override @@ -95,6 +103,87 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { return Futures.immediateFuture(rpcResultBuilder.build()); } + @Override + public Future> createTerminatingServiceActions(final CreateTerminatingServiceActionsInput input) { + final SettableFuture> result = SettableFuture.create(); + try{ + LOG.info("create terminatingServiceAction on DpnId = {} for tunnel-key {}", input.getDpid() , input.getTunnelKey()); + Interface interfaceInfo = InterfaceManagerCommonUtils.getInterfaceFromConfigDS(new InterfaceKey(input.getInterfaceName()),dataBroker); + IfTunnel tunnelInfo = interfaceInfo.getAugmentation(IfTunnel.class); + if(tunnelInfo != null) { + ListenableFuture installFlowResult = (tunnelInfo.getTunnelInterfaceType().isAssignableFrom(TunnelTypeMplsOverGre.class)) ? + makeLFIBFlow(input.getDpid(),input.getTunnelKey(), input.getInstruction(), NwConstants.ADD_FLOW) : + makeTerminatingServiceFlow(tunnelInfo, input.getDpid(), input.getTunnelKey(), input.getInstruction(), NwConstants.ADD_FLOW); + Futures.addCallback(installFlowResult, new FutureCallback(){ + + @Override + public void onSuccess(Void aVoid) { + result.set(RpcResultBuilder.success().build()); + } + + @Override + public void onFailure(Throwable error) { + String msg = String.format("Unable to install terminating service flow for %s", input.getInterfaceName()); + LOG.error("create terminating service actions failed. {}. {}", msg, error); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg, error).build()); + } + }); + result.set(RpcResultBuilder.success().build()); + } else { + String msg = String.format("Terminating Service Actions cannot be created for a non-tunnel interface %s",input.getInterfaceName()); + LOG.error(msg); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg).build()); + } + }catch(Exception e){ + String msg = String.format("create Terminating Service Actions for %s failed",input.getInterfaceName()); + LOG.error("create Terminating Service Actions for {} failed due to {}" ,input.getDpid(), e); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg, e.getMessage()).build()); + } + return result; + } + + @Override + public Future> removeTerminatingServiceActions(final RemoveTerminatingServiceActionsInput input) { + final SettableFuture> result = SettableFuture.create(); + try{ + WriteTransaction t = dataBroker.newWriteOnlyTransaction(); + LOG.info("remove terminatingServiceAction on DpnId = {} for tunnel-key {}", input.getDpid() , input.getTunnelKey()); + + Interface interfaceInfo = InterfaceManagerCommonUtils.getInterfaceFromConfigDS(new InterfaceKey(input.getInterfaceName()),dataBroker); + IfTunnel tunnelInfo = interfaceInfo.getAugmentation(IfTunnel.class); + if(tunnelInfo != null) { + ListenableFuture removeFlowResult = (tunnelInfo.getTunnelInterfaceType().isAssignableFrom(TunnelTypeMplsOverGre.class)) ? + makeLFIBFlow(input.getDpid(),input.getTunnelKey(), null, NwConstants.DEL_FLOW) : + makeTerminatingServiceFlow(tunnelInfo, input.getDpid(), input.getTunnelKey(), null, NwConstants.DEL_FLOW); + Futures.addCallback(removeFlowResult, new FutureCallback(){ + + @Override + public void onSuccess(Void aVoid) { + result.set(RpcResultBuilder.success().build()); + } + + @Override + public void onFailure(Throwable error) { + String msg = String.format("Unable to install terminating service flow %s", input.getInterfaceName()); + LOG.error("create terminating service actions failed. {}. {}", msg, error); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg, error).build()); + } + }); + result.set(RpcResultBuilder.success().build()); + } else { + String msg = String.format("Terminating Service Actions cannot be removed for a non-tunnel interface %s", + input.getInterfaceName()); + LOG.error(msg); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg).build()); + } + }catch(Exception e){ + LOG.error("Remove Terminating Service Actions for {} failed due to {}" ,input.getDpid(), e); + String msg = String.format("Remove Terminating Service Actions for %d failed.", input.getDpid()); + result.set(RpcResultBuilder.failed().withError(RpcError.ErrorType.APPLICATION, msg, e.getMessage()).build()); + } + return result; + } + @Override public Future> getEndpointIpForDpn(GetEndpointIpForDpnInput input) { RpcResultBuilder rpcResultBuilder; @@ -125,7 +214,10 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { RpcResultBuilder rpcResultBuilder; try { List instructionInfo = new ArrayList(); - List actionInfo = getEgressActionInfosForInterface(input.getIntfName()); + List actionInfo = IfmUtil.getEgressActionInfosForInterface(input.getIntfName(), + input.getTunnelKey(), + 0, /* ActionKey starting value */ + dataBroker); instructionInfo.add(new InstructionInfo(InstructionType.write_actions, actionInfo)); GetEgressInstructionsForInterfaceOutputBuilder output = new GetEgressInstructionsForInterfaceOutputBuilder(). setInstruction(buildInstructions(instructionInfo)); @@ -156,11 +248,39 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { return Futures.immediateFuture(rpcResultBuilder.build()); } + @Override + public Future> getTunnelType(GetTunnelTypeInput input) { + String interfaceName = input.getIntfName(); + RpcResultBuilder rpcResultBuilder; + try { + InterfaceKey interfaceKey = new InterfaceKey(interfaceName); + Interface interfaceInfo = InterfaceManagerCommonUtils.getInterfaceFromConfigDS(interfaceKey, dataBroker); + + if (Tunnel.class.equals(interfaceInfo.getType())) { + IfTunnel tnl = interfaceInfo.getAugmentation(IfTunnel.class); + Class tun_type = tnl.getTunnelInterfaceType(); + GetTunnelTypeOutputBuilder output = new GetTunnelTypeOutputBuilder().setTunnelType(tun_type); + rpcResultBuilder = RpcResultBuilder.success(); + rpcResultBuilder.withResult(output.build()); + } else { + LOG.error("Retrieval of interface type for the key {} failed", interfaceName); + rpcResultBuilder = RpcResultBuilder.failed(); + } + } catch (Exception e) { + LOG.error("Retrieval of interface type for the key {} failed due to {}", interfaceName, e); + rpcResultBuilder = RpcResultBuilder.failed(); + } + return Futures.immediateFuture(rpcResultBuilder.build()); + } + @Override public Future> getEgressActionsForInterface(GetEgressActionsForInterfaceInput input) { RpcResultBuilder rpcResultBuilder; try { - List actionsList = getEgressActionsForInterface(input.getIntfName()); + LOG.debug("Get Egress Action for interface {} with key {}", input.getIntfName(), input.getTunnelKey()); + List actionsList = IfmUtil.getEgressActionsForInterface(input.getIntfName(), + input.getTunnelKey(), + dataBroker); GetEgressActionsForInterfaceOutputBuilder output = new GetEgressActionsForInterfaceOutputBuilder(). setAction(actionsList); rpcResultBuilder = RpcResultBuilder.success(); @@ -172,6 +292,7 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { return Futures.immediateFuture(rpcResultBuilder.build()); } + @Override public Future> getPortFromInterface(GetPortFromInterfaceInput input) { RpcResultBuilder rpcResultBuilder; @@ -237,42 +358,6 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { return Futures.immediateFuture(rpcResultBuilder.build()); } - public List getEgressActionInfosForInterface(String interfaceName) { - Interface interfaceInfo = InterfaceManagerCommonUtils.getInterfaceFromConfigDS(new InterfaceKey(interfaceName), - dataBroker); - List listActionInfo = new ArrayList(); - org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface ifState = - InterfaceManagerCommonUtils.getInterfaceStateFromOperDS(interfaceName, dataBroker); - - String lowerLayerIf = ifState.getLowerLayerIf().get(0); - NodeConnectorId nodeConnectorId = new NodeConnectorId(lowerLayerIf); - String portNo = IfmUtil.getPortNoFromNodeConnectorId(nodeConnectorId); - Class ifType = interfaceInfo.getType(); - if(L2vlan.class.equals(ifType)){ - IfL2vlan vlanIface = interfaceInfo.getAugmentation(IfL2vlan.class); - LOG.trace("L2Vlan: {}",vlanIface); - long vlanVid = (vlanIface == null) ? 0 : vlanIface.getVlanId().getValue(); - if (vlanVid != 0) { - listActionInfo.add(new ActionInfo(ActionType.push_vlan, new String[] {})); - listActionInfo.add(new ActionInfo(ActionType.set_field_vlan_vid, - new String[] { Long.toString(vlanVid) })); - } - listActionInfo.add(new ActionInfo(ActionType.output, new String[] {portNo})); - }else if(Tunnel.class.equals(ifType)){ - listActionInfo.add(new ActionInfo(ActionType.output, new String[] { portNo})); - } - return listActionInfo; - } - - public List getEgressActionsForInterface(String interfaceName) { - List listActionInfo = getEgressActionInfosForInterface(interfaceName); - List actionsList = new ArrayList<>(); - for (ActionInfo actionInfo : listActionInfo) { - actionsList.add(actionInfo.buildAction()); - } - return actionsList; - } - protected static List buildInstructions(List listInstructionInfo) { if (listInstructionInfo != null) { List instructions = new ArrayList(); @@ -288,4 +373,41 @@ public class InterfaceManagerRpcService implements OdlInterfaceRpcService { return null; } + private ListenableFuture makeTerminatingServiceFlow(IfTunnel tunnelInfo, BigInteger dpnId, BigInteger tunnelKey, List instruction, int addOrRemove) { + List mkMatches = new ArrayList(); + mkMatches.add(new MatchInfo(MatchFieldType.tunnel_id, new BigInteger[] {tunnelKey})); + short tableId = tunnelInfo.isInternal() ? NwConstants.INTERNAL_TUNNEL_TABLE : + NwConstants.EXTERNAL_TUNNEL_TABLE; + final String flowRef = getFlowRef(dpnId,tableId, tunnelKey); + Flow terminatingSerFlow = MDSALUtil.buildFlowNew(tableId, flowRef, + 5, "TST Flow Entry", 0, 0, + IfmConstants.TUNNEL_TABLE_COOKIE.add(tunnelKey), mkMatches, instruction); + if (addOrRemove == NwConstants.ADD_FLOW) { + return mdsalMgr.installFlow(dpnId, terminatingSerFlow); + } + + return mdsalMgr.removeFlow(dpnId, terminatingSerFlow); + } + + private ListenableFuture makeLFIBFlow(BigInteger dpnId, BigInteger tunnelKey, List instruction, int addOrRemove) { + List mkMatches = new ArrayList(); + mkMatches.add(new MatchInfo(MatchFieldType.eth_type, + new long[]{0x8847L})); + mkMatches.add(new MatchInfo(MatchFieldType.mpls_label, new String[]{Long.toString(tunnelKey.longValue())})); + // Install the flow entry in L3_LFIB_TABLE + String flowRef = getFlowRef(dpnId, NwConstants.L3_LFIB_TABLE, tunnelKey); + + Flow lfibFlow = MDSALUtil.buildFlowNew(NwConstants.L3_LFIB_TABLE, flowRef, + IfmConstants.DEFAULT_FLOW_PRIORITY, "LFIB Entry", 0, 0, + IfmConstants.COOKIE_VM_LFIB_TABLE, mkMatches, instruction); + if (addOrRemove == NwConstants.ADD_FLOW) { + return mdsalMgr.installFlow(dpnId, lfibFlow); + } + return mdsalMgr.removeFlow(dpnId, lfibFlow); + } + + private String getFlowRef(BigInteger dpnId, short tableId, BigInteger tunnelKey) { + return new StringBuffer().append(IfmConstants.TUNNEL_TABLE_FLOWID_PREFIX).append(dpnId).append(NwConstants.FLOWID_SEPARATOR) + .append(tableId).append(NwConstants.FLOWID_SEPARATOR).append(tunnelKey).toString(); + } } \ No newline at end of file