blob: 0390ce102a99ea3081c8bac3f9bbbb16240518d7 (
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
#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"
#include <string>
/* messages from CP->DP Ids */
struct CGenNodeMsgBase {
enum {
NAT_FIRST = 7,
LATENCY_PKT = 8,
} msg_types;
public:
uint8_t m_msg_type; /* msg type */
};
/*
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,std::string name);
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);
void Delete();
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 */
static CMsgIns * m_ins;
};
#endif
|
