diff options
| author |   imarom <imarom@cisco.com> | 2016-05-17 14:01:03 +0300 |
|---|---|---|
| committer | imarom <imarom@cisco.com> | 2016-05-17 14:01:03 +0300 |
| commit | 8b1d07ff4019df739a233cdcb812048ee44ae554 (patch) | |
| tree | 3d7b32ab19701c29db15da9bb39aeb46607d0269 /src/stateless | |
| parent | f7ebbddbef19bf8bd362cfbe4772dfb65568285b (diff) | |
flush TX queue before sending done message to CP
Diffstat (limited to 'src/stateless')
| -rw-r--r-- | src/stateless/dp/trex_stateless_dp_core.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/stateless/dp/trex_stateless_dp_core.cpp b/src/stateless/dp/trex_stateless_dp_core.cpp index c5963625..3d99e0fd 100644 --- a/src/stateless/dp/trex_stateless_dp_core.cpp +++ b/src/stateless/dp/trex_stateless_dp_core.cpp @@ -1095,6 +1095,9 @@ TrexStatelessDpCore::stop_traffic(uint8_t port_id, } + /* flush the TX queue before sending done message to the CP */ + m_core->flush_tx_queue(); + CNodeRing *ring = CMsgIns::Ins()->getCpDp()->getRingDpToCp(m_core->m_thread_id); TrexStatelessDpToCpMsgBase *event_msg = new TrexDpPortEventMsg(m_core->m_thread_id, port_id, |