summaryrefslogtreecommitdiffstats
path: root/src/stateless/dp/trex_stateless_dp_core.cpp
diff options
context:
space:
mode:
authorHanoh Haim <hhaim@cisco.com>2015-11-19 09:08:28 +0200
committerHanoh Haim <hhaim@cisco.com>2015-11-19 09:08:28 +0200
commita2625fbfa24a812b950c1a95ef067e6fa169a3cf (patch)
tree9d8cf199af0912f17011703425b8a747a97435f1 /src/stateless/dp/trex_stateless_dp_core.cpp
parent0e8c9ae666d61897cb405c469a71be09d54a649b (diff)
add a test for stream program
Diffstat (limited to 'src/stateless/dp/trex_stateless_dp_core.cpp')
-rw-r--r--src/stateless/dp/trex_stateless_dp_core.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/stateless/dp/trex_stateless_dp_core.cpp b/src/stateless/dp/trex_stateless_dp_core.cpp
index 640fdb4d..c4fdd44b 100644
--- a/src/stateless/dp/trex_stateless_dp_core.cpp
+++ b/src/stateless/dp/trex_stateless_dp_core.cpp
@@ -435,9 +435,10 @@ TrexStatelessDpCore::add_cont_stream(TrexStatelessDpPerPort * lp_port,
lp_port->m_active_nodes.push_back(one_stream);
- /* schedule */
- m_core->m_node_gen.add_node((CGenNode *)node);
-
+ /* schedule only if active */
+ if (node->m_state == CGenNodeStateless::ss_ACTIVE) {
+ m_core->m_node_gen.add_node((CGenNode *)node);
+ }
}
void