summaryrefslogtreecommitdiffstats
path: root/src/stateless
diff options
context:
space:
mode:
authorIdo Barnea <ibarnea@cisco.com>2016-12-01 14:25:07 +0200
committerIdo Barnea <ibarnea@cisco.com>2016-12-04 11:24:28 +0200
commitc9028e25cd49b9bf69ea72432429f3d3a149153e (patch)
treec5bbdc98a945fab02d28fbe6680938b7d21e4013 /src/stateless
parent9464519d16d203f0d0ca33e8079c5735eb1c4c36 (diff)
cleanup
Signed-off-by: Ido Barnea <ibarnea@cisco.com>
Diffstat (limited to 'src/stateless')
-rw-r--r--src/stateless/rx/trex_stateless_rx_core.cpp48
1 files changed, 0 insertions, 48 deletions
diff --git a/src/stateless/rx/trex_stateless_rx_core.cpp b/src/stateless/rx/trex_stateless_rx_core.cpp
index df5e8e8e..d6dcd3f4 100644
--- a/src/stateless/rx/trex_stateless_rx_core.cpp
+++ b/src/stateless/rx/trex_stateless_rx_core.cpp
@@ -232,54 +232,6 @@ void CRxCoreStateless::capture_pkt(rte_mbuf_t *m) {
}
-#if 0
-//??????? remove
-// In VM setup, handle packets coming as messages from DP cores.
-void CRxCoreStateless::handle_rx_queue_msgs(uint8_t thread_id, CNodeRing * r) {
- while ( true ) {
- CGenNode * node;
- if ( r->Dequeue(node) != 0 ) {
- break;
- }
- assert(node);
-
- CGenNodeMsgBase * msg = (CGenNodeMsgBase *)node;
- CGenNodeLatencyPktInfo * l_msg;
- uint8_t msg_type = msg->m_msg_type;
- uint8_t rx_port_index;
-
-
- switch (msg_type) {
- case CGenNodeMsgBase::LATENCY_PKT:
- l_msg = (CGenNodeLatencyPktInfo *)msg;
- assert(l_msg->m_latency_offset == 0xdead);
- rx_port_index = (thread_id << 1) + (l_msg->m_dir & 1);
- assert( rx_port_index < m_max_ports );
-
- m_rx_port_mngr[rx_port_index].handle_pkt((rte_mbuf_t *)l_msg->m_pkt);
-
- if (m_capture)
- capture_pkt((rte_mbuf_t *)l_msg->m_pkt);
- rte_pktmbuf_free((rte_mbuf_t *)l_msg->m_pkt);
- break;
- default:
- printf("ERROR latency-thread message type is not valid %d \n", msg_type);
- assert(0);
- }
-
- CGlobalInfo::free_node(node);
- }
-}
-
-int CRxCoreStateless::process_all_pending_pkts(bool flush_rx) {
- int total_pkts = 0;
- for (int i = 0; i < m_max_ports; i++) {
- total_pkts += m_rx_port_mngr[i].process_all_pending_pkts(flush_rx);
- }
- return total_pkts;
-}
-
-
void CRxCoreStateless::reset_rx_stats(uint8_t port_id) {
m_rx_port_mngr[port_id].clear_stats();
}