Stale table=44 flows remains on VM deletion

[netvirt.git] / natservice / impl / src / main / java / org / opendaylight / netvirt / natservice / internal / NAPTEntryEvent.java

diff --git a/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NAPTEntryEvent.java b/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NAPTEntryEvent.java
index f7b6b16b93bbeafcd284a88f2ceb02ef88a4b67e..ea88ec000859f98d6784385c6ffe85dc24838ff8 100644 (file)
--- a/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NAPTEntryEvent.java
+++ b/natservice/impl/src/main/java/org/opendaylight/netvirt/natservice/internal/NAPTEntryEvent.java
@@ -16,6 +16,7 @@ public class NAPTEntryEvent {
     private final String ipAddress;
     private final int portNumber;
     private final Long routerId;
+    private String flowDpn;
     private final Operation op;
     private final Protocol protocol;
     private final PacketReceived packetReceived;
@@ -36,11 +37,12 @@ public class NAPTEntryEvent {
         this.objectCreationTime = System.currentTimeMillis();
     }
 
-    NAPTEntryEvent(String ipAddress, int portNumber, Long routerId, Operation op, Protocol protocol) {
+    NAPTEntryEvent(String ipAddress, int portNumber, String flowDpn, Long routerId, Operation op, Protocol protocol) {
         this.op = op;
         this.ipAddress = ipAddress;
         this.portNumber = portNumber;
         this.routerId = routerId;
+        this.flowDpn = flowDpn;
         this.protocol = protocol;
         this.packetReceived = null;
         this.pktProcessed = false;
@@ -68,6 +70,10 @@ public class NAPTEntryEvent {
         return routerId;
     }
 
+    public String getFlowDpn() {
+        return flowDpn;
+    }
+
     public Operation getOperation() {
         return op;
     }