2 * Copyright © 2017 Ericsson India Global Services Pvt Ltd. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
9 package org.opendaylight.netvirt.elan.evpn.utils;
11 import com.google.common.util.concurrent.ListenableFuture;
12 import java.math.BigInteger;
13 import java.util.ArrayList;
14 import java.util.Collections;
15 import java.util.List;
16 import javax.inject.Inject;
17 import javax.inject.Singleton;
18 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
19 import org.opendaylight.genius.infra.Datastore;
20 import org.opendaylight.genius.infra.ManagedNewTransactionRunner;
21 import org.opendaylight.genius.infra.ManagedNewTransactionRunnerImpl;
22 import org.opendaylight.genius.mdsalutil.MDSALUtil;
23 import org.opendaylight.genius.mdsalutil.MatchInfo;
24 import org.opendaylight.genius.mdsalutil.NwConstants;
25 import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
26 import org.opendaylight.netvirt.elan.utils.ElanConstants;
27 import org.opendaylight.netvirt.elan.utils.ElanEtreeUtils;
28 import org.opendaylight.netvirt.elan.utils.ElanItmUtils;
29 import org.opendaylight.netvirt.elan.utils.ElanUtils;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.action.types.rev131112.action.list.Action;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowId;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowBuilder;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.instruction.list.Instruction;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.elan.etree.rev160614.EtreeLeafTagName;
39 public class ElanEvpnFlowUtils {
40 private final IMdsalApiManager mdsalManager;
41 private final ElanItmUtils elanItmUtils;
42 private final ElanEtreeUtils elanEtreeUtils;
43 private final ManagedNewTransactionRunner txRunner;
46 public ElanEvpnFlowUtils(final IMdsalApiManager mdsalManager, final ElanItmUtils elanItmUtils,
47 final ElanEtreeUtils elanEtreeUtils, final DataBroker dataBroker) {
48 this.mdsalManager = mdsalManager;
49 this.elanItmUtils = elanItmUtils;
50 this.elanEtreeUtils = elanEtreeUtils;
51 this.txRunner = new ManagedNewTransactionRunnerImpl(dataBroker);
54 public Flow evpnBuildDmacFlowForExternalRemoteMac(EvpnDmacFlow evpnDmacFlow) {
55 List<MatchInfo> mkMatches = ElanUtils.buildMatchesForElanTagShFlagAndDstMac(evpnDmacFlow.getElanTag(), false,
56 evpnDmacFlow.getDstMacAddress());
57 List<Instruction> mkInstructions = new ArrayList<>();
58 List<Action> actions = elanItmUtils.getExternalTunnelItmEgressAction(evpnDmacFlow.getDpId(),
59 evpnDmacFlow.getNexthopIP(), evpnDmacFlow.getVni());
60 mkInstructions.add(MDSALUtil.buildApplyActionsInstruction(actions));
61 Flow flow = MDSALUtil.buildFlowNew(NwConstants.ELAN_DMAC_TABLE,
62 ElanUtils.getKnownDynamicmacFlowRef(NwConstants.ELAN_DMAC_TABLE, evpnDmacFlow.getDpId(),
63 evpnDmacFlow.getNexthopIP(), evpnDmacFlow.getDstMacAddress(), evpnDmacFlow.getElanTag(), false),
64 20, evpnDmacFlow.getElanName(), 0, 0,
65 ElanConstants.COOKIE_ELAN_KNOWN_DMAC.add(BigInteger.valueOf(evpnDmacFlow.getElanTag())), mkMatches,
71 public List<ListenableFuture<Void>> evpnDeleteDmacFlowsToExternalMac(EvpnDmacFlow evpnDmacFlow) {
72 List<ListenableFuture<Void>> futures = new ArrayList<>();
73 synchronized (ElanUtils.getElanMacDPNKey(evpnDmacFlow.getElanTag(), evpnDmacFlow.getDstMacAddress(),
74 evpnDmacFlow.getDpId())) {
76 evpnRemoveFlowThatSendsThePacketOnAnExternalTunnel(evpnDmacFlow.getElanTag(), evpnDmacFlow.dpId,
77 evpnDmacFlow.getNexthopIP(), evpnDmacFlow.getDstMacAddress()));
78 futures.addAll(evpnDeleteEtreeDmacFlowsToExternalMac(evpnDmacFlow.getElanTag(), evpnDmacFlow.getDpId(),
79 evpnDmacFlow.getNexthopIP(), evpnDmacFlow.getDstMacAddress()));
84 private List<ListenableFuture<Void>> evpnDeleteEtreeDmacFlowsToExternalMac(long elanTag, BigInteger dpId,
85 String nexthopIp, String macToRemove) {
86 List<ListenableFuture<Void>> futures = new ArrayList<>();
87 EtreeLeafTagName etreeLeafTag = elanEtreeUtils.getEtreeLeafTagByElanTag(elanTag);
88 if (etreeLeafTag != null) {
90 evpnRemoveFlowThatSendsThePacketOnAnExternalTunnel(etreeLeafTag.getEtreeLeafTag().getValue(), dpId,
91 nexthopIp, macToRemove));
93 evpnRemoveTheDropFlow(etreeLeafTag.getEtreeLeafTag().getValue(), dpId, nexthopIp, macToRemove));
98 static String evpnGetKnownDynamicmacFlowRef(short elanDmacTable, BigInteger dpId, String nexthopIp,
99 String dstMacAddress, long elanTag, boolean shFlag) {
100 return String.valueOf(elanDmacTable) + elanTag + dpId + nexthopIp + dstMacAddress + shFlag;
103 private List<ListenableFuture<Void>> evpnRemoveTheDropFlow(long elanTag, BigInteger dpId, String nexthopIp,
104 String macToRemove) {
105 String flowId = ElanEvpnFlowUtils.evpnGetKnownDynamicmacFlowRef(NwConstants.ELAN_DMAC_TABLE, dpId, nexthopIp,
106 macToRemove, elanTag, true);
107 Flow flowToRemove = new FlowBuilder().setId(new FlowId(flowId)).setTableId(NwConstants.ELAN_DMAC_TABLE).build();
108 return Collections.singletonList(txRunner.callWithNewReadWriteTransactionAndSubmit(Datastore.CONFIGURATION,
109 tx -> mdsalManager.removeFlow(tx, dpId, flowToRemove)));
112 private List<ListenableFuture<Void>> evpnRemoveFlowThatSendsThePacketOnAnExternalTunnel(long elanTag,
113 BigInteger dpId, String nexthopIp, String macToRemove) {
114 String flowId = ElanEvpnFlowUtils.evpnGetKnownDynamicmacFlowRef(NwConstants.ELAN_DMAC_TABLE, dpId, nexthopIp,
115 macToRemove, elanTag, false);
116 Flow flowToRemove = new FlowBuilder().setId(new FlowId(flowId)).setTableId(NwConstants.ELAN_DMAC_TABLE).build();
117 return Collections.singletonList(txRunner.callWithNewReadWriteTransactionAndSubmit(Datastore.CONFIGURATION,
118 tx -> mdsalManager.removeFlow(tx, dpId, flowToRemove)));
121 public static class EvpnDmacFlowBuilder {
122 private BigInteger dpId;
123 private String nexthopIP;
124 private long elanTag;
126 private String dstMacAddress;
127 private String elanName;
129 public EvpnDmacFlowBuilder() {
132 public EvpnDmacFlowBuilder setDpId(BigInteger dpId) {
137 public EvpnDmacFlowBuilder setNexthopIP(String nexthopIP) {
138 this.nexthopIP = nexthopIP;
142 public EvpnDmacFlowBuilder setElanTag(long elanTag) {
143 this.elanTag = elanTag;
147 public EvpnDmacFlowBuilder setVni(Long vni) {
152 public EvpnDmacFlowBuilder setDstMacAddress(String dstMacAddress) {
153 this.dstMacAddress = dstMacAddress;
157 public EvpnDmacFlowBuilder setElanName(String elanName) {
158 this.elanName = elanName;
162 public EvpnDmacFlow build() {
163 return new EvpnDmacFlow(dpId, nexthopIP, elanTag, vni, dstMacAddress, elanName);
167 static class EvpnDmacFlow {
168 private BigInteger dpId;
169 private String nexthopIP;
170 private long elanTag;
172 private String dstMacAddress;
173 private String elanName;
175 EvpnDmacFlow(BigInteger dpId, String nexthopIP, long elanTag, Long vni, String dstMacAddress,
178 this.nexthopIP = nexthopIP;
179 this.elanTag = elanTag;
181 this.dstMacAddress = dstMacAddress;
182 this.elanName = elanName;
185 public BigInteger getDpId() {
189 public String getNexthopIP() {
193 public long getElanTag() {
197 public Long getVni() {
201 public String getDstMacAddress() {
202 return dstMacAddress;
205 public String getElanName() {