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
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
/* Copyright (C) 2007-2015 Open Information Security Foundation
*
* You can copy, redistribute or modify this Program under the terms of
* the GNU General Public License version 2 as published by the Free
* Software Foundation.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* version 2 along with this program; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
* 02110-1301, USA.
*/
/**
* \file
*
* \author Anoop Saldanha <anoopsaldanha@gmail.com>
* \author Victor Julien <victor@inliniac.net>
*/
#ifndef __COUNTERS_H__
#define __COUNTERS_H__
/* forward declaration of the ThreadVars structure */
struct ThreadVars_;
/**
* \brief Container to hold the counter variable
*/
typedef struct StatsCounter_ {
int type;
/* local id for this counter in this thread */
uint16_t id;
/* global id, used in output */
uint16_t gid;
/* counter value(s): copies from the 'private' counter */
uint64_t value; /**< sum of updates/increments, or 'set' value */
uint64_t updates; /**< number of updates (for avg) */
/* when using type STATS_TYPE_Q_FUNC this function is called once
* to get the counter value, regardless of how many threads there are. */
uint64_t (*Func)(void);
/* name of the counter */
const char *name;
/* the next perfcounter for this tv's tm instance */
struct StatsCounter_ *next;
} StatsCounter;
/**
* \brief Stats Context for a ThreadVars instance
*/
typedef struct StatsPublicThreadContext_ {
/* flag set by the wakeup thread, to inform the client threads to sync */
uint32_t perf_flag;
/* pointer to the head of a list of counters assigned under this context */
StatsCounter *head;
/* holds the total no of counters already assigned for this perf context */
uint16_t curr_id;
/* mutex to prevent simultaneous access during update_counter/output_stat */
SCMutex m;
} StatsPublicThreadContext;
/**
* \brief Storage for local counters, with a link to the public counter used
* for syncs
*/
typedef struct StatsLocalCounter_ {
/* pointer to the counter that corresponds to this local counter */
StatsCounter *pc;
/* local counter id of the above counter */
uint16_t id;
/* total value of the adds/increments, or exact value in case of 'set' */
uint64_t value;
/* no of times the local counter has been updated */
uint64_t updates;
} StatsLocalCounter;
/**
* \brief used to hold the private version of the counters registered
*/
typedef struct StatsPrivateThreadContext_ {
/* points to the array holding local counters */
StatsLocalCounter *head;
/* size of head array in elements */
uint32_t size;
int initialized;
} StatsPrivateThreadContext;
/* the initialization functions */
void StatsInit(void);
void StatsSetupPostConfig(void);
void StatsSpawnThreads(void);
void StatsRegisterTests(void);
/* functions used to free the resources alloted by the Stats API */
void StatsReleaseResources(void);
/* counter registration functions */
uint16_t StatsRegisterCounter(char *, struct ThreadVars_ *);
uint16_t StatsRegisterAvgCounter(char *, struct ThreadVars_ *);
uint16_t StatsRegisterMaxCounter(char *, struct ThreadVars_ *);
uint16_t StatsRegisterGlobalCounter(char *cname, uint64_t (*Func)(void));
/* functions used to update local counter values */
void StatsAddUI64(struct ThreadVars_ *, uint16_t, uint64_t);
void StatsSetUI64(struct ThreadVars_ *, uint16_t, uint64_t);
void StatsIncr(struct ThreadVars_ *, uint16_t);
/* utility functions */
int StatsUpdateCounterArray(StatsPrivateThreadContext *, StatsPublicThreadContext *);
uint64_t StatsGetLocalCounterValue(struct ThreadVars_ *, uint16_t);
int StatsSetupPrivate(struct ThreadVars_ *);
void StatsThreadCleanup(struct ThreadVars_ *);
#define StatsSyncCounters(tv) \
StatsUpdateCounterArray(&(tv)->perf_private_ctx, &(tv)->perf_public_ctx); \
#define StatsSyncCountersIfSignalled(tv) \
do { \
if ((tv)->perf_public_ctx.perf_flag == 1) { \
StatsUpdateCounterArray(&(tv)->perf_private_ctx, \
&(tv)->perf_public_ctx); \
} \
} while (0)
#ifdef BUILD_UNIX_SOCKET
#include <jansson.h>
TmEcode StatsOutputCounterSocket(json_t *cmd,
json_t *answer, void *data);
#endif
#endif /* __COUNTERS_H__ */
|
