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
|
