diff options
author | imarom <imarom@cisco.com> | 2016-01-24 11:35:41 -0500 |
---|---|---|
committer | imarom <imarom@cisco.com> | 2016-01-24 11:35:41 -0500 |
commit | b87ac8e2af727598b3120510b221244c9c499e56 (patch) | |
tree | 425d9cb46b9fa49eb13a0e2773a3e68591182c6c /src/rpc-server/commands/trex_rpc_cmd_stream.cpp | |
parent | 7294d7f162e19e0ccd3a37eafbafe22cf63df6a4 (diff) |
added support for L1 B/W check
both start/update now enforce this and it can
be bypassed by providing 'force'
Diffstat (limited to 'src/rpc-server/commands/trex_rpc_cmd_stream.cpp')
-rw-r--r-- | src/rpc-server/commands/trex_rpc_cmd_stream.cpp | 13 |
1 files changed, 8 insertions, 5 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 ¶ms, 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 ¶ms, 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 ¶ms, 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 ¶ms, 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 ¶ms, 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()); } |