summaryrefslogtreecommitdiffstats
path: root/src/msg_manager.h
blob: b25660bb562cf8a20f8d475fff651b5840295732 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
#ifndef CMSG_MANAGER_H
#define CMSG_MANAGER_H
/*
 Hanoh Haim
 Cisco Systems, Inc.
*/

/*
Copyright (c) 2015-2015 Cisco Systems, Inc.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/


#include "CRing.h"


/* messages from CP->DP Ids */

#define NAT_MSG             (7)
#define LATENCY_PKT_SEND_MSG    (8)

/*

e.g DP with 4 threads 
will look like this 

      cp_to_dp  

      master :push
      dpx    : pop
                 
      -       --> dp0
cp    -       --> dp1
      -       --> dp2
      -       --> dp3

      dp_to_cp 

      cp     : pop
      dpx    : push

      
       <-      -- dp0
cp     <-      -- dp1
       <-      -- dp2
       <-      -- dp3


*/  

class CGenNode ;
typedef CTRingSp<CGenNode>  CNodeRing;

/* CP == latency thread 
   DP == traffic pkt generator */
class CMessagingManager {
public:
    CMessagingManager(){
        m_cp_to_dp=0;
        m_dp_to_cp=0;
        m_num_dp_threads=0;
    }
    bool Create(uint8_t num_dp_threads);
    void Delete();
    CNodeRing * getRingCpToDp(uint8_t thread_id);
    CNodeRing * getRingDpToCp(uint8_t thread_id);
    uint8_t get_num_threads(){
        return (m_num_dp_threads);
    }
private:
    CNodeRing * m_cp_to_dp;
    CNodeRing * m_dp_to_cp;
    uint8_t     m_num_dp_threads;
};


class CMsgIns {
public:
    static  CMsgIns  * Ins();
    static  void Free();
    bool Create(uint8_t num_threads);
public:
    CMessagingManager * getRxDp(){
        return (&m_rx_dp);
    }
    uint8_t get_num_threads(){
        return (m_rx_dp.get_num_threads());
    }

private:
    CMessagingManager m_rx_dp;

private:
    /* one instance */
    static  CMsgIns  * m_ins; 
};

#endif