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
|
#include "eemcs_statistics.h"
EEMCS_STATISTICS *eemcs_statistics[MAX_EXT_MD_NUM];
void eemcs_update_statistics_number(int md_id, int port, int tx_rx, int type, int number){
if (port >=CCCI_PORT_NUM_MAX){
return;
}
//Update statistics
switch (type){
case NORMAL:
{
eemcs_statistics[md_id]->port[port].cnt[tx_rx] = number;
eemcs_statistics[md_id]->port_total[port].cnt[tx_rx] = number;
break;
}
case DROP:
{
eemcs_statistics[md_id]->port[port].drop[tx_rx] = number;
eemcs_statistics[md_id]->port_total[port].drop[tx_rx] = number;
break;
}
case QUEUE:
{
eemcs_statistics[md_id]->port[port].queue[tx_rx] = number;
if (eemcs_statistics[md_id]->port_total[port].queue[tx_rx]< number){
eemcs_statistics[md_id]->port_total[port].queue[tx_rx]= number;
}
break;
}
}
}
void eemcs_update_statistics(int md_id, int port, int tx_rx, int type){
struct timeval tv;
if (port >=CCCI_PORT_NUM_MAX){
return;
}
if (eemcs_statistics[md_id]->start == 0){
return;
}
do_gettimeofday(&tv);
//Check if need to re-cal
if(tv.tv_sec - eemcs_statistics[md_id]->time.tv_sec > eemcs_statistics[md_id]->inteval){
eemcs_statistics_reset();
eemcs_statistics[md_id]->time = tv;
}
//Update statistics
switch (type){
case NORMAL:
{
eemcs_statistics[md_id]->port[port].cnt[tx_rx]++;
eemcs_statistics[md_id]->port_total[port].cnt[tx_rx]++;
break;
}
case DROP:
{
eemcs_statistics[md_id]->port[port].drop[tx_rx]++;
eemcs_statistics[md_id]->port_total[port].drop[tx_rx]++;
break;
}
default:
{
break;
}
}
}
void eemcs_statistics_reset(){
int md_id = 0;
for (md_id=0; md_id< MAX_EXT_MD_NUM; md_id++){
if(eemcs_statistics[md_id] != NULL){
int i = 0;
for (i=0; i< CCCI_PORT_NUM_MAX; i++){
memset(&eemcs_statistics[md_id]->port[i], 0, sizeof(CCCI_PORT_STATISTICS));
}
}
}
}
int eemcs_statistics_init()
{
int md_id = 0;
for (md_id=0; md_id< MAX_EXT_MD_NUM; md_id++){
eemcs_statistics[md_id] = kmalloc(sizeof(EEMCS_STATISTICS), GFP_KERNEL);
if(eemcs_statistics[md_id] != NULL){
memset(eemcs_statistics[md_id], 0, sizeof(EEMCS_STATISTICS));
eemcs_statistics[md_id]->inteval = 10;
eemcs_statistics[md_id]->start = 1;
do_gettimeofday(&eemcs_statistics[md_id]->time);
}
}
return KAL_SUCCESS;
}
void eemcs_statistics_exit()
{
int md_id = 0;
for (md_id=0; md_id< MAX_EXT_MD_NUM; md_id++){
if(eemcs_statistics[md_id] != NULL){
kfree(eemcs_statistics[md_id]);
eemcs_statistics[md_id] = NULL;
}
}
return;
}
|
