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
|
/* Copyright (c) 2008, 2010, Oracle and/or its affiliates. All rights reserved.
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; version 2 of the License.
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
along with this program; if not, write to the Free Software Foundation,
51 Franklin Street, Suite 500, Boston, MA 02110-1335 USA */
#ifndef PFS_STAT_H
#define PFS_STAT_H
/**
@file storage/perfschema/pfs_stat.h
Statistics (declarations).
*/
/**
@addtogroup Performance_schema_buffers
@{
*/
/** Usage statistics chain, for a single value and its aggregates. */
struct PFS_single_stat_chain
{
/**
Control flag.
Statistics are aggregated only if the control flag is true.
*/
bool *m_control_flag;
/** Next link in the statistics chain. */
struct PFS_single_stat_chain *m_parent;
/** Count of values. */
ulonglong m_count;
/** Sum of values. */
ulonglong m_sum;
/** Minimum value. */
ulonglong m_min;
/** Maximum value. */
ulonglong m_max;
};
/**
Reset a single statistic link.
Only the current link is reset, parents are not affected.
@param stat the statistics link to reset
*/
inline void reset_single_stat_link(PFS_single_stat_chain *stat)
{
stat->m_count= 0;
stat->m_sum= 0;
stat->m_min= ULONGLONG_MAX;
stat->m_max= 0;
}
/**
Aggregate a value to a statistic chain.
@param stat the aggregated statistic chain
@param value the value to aggregate
*/
inline void aggregate_single_stat_chain(PFS_single_stat_chain *stat,
ulonglong value)
{
do
{
if (*stat->m_control_flag)
{
stat->m_count++;
stat->m_sum+= value;
if (stat->m_min > value)
stat->m_min= value;
if (stat->m_max < value)
stat->m_max= value;
}
stat= stat->m_parent;
}
while (stat);
}
/**
Increment the value counts in a statistic chain.
Used for instruments that are 'ENABLED' but not 'TIMED'.
@param stat the aggregated statistic chain
*/
inline void increment_single_stat_chain(PFS_single_stat_chain *stat)
{
do
{
if (*stat->m_control_flag)
stat->m_count++;
stat= stat->m_parent;
}
while (stat);
}
/** Statistics for COND usage. */
struct PFS_cond_stat
{
/** Number of times a condition was signalled. */
ulonglong m_signal_count;
/** Number of times a condition was broadcasted. */
ulonglong m_broadcast_count;
};
/** Statistics for FILE usage. */
struct PFS_file_stat
{
/** Number of current open handles. */
ulong m_open_count;
/** Count of READ operations. */
ulonglong m_count_read;
/** Count of WRITE operations. */
ulonglong m_count_write;
/** Number of bytes read. */
ulonglong m_read_bytes;
/** Number of bytes written. */
ulonglong m_write_bytes;
};
/**
Reset file statistic.
@param stat the statistics to reset
*/
inline void reset_file_stat(PFS_file_stat *stat)
{
stat->m_open_count= 0;
stat->m_count_read= 0;
stat->m_count_write= 0;
stat->m_read_bytes= 0;
stat->m_write_bytes= 0;
}
/** @} */
#endif
|
