diff options
author | 2015-11-01 10:20:16 +0200 | |
---|---|---|
committer | 2015-11-01 10:20:16 +0200 | |
commit | a1971ec3a7f6cbe0aea1393a57aa17bf44deedac (patch) | |
tree | 41c0de4453d8f0cf0176834ca37f8757ecb90b47 /src/stateless/cp/trex_stateless_port.cpp | |
parent | 9a820782c35c6de79d2e724a48087e8ee62fc72d (diff) |
DP stop message now disables only port related nodes
and not all of them
Diffstat (limited to 'src/stateless/cp/trex_stateless_port.cpp')
-rw-r--r-- | src/stateless/cp/trex_stateless_port.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp index 375d1f63..feea5ed5 100644 --- a/src/stateless/cp/trex_stateless_port.cpp +++ b/src/stateless/cp/trex_stateless_port.cpp @@ -69,7 +69,7 @@ TrexStatelessPort::start_traffic(void) { /* compiler it */ TrexStreamsCompiler compiler; - TrexStreamsCompiledObj *compiled_obj = new TrexStreamsCompiledObj(); + TrexStreamsCompiledObj *compiled_obj = new TrexStreamsCompiledObj(m_port_id); bool rc = compiler.compile(streams, *compiled_obj); if (!rc) { @@ -99,7 +99,7 @@ TrexStatelessPort::stop_traffic(void) { } /* generate a message to all the relevant DP cores to start transmitting */ - TrexStatelessCpToDpMsgBase *stop_msg = new TrexStatelessDpStop(); + TrexStatelessCpToDpMsgBase *stop_msg = new TrexStatelessDpStop(m_port_id); // FIXME (add the right core list) CNodeRing *ring = CMsgIns::Ins()->getCpDp()->getRingCpToDp(0); |