diff options
Diffstat (limited to 'src/stateless')
| -rw-r--r-- | src/stateless/cp/trex_dp_port_events.cpp | 6 | ||||
| -rw-r--r-- | src/stateless/cp/trex_stateless_port.cpp | 9 |
2 files changed, 8 insertions, 7 deletions
diff --git a/src/stateless/cp/trex_dp_port_events.cpp b/src/stateless/cp/trex_dp_port_events.cpp index 8e098adf..1321a362 100644 --- a/src/stateless/cp/trex_dp_port_events.cpp +++ b/src/stateless/cp/trex_dp_port_events.cpp @@ -82,6 +82,12 @@ protected: void TrexDpPortEvents::barrier() { + + /* simulator will be stuck here forever */ + #ifdef TREX_SIM + return; + #endif + int barrier_id = create_event(new DPBarrier()); TrexStatelessCpToDpMsgBase *barrier_msg = new TrexStatelessDpBarrier(m_port->m_port_id, barrier_id); diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp index 7302e05d..5947aaf7 100644 --- a/src/stateless/cp/trex_stateless_port.cpp +++ b/src/stateless/cp/trex_stateless_port.cpp @@ -103,14 +103,9 @@ TrexStatelessPort::TrexStatelessPort(uint8_t port_id, const TrexPlatformApi *api } TrexStatelessPort::~TrexStatelessPort() { - if (m_graph_obj) { - delete m_graph_obj; - } - if (m_pending_async_stop_event != TrexDpPortEvents::INVALID_ID) { - m_dp_events.destroy_event(m_pending_async_stop_event); - m_pending_async_stop_event = TrexDpPortEvents::INVALID_ID; - } + stop_traffic(); + remove_and_delete_all_streams(); } /** |