1 files changed, 17 insertions, 3 deletions
diff --git a/src/msg_manager.h b/src/msg_manager.h
index b25660bb..8958f826 100755
--- a/src/msg_manager.h
+++ b/src/msg_manager.h
@@ -23,12 +23,20 @@ limitations under the License.
 
 
 #include "CRing.h"
+#include <string>
 
 
 /* messages from CP->DP Ids */
 
-#define NAT_MSG             (7)
-#define LATENCY_PKT_SEND_MSG    (8)
+struct CGenNodeMsgBase  {
+    enum {
+        NAT_FIRST     = 7,
+        LATENCY_PKT   = 8,
+    } msg_types;
+
+public:
+    uint8_t       m_msg_type; /* msg type */
+};
 
 /*
 
@@ -71,7 +79,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 +102,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 */