From 587f97686900f757b173469a2b231ede6705c568 Mon Sep 17 00:00:00 2001 From: Hanoh Haim Date: Mon, 26 Oct 2015 16:49:19 +0200 Subject: stateless dp works with static packet --- src/msg_manager.h | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'src/msg_manager.h') diff --git a/src/msg_manager.h b/src/msg_manager.h index b25660bb..6308eb1b 100755 --- a/src/msg_manager.h +++ b/src/msg_manager.h @@ -23,6 +23,7 @@ limitations under the License. #include "CRing.h" +#include /* messages from CP->DP Ids */ @@ -71,7 +72,7 @@ public: m_dp_to_cp=0; m_num_dp_threads=0; } - bool Create(uint8_t num_dp_threads); + bool Create(uint8_t num_dp_threads,std::string name); void Delete(); CNodeRing * getRingCpToDp(uint8_t thread_id); CNodeRing * getRingDpToCp(uint8_t thread_id); @@ -94,12 +95,18 @@ public: CMessagingManager * getRxDp(){ return (&m_rx_dp); } + CMessagingManager * getCpDp(){ + return (&m_cp_dp); + } + uint8_t get_num_threads(){ return (m_rx_dp.get_num_threads()); } private: CMessagingManager m_rx_dp; + CMessagingManager m_cp_dp; + private: /* one instance */ -- cgit