Merge random_seed per stream

2 files changed, 14 insertions, 5 deletions

diff --git a/src/rpc-server/commands/trex_rpc_cmd_general.cpp b/src/rpc-server/commands/trex_rpc_cmd_general.cpp
index 6ac88352..9b3b59a7 100644
--- a/src/rpc-server/commands/trex_rpc_cmd_general.cpp
+++ b/src/rpc-server/commands/trex_rpc_cmd_general.cpp
@@ -178,6 +178,10 @@ TrexRpcCmdGetSysInfo::_run(const Json::Value &params, Json::Value &result) {
 
         section["ports"][i]["driver"]  = driver;
 
+        section["ports"][i]["rx"]["caps"]      = port->get_rx_caps();
+        section["ports"][i]["rx"]["counters"]  = port->get_rx_count_num();
+            
+
         switch (speed) {
         case TrexPlatformApi::SPEED_1G:
             section["ports"][i]["speed"]   = 1;
diff --git a/src/rpc-server/commands/trex_rpc_cmd_stream.cpp b/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
index 5e23b813..cf11f8c6 100644
--- a/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
+++ b/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
@@ -105,18 +105,23 @@ TrexRpcCmdAddStream::_run(const Json::Value &params, Json::Value &result) {
 
     stream->m_rx_check.m_enabled = parse_bool(rx, "enabled", result);
 
+    TrexStatelessPort *port = get_stateless_obj()->get_port_by_id(stream->m_port_id);
+
     /* if it is enabled - we need more fields */
     if (stream->m_rx_check.m_enabled) {
-        stream->m_rx_check.m_user_id   = parse_int(rx, "stream_id", result);
-        stream->m_rx_check.m_seq_enabled = parse_bool(rx, "seq_enabled", result);
-        stream->m_rx_check.m_latency     = parse_bool(rx, "latency_enabled", result);
+
+        if (port->get_rx_caps() == 0) {
+            generate_parse_err(result, "RX stats is not supported on this interface");
+        }
+
+        stream->m_rx_check.m_user_id      = parse_int(rx, "stream_id", result);
+        stream->m_rx_check.m_seq_enabled  = parse_bool(rx, "seq_enabled", result);
+        stream->m_rx_check.m_latency      = parse_bool(rx, "latency_enabled", result);
     }
 
     /* make sure this is a valid stream to add */
     validate_stream(stream, result);
 
-    TrexStatelessPort *port = get_stateless_obj()->get_port_by_id(stream->m_port_id);
-
     try {
         port->add_stream(stream.get());
         stream.release();