Code Review
/
csit.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
CSIT-618 Add LaTeX support to release report
[csit.git]
/
resources
/
traffic_scripts
/
send_vxlangpe_nsh_for_proxy_test.py
diff --git
a/resources/traffic_scripts/send_vxlangpe_nsh_for_proxy_test.py
b/resources/traffic_scripts/send_vxlangpe_nsh_for_proxy_test.py
index
ea1f9b1
..
d998d7c
100755
(executable)
--- a/
resources/traffic_scripts/send_vxlangpe_nsh_for_proxy_test.py
+++ b/
resources/traffic_scripts/send_vxlangpe_nsh_for_proxy_test.py
@@
-21,11
+21,11
@@
import time
from scapy.layers.inet import IP, UDP, TCP
from scapy.layers.inet6 import IPv6
from scapy.all import Ether, Packet, Raw
from scapy.layers.inet import IP, UDP, TCP
from scapy.layers.inet6 import IPv6
from scapy.all import Ether, Packet, Raw
-from scapy.all import sendp
from resources.libraries.python.SFC.VerifyPacket import *
from resources.libraries.python.SFC.SFCConstants import SFCConstants as sfccon
from resources.libraries.python.TrafficScriptArg import TrafficScriptArg
from resources.libraries.python.SFC.VerifyPacket import *
from resources.libraries.python.SFC.SFCConstants import SFCConstants as sfccon
from resources.libraries.python.TrafficScriptArg import TrafficScriptArg
+from resources.libraries.python.PacketVerifier import RxQueue, TxQueue
from robot.api import logger
from robot.api import logger
@@
-48,6
+48,10
@@
def main():
frame_size = int(args.get_arg('framesize'))
test_type = args.get_arg('testtype')
frame_size = int(args.get_arg('framesize'))
test_type = args.get_arg('testtype')
+ rxq = RxQueue(rx_if)
+ txq = TxQueue(tx_if)
+ sent_packets = []
+
protocol = TCP
source_port = sfccon.DEF_SRC_PORT
destination_port = sfccon.DEF_DST_PORT
protocol = TCP
source_port = sfccon.DEF_SRC_PORT
destination_port = sfccon.DEF_DST_PORT
@@
-81,12
+85,17
@@
def main():
pkt_raw = pkt_header / Raw(load=pad_data)
pkt_raw = pkt_header / Raw(load=pad_data)
- sendp(pkt_raw, iface=tx_if, count=3)
+ # Send created packet on one interface and receive on the other
+ sent_packets.append(pkt_raw)
+ txq.send(pkt_raw)
+
+ ether = rxq.recv(2)
- time.sleep(timeout)
+ if ether is None:
+ raise RuntimeError("No packet is received!")
# let us begin to check the proxy inbound packet
# let us begin to check the proxy inbound packet
- VerifyPacket.check_the_nsh_sfc_packet(frame_size, test_type)
+ VerifyPacket.check_the_nsh_sfc_packet(
ether,
frame_size, test_type)
# we check all the fields about the proxy inbound, this test will pass
sys.exit(0)
# we check all the fields about the proxy inbound, this test will pass
sys.exit(0)