X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=natservice%2Fnatservice-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fvpnservice%2Fnatservice%2Finternal%2FNaptPacketInHandler.java;h=34795b1fe2df69cd74911b60dde0083645e41bc1;hb=HEAD;hp=b663f50614a01d2c32b2bdcd0034fc5eb12e3786;hpb=ed6f61816781aac385f54d8fe019e65fe5a21d3e;p=vpnservice.git diff --git a/natservice/natservice-impl/src/main/java/org/opendaylight/vpnservice/natservice/internal/NaptPacketInHandler.java b/natservice/natservice-impl/src/main/java/org/opendaylight/vpnservice/natservice/internal/NaptPacketInHandler.java index b663f506..34795b1f 100644 --- a/natservice/natservice-impl/src/main/java/org/opendaylight/vpnservice/natservice/internal/NaptPacketInHandler.java +++ b/natservice/natservice-impl/src/main/java/org/opendaylight/vpnservice/natservice/internal/NaptPacketInHandler.java @@ -9,7 +9,6 @@ package org.opendaylight.vpnservice.natservice.internal; import org.opendaylight.controller.liblldp.NetUtils; import org.opendaylight.vpnservice.mdsalutil.MetaDataUtil; -import org.opendaylight.vpnservice.mdsalutil.NWUtil; import org.opendaylight.vpnservice.mdsalutil.packet.Ethernet; import org.opendaylight.vpnservice.mdsalutil.packet.IPv4; import org.opendaylight.vpnservice.mdsalutil.packet.TCP; @@ -67,11 +66,19 @@ public class NaptPacketInHandler implements PacketProcessingListener { if (ipPkt.getPayload() instanceof TCP) { TCP tcpPkt = (TCP) ipPkt.getPayload(); portNumber = tcpPkt.getSourcePort(); + if(portNumber < 0){ + portNumber = 32767 + portNumber + 32767 + 2; + LOG.trace("Retrieved and extracted TCP portNumber {}", portNumber); + } protocol = NAPTEntryEvent.Protocol.TCP; LOG.trace("Retrieved TCP portNumber {}", portNumber); } else if (ipPkt.getPayload() instanceof UDP) { UDP udpPkt = (UDP) ipPkt.getPayload(); portNumber = udpPkt.getSourcePort(); + if(portNumber < 0){ + portNumber = 32767 + portNumber + 32767 + 2; + LOG.trace("Retrieved and extracted UDP portNumber {}", portNumber); + } protocol = NAPTEntryEvent.Protocol.UDP; LOG.trace("Retrieved UDP portNumber {}", portNumber); } else {