summaryrefslogtreecommitdiffstats
path: root/src/stateless/cp/trex_stateless_port.cpp
diff options
context:
space:
mode:
authorimarom <imarom@cisco.com>2016-02-01 08:59:38 -0500
committerimarom <imarom@cisco.com>2016-02-01 09:03:03 -0500
commit11bcf4ca8fed5259e321c535bf90d0442e9b9746 (patch)
treed0c632c77fdb15773b7151c394224d6e7253c743 /src/stateless/cp/trex_stateless_port.cpp
parentbdc690e8229808974a8f899e145931c06db6e082 (diff)
fix for http://trex-tgn.cisco.com/youtrack/issue/trex-174
Diffstat (limited to 'src/stateless/cp/trex_stateless_port.cpp')
-rw-r--r--src/stateless/cp/trex_stateless_port.cpp11
1 files changed, 9 insertions, 2 deletions
diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp
index 2286ef76..a281e428 100644
--- a/src/stateless/cp/trex_stateless_port.cpp
+++ b/src/stateless/cp/trex_stateless_port.cpp
@@ -184,8 +184,15 @@ TrexStatelessPort::start_traffic(const TrexPortMultiplier &mul, double duration,
int index = 0;
for (auto core_id : m_cores_id_list) {
- TrexStatelessCpToDpMsgBase *start_msg = new TrexStatelessDpStart(m_port_id, event_id, compiled_objs[index], duration);
- send_message_to_dp(core_id, start_msg);
+ /* was the core assigned a compiled object ? */
+ if (compiled_objs[index]) {
+ TrexStatelessCpToDpMsgBase *start_msg = new TrexStatelessDpStart(m_port_id, event_id, compiled_objs[index], duration);
+ send_message_to_dp(core_id, start_msg);
+ } else {
+
+ /* mimic an end event */
+ m_dp_events.handle_event(TrexDpPortEvent::EVENT_STOP, core_id, event_id);
+ }
index++;
}