--- /dev/null
+#!/bin/bash
+/usr/bin/python ../src/console/trex_console.py
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:
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"
\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
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
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
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")
panel.update_panels();
self.stdscr.refresh()
- sleep(0.2)
+ sleep(0.1)
def show_trex_status_internal (stdscr, rpc_client):
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;
}