1 files changed, 55 insertions, 15 deletions

diff --git a/src/stateless/cp/trex_stateless_port.cpp b/src/stateless/cp/trex_stateless_port.cpp
index 9bb20990..d4bc5c36 100644
--- a/src/stateless/cp/trex_stateless_port.cpp
+++ b/src/stateless/cp/trex_stateless_port.cpp
@@ -25,6 +25,7 @@ limitations under the License.
 #include <trex_streams_compiler.h>
 #include <common/basic_utils.h>
 #include <common/captureFile.h>
+#include "trex_stateless_rx_defs.h"
 
 #include <string>
 
@@ -156,9 +157,9 @@ private:
 TrexStatelessPort::TrexStatelessPort(uint8_t port_id, const TrexPlatformApi *api) : m_dp_events(this) {
     std::vector<std::pair<uint8_t, uint8_t>> core_pair_list;
 
-    m_port_id = port_id;
-    m_port_state = PORT_STATE_IDLE;
-    m_platform_api = api;
+    m_port_id            = port_id;
+    m_port_state         = PORT_STATE_IDLE;
+    m_platform_api       = api;
 
     /* get the platform specific data */
     api->get_interface_info(port_id, m_api_info);
@@ -584,10 +585,9 @@ TrexStatelessPort::get_max_stream_id() const {
 }
 
 void
-TrexStatelessPort::get_properties(std::string &driver, uint32_t &speed) {
+TrexStatelessPort::get_properties(std::string &driver) {
 
     driver = m_api_info.driver_name;
-    speed = m_platform_api->getPortAttrObj(m_port_id)->get_link_speed();
 }
 
 bool
@@ -888,16 +888,6 @@ TrexStatelessPort::get_port_effective_rate(double &pps,
 }
 
 void
-TrexStatelessPort::get_macaddr(std::string &hw_macaddr,
-                               std::string &src_macaddr,
-                               std::string &dst_macaddr) {
-
-    utl_macaddr_to_str(m_api_info.mac_info.hw_macaddr, hw_macaddr);
-    utl_macaddr_to_str(m_api_info.mac_info.src_macaddr, src_macaddr);
-    utl_macaddr_to_str(m_api_info.mac_info.dst_macaddr, dst_macaddr);
-}
-
-void
 TrexStatelessPort::get_pci_info(std::string &pci_addr, int &numa_node) {
     pci_addr  = m_api_info.pci_addr;
     numa_node = m_api_info.numa_node;
@@ -944,6 +934,56 @@ TrexStatelessPort::remove_and_delete_all_streams() {
     }
 }
 
+void 
+TrexStatelessPort::start_rx_capture(const std::string &pcap_filename, uint64_t limit) {
+
+    m_rx_features_info.m_rx_capture_info.enable(pcap_filename, limit);
+
+    TrexStatelessCpToRxMsgBase *msg = new TrexStatelessRxStartCapture(m_port_id, m_rx_features_info.m_rx_capture_info);
+    send_message_to_rx(msg);
+}
+
+void
+TrexStatelessPort::stop_rx_capture() {
+    TrexStatelessCpToRxMsgBase *msg = new TrexStatelessRxStopCapture(m_port_id);
+    send_message_to_rx(msg);
+    m_rx_features_info.m_rx_capture_info.disable();
+}
+
+void 
+TrexStatelessPort::start_rx_queue(uint64_t size) {
+
+    m_rx_features_info.m_rx_queue_info.enable(size);
+
+    TrexStatelessCpToRxMsgBase *msg = new TrexStatelessRxStartQueue(m_port_id, m_rx_features_info.m_rx_queue_info);
+    send_message_to_rx(msg);
+}
+
+void
+TrexStatelessPort::stop_rx_queue() {
+    TrexStatelessCpToRxMsgBase *msg = new TrexStatelessRxStopQueue(m_port_id);
+    send_message_to_rx(msg);
+    m_rx_features_info.m_rx_queue_info.disable();
+}
+
+
+RxPacketBuffer *
+TrexStatelessPort::get_rx_queue_pkts() {
+
+    if (m_rx_features_info.m_rx_queue_info.is_empty()) {
+        return NULL;
+    }
+
+    /* ask RX core for the pkt queue */
+    TrexStatelessMsgReply<RxPacketBuffer *> msg_reply;
+
+    TrexStatelessCpToRxMsgBase *msg = new TrexStatelessRxQueueGetPkts(m_port_id, msg_reply);
+    send_message_to_rx(msg);
+
+    RxPacketBuffer *pkt_buffer = msg_reply.wait_for_reply();
+    return pkt_buffer;
+}
+
 /************* Trex Port Owner **************/
 
 TrexPortOwner::TrexPortOwner() {