added support for L1 B/W check

both start/update now enforce this and it can
be bypassed by providing 'force'

4 files changed, 45 insertions, 19 deletions

diff --git a/src/rpc-server/commands/trex_rpc_cmd_stream.cpp b/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
index b6585a88..821479f5 100644
--- a/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
+++ b/src/rpc-server/commands/trex_rpc_cmd_stream.cpp
@@ -450,6 +450,7 @@ TrexRpcCmdStartTraffic::_run(const Json::Value &params, Json::Value &result) {
     TrexStatelessPort *port = get_stateless_obj()->get_port_by_id(port_id);
 
     double duration  = parse_double(params, "duration", result);
+    bool   force     = parse_bool(params, "force", result);
 
     /* multiplier */
     const Json::Value &mul_obj  = parse_object(params, "mul", result);
@@ -457,7 +458,7 @@ TrexRpcCmdStartTraffic::_run(const Json::Value &params, Json::Value &result) {
     std::string type   = parse_choice(mul_obj, "type", TrexPortMultiplier::g_types, result);
     std::string op     = parse_string(mul_obj, "op", result);
     double      value  = parse_double(mul_obj, "value", result);
-
+    
     if (op != "abs") {
         generate_parse_err(result, "start message can only specify absolute speed rate");
     }
@@ -465,9 +466,9 @@ TrexRpcCmdStartTraffic::_run(const Json::Value &params, Json::Value &result) {
     TrexPortMultiplier mul(type, op, value);
 
     try {
-        port->start_traffic(mul, duration);
+        port->start_traffic(mul, duration, force);
 
-    } catch (const TrexRpcException &ex) {
+    } catch (const TrexException &ex) {
         generate_execute_err(result, ex.what());
     }
 
@@ -585,6 +586,8 @@ TrexRpcCmdUpdateTraffic::_run(const Json::Value &params, Json::Value &result) {
     uint8_t port_id = parse_port(params, result);
     TrexStatelessPort *port = get_stateless_obj()->get_port_by_id(port_id);
 
+    bool force = parse_bool(params, "force", result);
+
     /* multiplier */
 
     const Json::Value &mul_obj  = parse_object(params, "mul", result);
@@ -597,8 +600,8 @@ TrexRpcCmdUpdateTraffic::_run(const Json::Value &params, Json::Value &result) {
 
 
     try {
-        port->update_traffic(mul);
-    } catch (const TrexRpcException &ex) {
+        port->update_traffic(mul, force);
+    } catch (const TrexException &ex) {
         generate_execute_err(result, ex.what());
     }
 
diff --git a/src/rpc-server/commands/trex_rpc_cmds.h b/src/rpc-server/commands/trex_rpc_cmds.h
index 081398d1..48a38780 100644
--- a/src/rpc-server/commands/trex_rpc_cmds.h
+++ b/src/rpc-server/commands/trex_rpc_cmds.h
@@ -110,12 +110,12 @@ TREX_RPC_CMD_DEFINE(TrexRpcCmdGetStream, "get_stream", 3, false);
 
 
 
-TREX_RPC_CMD_DEFINE(TrexRpcCmdStartTraffic,  "start_traffic", 3, true);
+TREX_RPC_CMD_DEFINE(TrexRpcCmdStartTraffic,  "start_traffic", 4, true);
 TREX_RPC_CMD_DEFINE(TrexRpcCmdStopTraffic,   "stop_traffic", 1, true);
 TREX_RPC_CMD_DEFINE(TrexRpcCmdPauseTraffic,  "pause_traffic", 1, true);
 TREX_RPC_CMD_DEFINE(TrexRpcCmdResumeTraffic, "resume_traffic", 1, true);
 
-TREX_RPC_CMD_DEFINE(TrexRpcCmdUpdateTraffic, "update_traffic", 2, true);
+TREX_RPC_CMD_DEFINE(TrexRpcCmdUpdateTraffic, "update_traffic", 3, true);
 
 TREX_RPC_CMD_DEFINE(TrexRpcCmdValidate, "validate", 2, false);
 
diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp
index f14cc84c..d47802ec 100644
--- a/src/stateless/cp/trex_stateless_port.cpp
+++ b/src/stateless/cp/trex_stateless_port.cpp
@@ -132,7 +132,7 @@ TrexStatelessPort::release(void) {
  * 
  */
 void
-TrexStatelessPort::start_traffic(const TrexPortMultiplier &mul, double duration) {
+TrexStatelessPort::start_traffic(const TrexPortMultiplier &mul, double duration, bool force) {
 
     /* command allowed only on state stream */
     verify_state(PORT_STATE_STREAMS);
@@ -143,7 +143,8 @@ TrexStatelessPort::start_traffic(const TrexPortMultiplier &mul, double duration)
     /* on start - we can only provide absolute values */
     assert(mul.m_op == TrexPortMultiplier::OP_ABS);
 
-    double factor = calculate_effective_factor(mul);
+    /* caclulate the effective factor for DP */
+    double factor = calculate_effective_factor(mul, force);
 
     /* fetch all the streams from the table */
     vector<TrexStream *> streams;
@@ -274,14 +275,14 @@ TrexStatelessPort::resume_traffic(void) {
 }
 
 void
-TrexStatelessPort::update_traffic(const TrexPortMultiplier &mul) {
+TrexStatelessPort::update_traffic(const TrexPortMultiplier &mul, bool force) {
 
     double factor;
 
     verify_state(PORT_STATE_TX | PORT_STATE_PAUSE);
 
     /* generate a message to all the relevant DP cores to start transmitting */
-    double new_factor = calculate_effective_factor(mul);
+    double new_factor = calculate_effective_factor(mul, force);
 
     switch (mul.m_op) {
     case TrexPortMultiplier::OP_ABS:
@@ -446,20 +447,42 @@ TrexStatelessPort::get_port_speed_bps() const {
     }
 }
 
+static inline double
+bps_to_gbps(double bps) {
+    return (bps / (1000.0 * 1000 * 1000));
+}
+
 double
-TrexStatelessPort::calculate_effective_factor(const TrexPortMultiplier &mul) {
+TrexStatelessPort::calculate_effective_factor(const TrexPortMultiplier &mul, bool force) {
 
-    /* for a simple factor request */
-    if (mul.m_type == TrexPortMultiplier::MUL_FACTOR) {
-        return (mul.m_value);
+    double factor = calculate_effective_factor_internal(mul);
+
+    /* did we exceeded the max L1 line rate ? */
+    double expected_l1_rate = factor * m_graph_obj->get_max_bps_l1();
+
+    /* if not force and exceeded - throw exception */
+    if ( (!force) && (expected_l1_rate > get_port_speed_bps()) ) {
+        stringstream ss;
+        ss << "Expected L1 B/W: '" << bps_to_gbps(expected_l1_rate) << " Gbps' exceeds port line rate: '" << bps_to_gbps(get_port_speed_bps()) << " Gbps'";
+        throw TrexException(ss.str());
     }
 
+    return factor;
+}
+
+double
+TrexStatelessPort::calculate_effective_factor_internal(const TrexPortMultiplier &mul) {
+
     /* we now need the graph - generate it if we don't have it (happens once) */
     if (!m_graph_obj) {
         generate_streams_graph();
     }
 
     switch (mul.m_type) {
+
+    case TrexPortMultiplier::MUL_FACTOR:
+        return (mul.m_value);
+
     case TrexPortMultiplier::MUL_BPS:
         return (mul.m_value / m_graph_obj->get_max_bps_l2());
 
diff --git a/src/stateless/cp/trex_stateless_port.h b/src/stateless/cp/trex_stateless_port.h
index c3785b0c..64cf73a4 100644
--- a/src/stateless/cp/trex_stateless_port.h
+++ b/src/stateless/cp/trex_stateless_port.h
@@ -162,7 +162,7 @@ public:
      * start traffic
      * throws TrexException in case of an error
      */
-    void start_traffic(const TrexPortMultiplier &mul, double duration);
+    void start_traffic(const TrexPortMultiplier &mul, double duration, bool force = false);
 
     /**
      * stop traffic
@@ -186,7 +186,7 @@ public:
      * update current traffic on port
      * 
      */
-    void update_traffic(const TrexPortMultiplier &mul);
+    void update_traffic(const TrexPortMultiplier &mul, bool force);
 
     /**
      * get the port state
@@ -351,8 +351,8 @@ private:
      * calculate effective M per core
      * 
      */
-    double calculate_effective_factor(const TrexPortMultiplier &mul);
-
+    double calculate_effective_factor(const TrexPortMultiplier &mul, bool force = false);
+    double calculate_effective_factor_internal(const TrexPortMultiplier &mul);
   
 
     /**