From cdcc62972d42f009f55e6aeb2ca5c60c3acd75eb Mon Sep 17 00:00:00 2001
From: Dan Klein <danklei@cisco.com>
Date: Wed, 26 Aug 2015 14:27:43 +0300
Subject: added dpkt package, initial stateless client implementation

---
 .../client/trex_stateless_client.py                | 58 ++++++++++++++++++++++
 1 file changed, 58 insertions(+)
 create mode 100644 scripts/automation/trex_control_plane/client/trex_stateless_client.py

(limited to 'scripts/automation/trex_control_plane/client')

diff --git a/scripts/automation/trex_control_plane/client/trex_stateless_client.py b/scripts/automation/trex_control_plane/client/trex_stateless_client.py
new file mode 100644
index 00000000..670eda1d
--- /dev/null
+++ b/scripts/automation/trex_control_plane/client/trex_stateless_client.py
@@ -0,0 +1,58 @@
+#!/router/bin/python
+
+try:
+    # support import for Python 2
+    import outer_packages
+except ImportError:
+    # support import for Python 3
+    import client.outer_packages
+from client_utils.jsonrpc_client import JsonRpcClient
+
+
+
+class CTRexStatelessClient(object):
+    """docstring for CTRexStatelessClient"""
+    def __init__(self, server="localhost", port=5050, virtual=False):
+        super(CTRexStatelessClient, self).__init__()
+        self.tx_link = CTRexStatelessClient.CTxLink(server, port, virtual)
+
+
+    def transmit(self, method_name, params = {}):
+        return self.tx_link.transmit(method_name, params)
+
+
+
+    class CTxLink(object):
+        """describes the connectivity of the stateless client method"""
+        def __init__(self, server="localhost", port=5050, virtual=False):
+            super(CTRexStatelessClient.CTxLink, self).__init__()
+            self.virtual = virtual
+            self.server = server
+            self.port = port
+            self.rpc_link = JsonRpcClient(self.server, self.port)
+            if not self.virtual:
+                self.rpc_link.connect()
+
+        def transmit(self, method_name, params = {}):
+            if self.virtual:
+                print "Transmitting virtually over tcp://{server}:{port}".format(
+                    server=self.server,
+                    port=self.port)
+                id, msg = self.rpc_link.create_jsonrpc_v2(method_name, params)
+                print msg
+                return
+            else:
+                return self.rpc_link.invoke_rpc_method(method_name, params)
+
+
+
+
+
+class CTRexVM(object):
+    """docstring for CTRexVM"""
+    def __init__(self, arg):
+        super(CTRexVM, self).__init__()
+        self.arg = arg
+
+if __name__ == "__main__":
+    pass
-- 
cgit