* 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.natservice.internal;
+import java.math.BigInteger;
+import javax.inject.Inject;
+import javax.inject.Singleton;
+import org.opendaylight.controller.md.sal.binding.api.DataBroker;
+import org.opendaylight.genius.mdsalutil.FlowEntity;
import org.opendaylight.genius.mdsalutil.MetaDataUtil;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowListener;
+import org.opendaylight.genius.mdsalutil.NwConstants;
+import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowAdded;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowRemoved;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowUpdated;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeErrorNotification;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.NodeExperimenterErrorNotification;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SalFlowListener;
import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.SwitchFlowRemoved;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.RemovedReasonFlags;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.rev131026.RemovedFlowReason;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.TcpMatchFields;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.UdpMatchFields;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer3Match;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.Layer4Match;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._3.match.Ipv4Match;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Prefix;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.TcpMatch;
import org.opendaylight.yang.gen.v1.urn.opendaylight.model.match.types.rev131026.match.layer._4.match.UdpMatch;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
import org.opendaylight.yang.gen.v1.urn.opendaylight.netvirt.natservice.rev160111.intext.ip.port.map.ip.port.mapping.intext.ip.protocol.type.ip.port.map.IpPortExternal;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.opendaylight.genius.mdsalutil.FlowEntity;
-import org.opendaylight.genius.mdsalutil.interfaces.IMdsalApiManager;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
-import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import java.math.BigInteger;
-public class NaptFlowRemovedEventHandler implements SalFlowListener{
- private DataBroker dataBroker;
- private final EventDispatcher naptEventdispatcher;
+@Singleton
+public class NaptFlowRemovedEventHandler implements SalFlowListener {
private static final Logger LOG = LoggerFactory.getLogger(NaptFlowRemovedEventHandler.class);
+ private final DataBroker dataBroker;
+ private final IMdsalApiManager mdsalManager;
+ private final EventDispatcher naptEventdispatcher;
private final NaptPacketInHandler naptPacketInHandler;
- private IMdsalApiManager mdsalManager;
- private NaptManager naptManager;
-
- public NaptFlowRemovedEventHandler(EventDispatcher eventDispatcher, DataBroker dataBroker, NaptPacketInHandler handler,
- IMdsalApiManager mdsalManager, NaptManager naptManager) {
- this.naptEventdispatcher = eventDispatcher;
+ private final NaptManager naptManager;
+
+ @Inject
+ public NaptFlowRemovedEventHandler(final DataBroker dataBroker,
+ final IMdsalApiManager mdsalManager,
+ final EventDispatcher eventDispatcher,
+ final NaptPacketInHandler handler,
+ final NaptManager naptManager) {
this.dataBroker = dataBroker;
- this.naptPacketInHandler = handler;
this.mdsalManager = mdsalManager;
+ this.naptEventdispatcher = eventDispatcher;
+ this.naptPacketInHandler = handler;
this.naptManager = naptManager;
}
@Override
- public void onSwitchFlowRemoved(SwitchFlowRemoved switchFlowRemoved) {
+ public void onSwitchFlowRemoved(SwitchFlowRemoved flowRemoved) {
-/*
+ }
+
+ private BigInteger getDpnId(String node) {
+ //openflow:1]
+ String[] temp = node.split(":");
+ return new BigInteger(temp[1]);
+
+ }
+
+ @Override
+ public void onFlowAdded(FlowAdded arg0) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public void onFlowRemoved(FlowRemoved flowRemoved) {
+ /*
If the removed flow is from the OUTBOUND NAPT table :
1) Get the ActionInfo of the flow.
2) From the ActionInfo of the flow get the internal IP address, port and the protocol.
7) Place the NaptEntry event to the queue.
*/
- short tableId = switchFlowRemoved.getTableId();
- RemovedReasonFlags removedReasonFlag = switchFlowRemoved.getRemovedReason();
-
- if (tableId == NatConstants.OUTBOUND_NAPT_TABLE && removedReasonFlag.isIDLETIMEOUT()) {
- LOG.info("NaptFlowRemovedEventHandler : onSwitchFlowRemoved() entry");
+ short tableId = flowRemoved.getTableId();
+ RemovedFlowReason removedReasonFlag = flowRemoved.getReason();
+ if (tableId == NwConstants.OUTBOUND_NAPT_TABLE
+ && RemovedFlowReason.OFPRRIDLETIMEOUT.equals(removedReasonFlag)) {
+ LOG.info("onFlowRemoved : triggered for table-{} entry", tableId);
//Get the internal internal IP address and the port number from the IPv4 match.
Ipv4Prefix internalIpv4Address = null;
- Layer3Match layer3Match = switchFlowRemoved.getMatch().getLayer3Match();
+ Layer3Match layer3Match = flowRemoved.getMatch().getLayer3Match();
if (layer3Match instanceof Ipv4Match) {
Ipv4Match internalIpv4Match = (Ipv4Match) layer3Match;
internalIpv4Address = internalIpv4Match.getIpv4Source();
}
- if(internalIpv4Address == null){
- LOG.error("NaptFlowRemovedEventHandler : Matching internal IP is null while retrieving the value from the Outbound NAPT flow");
+ if (internalIpv4Address == null) {
+ LOG.error("onFlowRemoved : Matching internal IP is null while retrieving the "
+ + "value from the Outbound NAPT flow");
return;
}
//Get the internal IP as a string
String internalIpv4AddressAsString = internalIpv4Address.getValue();
String[] internalIpv4AddressParts = internalIpv4AddressAsString.split("/");
String internalIpv4HostAddress = null;
- if(internalIpv4AddressParts.length >= 1){
+ if (internalIpv4AddressParts.length >= 1) {
internalIpv4HostAddress = internalIpv4AddressParts[0];
}
//Get the protocol from the layer4 match
NAPTEntryEvent.Protocol protocol = null;
Integer internalPortNumber = null;
- Layer4Match layer4Match = switchFlowRemoved.getMatch().getLayer4Match();
+ Layer4Match layer4Match = flowRemoved.getMatch().getLayer4Match();
if (layer4Match instanceof TcpMatch) {
- TcpMatchFields tcpMatchFields = (TcpMatchFields)layer4Match;
+ TcpMatchFields tcpMatchFields = (TcpMatchFields) layer4Match;
internalPortNumber = tcpMatchFields.getTcpSourcePort().getValue();
protocol = NAPTEntryEvent.Protocol.TCP;
- }else if (layer4Match instanceof UdpMatch){
- UdpMatchFields udpMatchFields = (UdpMatchFields)layer4Match;
+ } else if (layer4Match instanceof UdpMatch) {
+ UdpMatchFields udpMatchFields = (UdpMatchFields) layer4Match;
internalPortNumber = udpMatchFields.getUdpSourcePort().getValue();
protocol = NAPTEntryEvent.Protocol.UDP;
}
- if(protocol == null){
- LOG.error("NaptFlowRemovedEventHandler : Matching protocol is null while retrieving the value from the Outbound NAPT flow");
+ if (protocol == null) {
+ LOG.error("onFlowRemoved : Matching protocol is null while retrieving the value "
+ + "from the Outbound NAPT flow");
return;
}
//Get the router ID from the metadata.
Long routerId;
- BigInteger metadata = switchFlowRemoved.getMatch().getMetadata().getMetadata();
+ BigInteger metadata = flowRemoved.getMatch().getMetadata().getMetadata();
if (MetaDataUtil.getNatRouterIdFromMetadata(metadata) != 0) {
routerId = MetaDataUtil.getNatRouterIdFromMetadata(metadata);
} else {
- LOG.error("NaptFlowRemovedEventHandler : Null exception while retrieving routerId");
+ LOG.error("onFlowRemoved : Null exception while retrieving routerId");
return;
}
-
+ final String internalIpPortKey = routerId + NatConstants.COLON_SEPARATOR
+ + internalIpv4HostAddress + NatConstants.COLON_SEPARATOR + internalPortNumber;
//Get the external IP address and the port from the model
- IpPortExternal ipPortExternal = NatUtil.getExternalIpPortMap(dataBroker, routerId, internalIpv4HostAddress, internalPortNumber.toString(), protocol);
+ IpPortExternal ipPortExternal = NatUtil.getExternalIpPortMap(dataBroker, routerId,
+ internalIpv4HostAddress, internalPortNumber.toString(), protocol);
if (ipPortExternal == null) {
- LOG.debug("NaptFlowRemovedEventHandler : IpPortExternal not found, BGP vpn might be associated with router");
+ LOG.error("onFlowRemoved : IpPortExternal not found, BGP vpn might be "
+ + "associated with router");
//router must be associated with BGP vpn ID
long bgpVpnId = routerId;
- LOG.debug("NaptFlowRemovedEventHandler : BGP VPN ID {}", bgpVpnId);
+ LOG.debug("onFlowRemoved : BGP VPN ID {}", bgpVpnId);
String vpnName = NatUtil.getRouterName(dataBroker, bgpVpnId);
- String routerName = NatUtil.getRouterIdfromVpnId(dataBroker, vpnName);
+ String routerName = NatUtil.getRouterIdfromVpnInstance(dataBroker, vpnName);
+ if (routerName == null) {
+ LOG.error("onFlowRemoved : Unable to find router for VpnName {}", vpnName);
+ return;
+ }
routerId = NatUtil.getVpnId(dataBroker, routerName);
- LOG.debug("NaptFlowRemovedEventHandler : Router ID {}", routerId);
- ipPortExternal = NatUtil.getExternalIpPortMap(dataBroker, routerId, internalIpv4HostAddress, internalPortNumber.toString(), protocol);
- if(ipPortExternal == null) {
- LOG.error("NaptFlowRemovedEventHandler : IpPortExternal is null while queried from the model for routerId {}",routerId);
+ LOG.debug("onFlowRemoved : Router ID {}", routerId);
+ ipPortExternal = NatUtil.getExternalIpPortMap(dataBroker, routerId,
+ internalIpv4HostAddress, internalPortNumber.toString(), protocol);
+ if (ipPortExternal == null) {
+ LOG.error("onFlowRemoved : IpPortExternal is null while queried from the "
+ + "model for routerId {}", routerId);
return;
}
}
int externalPortNumber = ipPortExternal.getPortNum();
//Create an NAPT event and place it in the queue.
- NAPTEntryEvent naptEntryEvent = new NAPTEntryEvent(externalIpAddress, externalPortNumber, routerId, NAPTEntryEvent.Operation.DELETE, protocol, null, false);
- naptEventdispatcher.addNaptEvent(naptEntryEvent);
+ NAPTEntryEvent naptEntryEvent = new NAPTEntryEvent(externalIpAddress, externalPortNumber,
+ routerId, NAPTEntryEvent.Operation.DELETE, protocol, null, false);
+ naptEventdispatcher.addFlowRemovedNaptEvent(naptEntryEvent);
//Get the DPN ID from the Node
- InstanceIdentifier<Node> nodeRef = switchFlowRemoved.getNode().getValue().firstIdentifierOf(Node.class);
+ InstanceIdentifier<Node> nodeRef = flowRemoved.getNode().getValue().firstIdentifierOf(Node.class);
String dpn = nodeRef.firstKeyOf(Node.class).getId().getValue();
BigInteger dpnId = getDpnId(dpn);
- String switchFlowRef = NatUtil.getNaptFlowRef(dpnId, tableId, String.valueOf(routerId), internalIpv4HostAddress, internalPortNumber);
+ String switchFlowRef = NatUtil.getNaptFlowRef(dpnId, tableId, String.valueOf(routerId),
+ internalIpv4HostAddress, internalPortNumber);
//Inform the MDSAL manager to inform about the flow removal.
- LOG.debug("NaptFlowRemovedEventHandler : DPN ID {}, Metadata {}, SwitchFlowRef {}, internalIpv4HostAddress{}", dpnId, routerId, switchFlowRef, internalIpv4AddressAsString);
+ LOG.debug("onFlowRemoved : DPN ID {}, Metadata {}, SwitchFlowRef {}, "
+ + "internalIpv4HostAddress{}", dpnId, routerId, switchFlowRef, internalIpv4AddressAsString);
FlowEntity snatFlowEntity = NatUtil.buildFlowEntity(dpnId, tableId, switchFlowRef);
+ long startTime = System.currentTimeMillis();
mdsalManager.removeFlow(snatFlowEntity);
-
- LOG.debug("Received flow removed notification due to idleTimeout of flow from switch for flowref {}",switchFlowRef);
+ LOG.debug("onFlowRemoved : Elapsed time fo deleting table-{} flow for snat ({}) session:{}ms",
+ tableId, internalIpPortKey, (System.currentTimeMillis() - startTime));
//Remove the SourceIP:Port key from the Napt packet handler map.
- String internalIpPortKey = internalIpv4HostAddress + ":" + internalPortNumber;
naptPacketInHandler.removeIncomingPacketMap(internalIpPortKey);
//Remove the mapping of internal fixed ip/port to external ip/port from the datastore.
SessionAddress internalSessionAddress = new SessionAddress(internalIpv4HostAddress, internalPortNumber);
naptManager.releaseIpExtPortMapping(routerId, internalSessionAddress, protocol);
- LOG.info("NaptFlowRemovedEventHandler : onSwitchFlowRemoved() exit");
- }else {
- LOG.debug("Received flow removed notification due to flowdelete from switch for flowref");
+ LOG.info("onFlowRemoved : exit");
+ } else {
+ LOG.debug("onFlowRemoved : Received flow removed notification due to flowdelete from switch for flowref");
}
}
- private BigInteger getDpnId(String node) {
- //openflow:1]
- String temp[] = node.split(":");
- BigInteger dpnId = new BigInteger(temp[1]);
- return dpnId;
-
- }
-
- @Override
- public void onFlowAdded(FlowAdded arg0) {
- // TODO Auto-generated method stub
-
- }
-
- @Override
- public void onFlowRemoved(FlowRemoved arg0) {
- // TODO Auto-generated method stub
-
- }
-
@Override
public void onFlowUpdated(FlowUpdated arg0) {
// TODO Auto-generated method stub
Code Review / netvirt.git / blobdiff