diff options
author | imarom <imarom@cisco.com> | 2016-03-02 11:05:51 +0200 |
---|---|---|
committer | imarom <imarom@cisco.com> | 2016-03-02 13:35:09 +0200 |
commit | 59a3b58d240661a2bc06c6ede473d2eda4eb5e55 (patch) | |
tree | 37dd8d43c4bc6a0421d5964d7d1c57be3cca51a2 /src/stateless/messaging/trex_stateless_messaging.cpp | |
parent | 70cfb9f88b00016f1413754e5625b5b05acc2063 (diff) |
TX barrier
Diffstat (limited to 'src/stateless/messaging/trex_stateless_messaging.cpp')
-rw-r--r-- | src/stateless/messaging/trex_stateless_messaging.cpp | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/src/stateless/messaging/trex_stateless_messaging.cpp b/src/stateless/messaging/trex_stateless_messaging.cpp index 257de168..333aec88 100644 --- a/src/stateless/messaging/trex_stateless_messaging.cpp +++ b/src/stateless/messaging/trex_stateless_messaging.cpp @@ -180,11 +180,29 @@ TrexStatelessDpUpdate::clone() { return new_msg; } +/************************* + barrier message + ************************/ + +bool +TrexStatelessDpBarrier::handle(TrexStatelessDpCore *dp_core) { + dp_core->barrier(m_port_id, m_event_id); + return true; +} + +TrexStatelessCpToDpMsgBase * +TrexStatelessDpBarrier::clone() { + + TrexStatelessCpToDpMsgBase *new_msg = new TrexStatelessDpBarrier(m_port_id, m_event_id); + + return new_msg; +} + /************************* messages from DP to CP **********************/ bool TrexDpPortEventMsg::handle() { TrexStatelessPort *port = get_stateless_obj()->get_port_by_id(m_port_id); - port->get_dp_events().handle_event(m_event_type, m_thread_id, m_event_id); + port->get_dp_events().on_core_reporting_in(m_event_id, m_thread_id); return (true); } |