1 package org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow;
3 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.addNxNsiMatch;
4 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.addNxNspMatch;
5 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.addNxRegMatch;
6 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.addNxTunIdMatch;
7 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.addNxTunIpv4DstMatch;
8 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.applyActionIns;
9 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.gotoTableIns;
10 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.instructions;
11 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxLoadNshc1RegAction;
12 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxLoadNshc2RegAction;
13 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxLoadRegAction;
14 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxLoadTunIPv4Action;
15 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxLoadTunIdAction;
16 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.nxOutputRegAction;
17 import static org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.outputAction;
19 import java.math.BigInteger;
21 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.OfContext;
22 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.OfWriter;
23 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.FlowUtils.RegMatch;
24 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.OrdinalFactory.EndpointFwdCtxOrdinals;
25 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.flow.PolicyEnforcer.NetworkElements;
26 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.sf.ChainAction;
27 import org.opendaylight.groupbasedpolicy.renderer.ofoverlay.sfcutils.SfcNshHeader;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.Match;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.flow.MatchBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.ofoverlay.rev140528.OfOverlayContext;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg0;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg1;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg4;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg5;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg6;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowjava.nx.match.rev140421.NxmNxReg7;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.overlay.rev150105.TunnelTypeVxlanGpe;
43 import org.slf4j.Logger;
44 import org.slf4j.LoggerFactory;
46 public class ChainActionFlows {
48 private static final Logger LOG = LoggerFactory.getLogger(ChainAction.class);
50 public ChainActionFlows() {
54 public static void createChainTunnelFlows(SfcNshHeader sfcNshHeader, NetworkElements netElements, OfWriter ofWriter,
57 NodeId localNodeId = netElements.getLocalNodeId();
58 NodeId destNodeId = netElements.getDstEp().getAugmentation(OfOverlayContext.class).getNodeId();
59 EndpointFwdCtxOrdinals epOrds = netElements.getSrcEpOrds();
61 NodeConnectorId localNodeTunPort = ctx.getSwitchManager().getTunnelPort(localNodeId, TunnelTypeVxlanGpe.class);
62 NodeConnectorId destNodeTunPort = ctx.getSwitchManager().getTunnelPort(destNodeId, TunnelTypeVxlanGpe.class);
63 if (localNodeTunPort == null || destNodeTunPort == null) {
64 LOG.error("createChainTunnelFlows: No valid VXLAN GPE tunnel for Node {} or Node {}", localNodeId,
68 ofWriter.writeFlow(localNodeId, ctx.getPolicyManager().getTABLEID_PORTSECURITY(),
69 allowFromChainPort(localNodeTunPort, ctx.getPolicyManager().getTABLEID_PORTSECURITY(), ctx));
71 ofWriter.writeFlow(localNodeId, ctx.getPolicyManager().getTABLEID_POLICY_ENFORCER(),
72 allowFromChainTunnel(localNodeTunPort, ctx.getPolicyManager().getTABLEID_POLICY_ENFORCER()));
76 ctx.getPolicyManager().getTABLEID_EXTERNAL_MAPPER(),
77 createExternalFlow(sfcNshHeader, localNodeTunPort, netElements, ctx.getPolicyManager()
78 .getTABLEID_EXTERNAL_MAPPER(), ctx));
82 ctx.getPolicyManager().getTABLEID_SOURCE_MAPPER(),
83 createChainTunnelFlow(sfcNshHeader, destNodeTunPort, epOrds, ctx.getPolicyManager()
84 .getTABLEID_SOURCE_MAPPER(), ctx));
88 ctx.getPolicyManager().getTABLEID_SOURCE_MAPPER(),
89 createChainBroadcastFlow(sfcNshHeader, destNodeTunPort, epOrds, ctx.getPolicyManager()
90 .getTABLEID_SOURCE_MAPPER(), ctx));
93 private static Flow createChainBroadcastFlow(SfcNshHeader sfcNshHeader, NodeConnectorId tunPort,
94 EndpointFwdCtxOrdinals epFwdCtxOrds, short tableId, OfContext ctx) {
96 int fdId = epFwdCtxOrds.getFdId();
98 MatchBuilder mb = new MatchBuilder().setInPort(tunPort);
100 addNxNsiMatch(mb, sfcNshHeader.getNshNsiFromChain());
101 addNxNspMatch(mb, sfcNshHeader.getNshNspFromChain());
102 addNxTunIdMatch(mb, fdId);
104 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action fdReg = nxLoadRegAction(
105 NxmNxReg5.class, BigInteger.valueOf(fdId));
107 Match match = mb.build();
108 FlowId flowId = FlowIdUtils.newFlowId(tableId, "chainbroadcast", match);
110 FlowBuilder flowb = base(tableId).setId(flowId)
111 .setPriority(Integer.valueOf(150))
114 instructions(applyActionIns(fdReg), gotoTableIns(ctx.getPolicyManager()
115 .getTABLEID_DESTINATION_MAPPER())));
116 return flowb.build();
119 private static Flow createExternalFlow(SfcNshHeader sfcNshHeader, NodeConnectorId tunPort,
120 NetworkElements netElements, short tableId, OfContext ctx) {
122 Integer priority = 1000;
123 int matchTunnelId=sfcNshHeader.getNshMetaC2().intValue();
124 Long l3c=Long.valueOf(netElements.getSrcEpOrds().getL3Id());
126 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action loadC1 = nxLoadNshc1RegAction(sfcNshHeader.getNshMetaC1());
127 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action loadC2 = nxLoadNshc2RegAction(sfcNshHeader.getNshMetaC2());
128 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action loadChainTunVnid = nxLoadTunIdAction(
129 BigInteger.valueOf(sfcNshHeader.getNshMetaC2()), false);
130 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action loadChainTunDest = nxLoadTunIPv4Action(
131 sfcNshHeader.getNshTunIpDst().getValue(), false);
133 MatchBuilder mb = new MatchBuilder();
134 addNxRegMatch(mb, RegMatch.of(NxmNxReg6.class, l3c));
135 addNxTunIdMatch(mb, matchTunnelId);
136 addNxNspMatch(mb, sfcNshHeader.getNshNspToChain());
137 addNxNsiMatch(mb, sfcNshHeader.getNshNsiToChain());
138 if (!netElements.getDstNodeId().equals(netElements.getSrcNodeId())) {
139 addNxTunIpv4DstMatch(mb, ctx.getSwitchManager()
140 .getTunnelIP(netElements.getDstNodeId(), TunnelTypeVxlanGpe.class)
145 Match match = mb.build();
146 FlowId flowId = FlowIdUtils.newFlowId(tableId, "chainexternal", match);
147 FlowBuilder flowb = base(tableId).setId(flowId)
148 .setPriority(Integer.valueOf(priority))
151 instructions(applyActionIns(loadC1, loadC2, loadChainTunDest, loadChainTunVnid,
152 outputAction(tunPort))));
153 return flowb.build();
156 private static Flow createChainTunnelFlow(SfcNshHeader sfcNshHeader, NodeConnectorId tunPort,
157 EndpointFwdCtxOrdinals epFwdCtxOrds, short tableId, OfContext ctx) {
159 int egId = epFwdCtxOrds.getEpgId();
160 int bdId = epFwdCtxOrds.getBdId();
161 int fdId = epFwdCtxOrds.getFdId();
162 int l3Id = epFwdCtxOrds.getL3Id();
163 int tunnelId = epFwdCtxOrds.getTunnelId();
165 MatchBuilder mb = new MatchBuilder().setInPort(tunPort);
166 addNxTunIdMatch(mb, tunnelId);
167 addNxNspMatch(mb, sfcNshHeader.getNshNspFromChain());
168 addNxNsiMatch(mb, sfcNshHeader.getNshNsiFromChain());
170 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action segReg = nxLoadRegAction(
171 NxmNxReg0.class, BigInteger.valueOf(egId));
172 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action scgReg = nxLoadRegAction(
173 NxmNxReg1.class, BigInteger.valueOf(0xffffff));
174 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action bdReg = nxLoadRegAction(
175 NxmNxReg4.class, BigInteger.valueOf(bdId));
176 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action fdReg = nxLoadRegAction(
177 NxmNxReg5.class, BigInteger.valueOf(fdId));
178 org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.Action vrfReg = nxLoadRegAction(
179 NxmNxReg6.class, BigInteger.valueOf(l3Id));
181 Match match = mb.build();
182 FlowId flowId = FlowIdUtils.newFlowId(tableId, "chaintunnel", match);
183 FlowBuilder flowb = base(tableId).setId(flowId)
184 .setPriority(Integer.valueOf(150))
187 instructions(applyActionIns(segReg, scgReg, bdReg, fdReg, vrfReg),
188 gotoTableIns(ctx.getPolicyManager().getTABLEID_DESTINATION_MAPPER())));
189 return flowb.build();
192 private static Flow allowFromChainPort(NodeConnectorId port, short tableId, OfContext ctx) {
194 Match match = new MatchBuilder().setInPort(port).build();
195 FlowId flowId = FlowIdUtils.newFlowId(tableId, "chainport", match);
196 FlowBuilder flowb = base(tableId).setId(flowId)
197 .setPriority(Integer.valueOf(200))
199 .setInstructions(FlowUtils.gotoTableInstructions(ctx.getPolicyManager().getTABLEID_SOURCE_MAPPER()));
200 return flowb.build();
203 private static Flow allowFromChainTunnel(NodeConnectorId tunPort, short tableId) {
205 MatchBuilder mb = new MatchBuilder().setInPort(tunPort);
206 addNxRegMatch(mb, RegMatch.of(NxmNxReg1.class, Long.valueOf(0xffffff)));
207 Match match = mb.build();
208 FlowId flowId = FlowIdUtils.newFlowId(tableId, "chainport", match);
210 FlowBuilder flow = base(tableId).setId(flowId)
213 .setInstructions(instructions(applyActionIns(nxOutputRegAction(NxmNxReg7.class))));
219 * Get a base flow builder with some common features already set
221 private static FlowBuilder base(short tableId) {
222 return new FlowBuilder().setTableId(tableId).setBarrier(false).setHardTimeout(0).setIdleTimeout(0);