Working version. temporary send_node that duplicates the mbuf data

1 files changed, 12 insertions, 0 deletions

diff --git a/src/stateless/dp/trex_stateless_dp_core.cpp b/src/stateless/dp/trex_stateless_dp_core.cpp
index 833fb6e1..9c05c16b 100644
--- a/src/stateless/dp/trex_stateless_dp_core.cpp
+++ b/src/stateless/dp/trex_stateless_dp_core.cpp
@@ -211,6 +211,18 @@ std::string CGenNodeStateless::get_stream_state_str(stream_state_t stream_state)
     return(res);
 }
 
+rte_mbuf_t * CGenNodeStateless::alloc_flow_stat_mbuf(rte_mbuf_t *m) {
+    //?????????
+    // temp implementation. Just copy the entire mbuf
+    rte_mbuf_t *m_new = CGlobalInfo::pktmbuf_alloc( get_socket_id(), m->data_len );
+    /* TBD remove this, should handle cases of error */
+    assert(m_new);
+    char *p = rte_pktmbuf_mtod(m, char*);
+    char *p_new = rte_pktmbuf_append(m_new, m->data_len);
+    memcpy(p_new , p, m->data_len);
+
+    return m_new;
+}
 
 rte_mbuf_t   * CGenNodeStateless::alloc_node_with_vm(){