1 files changed, 95 insertions, 10 deletions
diff --git a/src/stateless/dp/trex_stateless_dp_core.h b/src/stateless/dp/trex_stateless_dp_core.h
index 4b09b752..d95f7eeb 100644
--- a/src/stateless/dp/trex_stateless_dp_core.h
+++ b/src/stateless/dp/trex_stateless_dp_core.h
@@ -21,23 +21,108 @@ limitations under the License.
 #ifndef __TREX_STATELESS_DP_CORE_H__
 #define __TREX_STATELESS_DP_CORE_H__
 
-#include <stdint.h>
+#include <vector>
+
+#include <msg_manager.h>
+#include <pal_utl.h>
+
+class TrexStatelessCpToDpMsgBase;
+class TrexStatelessDpStart;
+class CFlowGenListPerThread;
+class CGenNode;
+class TrexStreamsCompiledObj;
+class CGenNodeStateless;
 
-/**
- * stateless DP core object
- * 
- */
 class TrexStatelessDpCore {
+
 public:
 
-    TrexStatelessDpCore(uint8_t core_id);
+    /* states */
+    enum state_e {
+        STATE_IDLE,
+        STATE_TRANSMITTING
+    };
+
+    TrexStatelessDpCore(uint8_t thread_id, CFlowGenListPerThread *core);
+
+    /**
+     * launch the stateless DP core code
+     * 
+     */
+    void start();
+
+    /**
+     * handle pkt event
+     * 
+     * @author imarom (27-Oct-15)
+     */
+    void handle_pkt_event(CGenNode *node);
+
+    /**
+     * dummy traffic creator
+     * 
+     * @author imarom (27-Oct-15)
+     * 
+     * @param pkt 
+     * @param pkt_len 
+     */
+    void start_traffic(TrexStreamsCompiledObj *obj);
+
+    /**
+     * stop all traffic for this core
+     * 
+     */
+    void stop_traffic();
+
+    /**
+     * check for and handle messages from CP
+     * 
+     * @author imarom (27-Oct-15)
+     */
+    void periodic_check_for_cp_messages() {
+        // doing this inline for performance reasons
 
-    /* starts the DP core run */
-    void run();
+        /* fast path */
+        if ( likely ( m_ring_from_cp->isEmpty() ) ) {
+            return;
+        }
+
+        while ( true ) {
+            CGenNode * node = NULL;
+            if (m_ring_from_cp->Dequeue(node) != 0) {
+                break;
+            }
+            assert(node);
+
+            TrexStatelessCpToDpMsgBase * msg = (TrexStatelessCpToDpMsgBase *)node;
+            handle_cp_msg(msg);
+        }
+
+    }
 
 private:
-    void test_inject_dummy_pkt();
-    uint8_t m_core_id;
+    /**
+     * handles a CP to DP message
+     * 
+     * @author imarom (27-Oct-15)
+     * 
+     * @param msg 
+     */
+    void handle_cp_msg(TrexStatelessCpToDpMsgBase *msg);
+
+    void add_cont_stream(double pps, const uint8_t *pkt, uint16_t pkt_len);
+
+    uint8_t              m_thread_id;
+    state_e              m_state;
+    CNodeRing           *m_ring_from_cp;
+    CNodeRing           *m_ring_to_cp;
+
+    /* holds the current active nodes */
+    std::vector<CGenNodeStateless *> m_active_nodes;
+
+    /* pointer to the main object */
+    CFlowGenListPerThread *m_core;
 };
 
 #endif /* __TREX_STATELESS_DP_CORE_H__ */
+