udp: refactor udp code

[vpp.git] / src / scripts / vnet / uri / dummy_app.py

diff --git a/src/scripts/vnet/uri/dummy_app.py b/src/scripts/vnet/uri/dummy_app.py
old mode 100644 (file)
new mode 100755 (executable)
index ff00f2f..85ea4dc
--- a/src/scripts/vnet/uri/dummy_app.py
+++ b/src/scripts/vnet/uri/dummy_app.py
@@ -3,6 +3,7 @@
 import socket
 import sys
 import time
+import argparse
 
 # action can be reflect or drop 
 action = "drop"
@@ -32,37 +33,52 @@ def handle_connection (connection, client_address):
                 connection.sendall(data)
     finally:
         connection.close()
-        
-def run_server(ip, port):
-    print("Starting server {}:{}".format(repr(ip), repr(port)))
+def run_tcp_server(ip, port):
+    print("Starting TCP server {}:{}".format(repr(ip), repr(port)))
     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
     server_address = (ip, int(port))
     sock.bind(server_address)
     sock.listen(1)
-    
     while True:
         connection, client_address = sock.accept()
         handle_connection (connection, client_address)
+def run_udp_server(ip, port):
+    print("Starting UDP server {}:{}".format(repr(ip), repr(port)))
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    server_address = (ip, int(port))
+    sock.bind(server_address)
+    while True:
+        data, addr = sock.recvfrom(4096)
+        if (action != "drop"):
+            #snd_sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+            sock.sendto (data, addr)
 
-def prepare_data():
+def run_server(ip, port, proto):
+    if (proto == "tcp"):
+        run_tcp_server(ip, port)
+    elif (proto == "udp"):
+        run_udp_server(ip, port)
+
+def prepare_data(power):
     buf = []
-    for i in range (0, pow(2, 16)):
+    for i in range (0, pow(2, power)):
         buf.append(i & 0xff)
     return bytearray(buf)
 
-def run_client(ip, port):
-    print("Starting client {}:{}".format(repr(ip), repr(port)))
+def run_tcp_client(ip, port):
+    print("Starting TCP client {}:{}".format(repr(ip), repr(port)))
     sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-    server_address = (ip, port)
+    server_address = (ip, int(port))
     sock.connect(server_address)
-    
-    data = prepare_data()
+
+    data = prepare_data(16)
     n_rcvd = 0
     n_sent = len (data)
     try:
         sock.sendall(data)
-        
+
         timeout = time.time() + 2
         while n_rcvd < n_sent and time.time() < timeout:
             tmp = sock.recv(1500)
@@ -73,28 +89,53 @@ def run_client(ip, port):
                     print("Difference at byte {}. Sent {} got {}"
                           .format(n_rcvd + i, data[n_rcvd + i], tmp[i]))
             n_rcvd += n_read
-            
+
         if (n_rcvd < n_sent or n_rcvd > n_sent):
             print("Sent {} and got back {}".format(n_sent, n_rcvd))
         else:
             print("Got back what we've sent!!");
-            
+
     finally:
         sock.close()
-    
-def run(mode, ip, port):
+def run_udp_client(ip, port):
+    print("Starting UDP client {}:{}".format(repr(ip), repr(port)))
+    n_packets = 100
+    sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+    server_address = (ip, int(port))
+    data = prepare_data(10)
+    try:
+        for i in range (0, n_packets):
+            sock.sendto(data, server_address)
+    finally:
+        sock.close()
+def run_client(ip, port, proto):
+    if (proto == "tcp"):
+        run_tcp_client(ip, port)
+    elif (proto == "udp"):
+        run_udp_client(ip, port)
+def run(mode, ip, port, proto):
     if (mode == "server"):
-        run_server (ip, port)
+        run_server (ip, port, proto)
     elif (mode == "client"):
-        run_client (ip, port)
+        run_client (ip, port, proto)
     else:
         raise Exception("Unknown mode. Only client and server supported")
 
 if __name__ == "__main__":
-    if (len(sys.argv)) < 4:
-        raise Exception("Usage: ./dummy_app <mode> <ip> <port> [<action> <test>]")
-    if (len(sys.argv) == 6):
-        action = sys.argv[4]
-        test = int(sys.argv[5])
-
-    run (sys.argv[1], sys.argv[2], int(sys.argv[3]))
+    parser = argparse.ArgumentParser()
+    parser.add_argument('-m', action='store', dest='mode')
+    parser.add_argument('-i', action='store', dest='ip')
+    parser.add_argument('-p', action='store', dest='port')
+    parser.add_argument('-proto', action='store', dest='proto')
+    parser.add_argument('-a', action='store', dest='action')
+    parser.add_argument('-t', action='store', dest='test')
+    results = parser.parse_args()
+    action = results.action
+    test = results.test
+    run(results.mode, results.ip, results.port, results.proto)
+    #if (len(sys.argv)) < 4:
+    #    raise Exception("Usage: ./dummy_app <mode> <ip> <port> [<action> <test>]")
+    #if (len(sys.argv) == 6):
+    #    action = sys.argv[4]
+    #    test = int(sys.argv[5])
+    #run (sys.argv[1], sys.argv[2], int(sys.argv[3]))