From 051a334b6f57280faa9dd90eeab922fb51f3c89e Mon Sep 17 00:00:00 2001 From: imarom Date: Wed, 30 Nov 2016 13:00:54 +0200 Subject: reply to messages Signed-off-by: imarom --- .../messaging/trex_stateless_messaging.cpp | 29 ++++++++++++++++------ 1 file changed, 21 insertions(+), 8 deletions(-) (limited to 'src/stateless/messaging/trex_stateless_messaging.cpp') diff --git a/src/stateless/messaging/trex_stateless_messaging.cpp b/src/stateless/messaging/trex_stateless_messaging.cpp index cad4fe7a..53d5a87e 100644 --- a/src/stateless/messaging/trex_stateless_messaging.cpp +++ b/src/stateless/messaging/trex_stateless_messaging.cpp @@ -259,9 +259,10 @@ bool TrexStatelessRxQuit::handle (CRxCoreStateless *rx_core) { bool TrexStatelessRxStartCapture::handle(CRxCoreStateless *rx_core) { - rx_core->start_recorder(m_port_id, m_pcap_filename, m_limit, m_shared_counter); + rx_core->start_recorder(m_port_id, m_pcap_filename, m_limit); - set_reply(true); + /* mark as done */ + m_reply.set_reply(true); return true; } @@ -275,10 +276,10 @@ TrexStatelessRxStopCapture::handle(CRxCoreStateless *rx_core) { bool TrexStatelessRxStartQueue::handle(CRxCoreStateless *rx_core) { - rx_core->start_queue(m_port_id, m_size, m_shared_counter); + rx_core->start_queue(m_port_id, m_size); /* mark as done */ - set_reply(true); + m_reply.set_reply(true); return true; } @@ -292,12 +293,24 @@ TrexStatelessRxStopQueue::handle(CRxCoreStateless *rx_core) { -bool TrexStatelessRxQueueGetPkts::handle(CRxCoreStateless *rx_core) { - RXPacketBuffer *pkt_buffer = rx_core->get_rx_queue_pkts(m_port_id); - assert(pkt_buffer); +bool +TrexStatelessRxQueueGetPkts::handle(CRxCoreStateless *rx_core) { + const RXPacketBuffer *pkt_buffer = rx_core->get_rx_queue_pkts(m_port_id); /* set the reply */ - set_reply(pkt_buffer); + m_reply.set_reply(pkt_buffer); return true; } + + +bool +TrexStatelessRxFeaturesToJson::handle(CRxCoreStateless *rx_core) { + Json::Value output = rx_core->get_rx_port_mngr(m_port_id).to_json(); + + /* set the reply */ + m_reply.set_reply(output); + + return true; +} + -- cgit 1.2.3-korg