draft
authorimarom <[email protected]>
Tue, 18 Aug 2015 14:00:00 +0000 (17:00 +0300)
committerimarom <[email protected]>
Tue, 18 Aug 2015 14:00:00 +0000 (17:00 +0300)
scripts/trex_console [new file with mode: 0755]
src/console/trex_console.py
src/console/trex_rpc_client.py
src/console/trex_status.py
src/rpc-server/src/trex_rpc_server.cpp

diff --git a/scripts/trex_console b/scripts/trex_console
new file mode 100755 (executable)
index 0000000..6a79d54
--- /dev/null
@@ -0,0 +1,2 @@
+#!/bin/bash
+/usr/bin/python ../src/console/trex_console.py
index ca4c7e8..15022e0 100755 (executable)
@@ -15,6 +15,7 @@ class TrexConsole(cmd.Cmd):
         self.intro  = "\n-=TRex Console V1.0=-\n" 
         self.rpc_client = rpc_client
         self.verbose = False
+        
         rc, msg = self.rpc_client.query_rpc_server()
 
         if rc:
@@ -96,7 +97,7 @@ class TrexConsole(cmd.Cmd):
 def main ():
     # RPC client
     try:
-        rpc_client = RpcClient(5050)
+        rpc_client = RpcClient("localhost", 5050)
         rpc_client.connect()
     except Exception as e:
         print "\n*** " + str(e) + "\n"
index 04dd772..4562cf2 100644 (file)
@@ -5,6 +5,23 @@ from time import sleep
 \r
 class RpcClient():\r
 \r
+    def __init__ (self, server, port):\r
+        self.context = zmq.Context()\r
+        \r
+        self.port = port\r
+        self.server = server\r
+        #  Socket to talk to server\r
+        self.transport = "tcp://{0}:{1}".format(server, port)\r
+\r
+        self.verbose = False\r
+\r
+    def get_connection_details (self):\r
+        rc = {}\r
+        rc['server'] = self.server\r
+        rc['port']   = self.port\r
+\r
+        return rc\r
+\r
     def create_jsonrpc_v2 (self, method_name, params = {}, id = None):\r
         msg = {}\r
         msg["jsonrpc"] = "2.0"\r
@@ -79,13 +96,6 @@ class RpcClient():
     def query_rpc_server (self):\r
         return self.invoke_rpc_method("rpc_get_reg_cmds")\r
 \r
-    def __init__ (self, port):\r
-        self.context = zmq.Context()\r
-        \r
-        #  Socket to talk to server\r
-        self.transport = "tcp://localhost:{0}".format(port)\r
-\r
-        self.verbose = False\r
 \r
     def set_verbose (self, mode):\r
         self.verbose = mode\r
index a17c258..20d7053 100755 (executable)
@@ -91,11 +91,14 @@ class TrexStatus():
 
         self.info_panel.clear()
 
-        self.info_panel.getwin().addstr(3, 2, "{:<30} {:30}".format("Version:", self.server_status["general"]["version"]))
-        self.info_panel.getwin().addstr(4, 2, "{:<30} {:30}".format("Build:", 
+        connection_details = self.rpc_client.get_connection_details()
+
+        self.info_panel.getwin().addstr(3, 2, "{:<30} {:30}".format("Server:", connection_details['server'] + ":" + str(connection_details['port'])))
+        self.info_panel.getwin().addstr(4, 2, "{:<30} {:30}".format("Version:", self.server_status["general"]["version"]))
+        self.info_panel.getwin().addstr(5, 2, "{:<30} {:30}".format("Build:", 
                                                                     self.server_status["general"]["build_date"] + " @ " + self.server_status["general"]["build_time"] + " by " + self.server_status["general"]["version_user"]))
 
-        self.info_panel.getwin().addstr(5, 2, "{:<30} {:30}".format("Server Uptime:", self.server_status["general"]["uptime"]))
+        self.info_panel.getwin().addstr(6, 2, "{:<30} {:30}".format("Server Uptime:", self.server_status["general"]["uptime"]))
         #self.ft_panel.clear()
 
         #ft_section_y  = 3
@@ -250,7 +253,7 @@ class TrexStatus():
                     self.add_log_event("Pinging RPC server")
                     rc, msg = self.rpc_client.ping_rpc_server()
                     if rc:
-                        self.add_log_event("Server replied")
+                        self.add_log_event("Server replied: '{0}'".format(msg))
                     else:
                         self.add_log_event("Failed to get reply")
                     
@@ -268,7 +271,7 @@ class TrexStatus():
 
             panel.update_panels(); 
             self.stdscr.refresh()
-            sleep(0.2)
+            sleep(0.1)
 
 
 def show_trex_status_internal (stdscr, rpc_client):
index 17eeec6..139614e 100644 (file)
@@ -75,7 +75,7 @@ get_current_date_time() {
     struct tm  tstruct;
     char       buf[80];
     tstruct = *localtime(&now);
-    strftime(buf, sizeof(buf), "%d-%b-%Y / %X", &tstruct);
+    strftime(buf, sizeof(buf), "%b %d %Y @ %X", &tstruct);
 
     return buf;
 }