X-Git-Url: https://gerrit.fd.io/r/gitweb?p=csit.git;a=blobdiff_plain;f=GPL%2Ftraffic_scripts%2Fnat.py;h=9e224dbae862259370bf8c0c6385ce0d5493e35b;hp=43715fb383e6b3a4ca75096272927852117d3f63;hb=9d14c2d71ce85fe95aa9a2321738abb25d032b0c;hpb=7829fea4a2c8936513fa95215b7d84997f814a69 diff --git a/GPL/traffic_scripts/nat.py b/GPL/traffic_scripts/nat.py index 43715fb383..9e224dbae8 100644 --- a/GPL/traffic_scripts/nat.py +++ b/GPL/traffic_scripts/nat.py @@ -30,7 +30,7 @@ import sys import ipaddress from scapy.layers.inet import IP, TCP, UDP -from scapy.layers.inet6 import IPv6, ICMPv6ND_NS, ICMPv6MLReport2 +from scapy.layers.inet6 import IPv6, ICMPv6ND_NS, ICMPv6MLReport2, ICMPv6ND_RA from scapy.layers.l2 import Ether from scapy.packet import Raw @@ -45,7 +45,6 @@ def valid_ipv4(ip_address): :type ip_address: str :returns: True if IP address is correct. :rtype: bool - :raises AttributeError, AddressValueError: If IP address is not valid. """ try: ipaddress.IPv4Address(ip_address) @@ -61,7 +60,6 @@ def valid_ipv6(ip_address): :type ip_address: str :returns: True if IP address is correct. :rtype: bool - :raises AttributeError, AddressValueError: If IP address is not valid. """ try: ipaddress.IPv6Address(ip_address) @@ -136,9 +134,16 @@ def main(): if ether.haslayer(ICMPv6ND_NS): # read another packet in the queue if the current one is ICMPv6ND_NS continue - else: - # otherwise process the current packet - break + elif ether.haslayer(ICMPv6MLReport2): + # read another packet in the queue if the current one is + # ICMPv6MLReport2 + continue + elif ether.haslayer(ICMPv6ND_RA): + # read another packet in the queue if the current one is + # ICMPv6ND_RA + continue + + break if rx_dst_mac != ether[Ether].dst or rx_src_mac != ether[Ether].src: raise RuntimeError(f"Matching packet unsuccessful: {ether!r}") @@ -202,9 +207,12 @@ def main(): # read another packet in the queue if the current one is # ICMPv6MLReport2 continue - else: - # otherwise process the current packet - break + elif ether.haslayer(ICMPv6ND_RA): + # read another packet in the queue if the current one is + # ICMPv6ND_RA + continue + + break if ether[Ether].dst != tx_src_mac or ether[Ether].src != tx_dst_mac: raise RuntimeError(f"Matching packet unsuccessful: {ether!r}")