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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
|
/* 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_INSTR_CLASS_H
#define PFS_INSTR_CLASS_H
#include "mysql_com.h" /* NAME_LEN */
/**
@file storage/perfschema/pfs_instr_class.h
Performance schema instruments meta data (declarations).
*/
/**
Maximum length of an instrument name.
For example, 'wait/sync/mutex/sql/LOCK_open' is an instrument name.
*/
#define PFS_MAX_INFO_NAME_LENGTH 128
/**
Maximum length of the 'full' prefix of an instrument name.
For example, for the instrument name 'wait/sync/mutex/sql/LOCK_open',
the full prefix is 'wait/sync/mutex/sql/', which in turn derives from
a prefix 'wait/sync/mutex' for mutexes, and a category of 'sql' for mutexes
of the sql layer in the server.
*/
#define PFS_MAX_FULL_PREFIX_NAME_LENGTH 32
#include <my_global.h>
#include <mysql/psi/psi.h>
#include "pfs_lock.h"
#include "pfs_stat.h"
/**
@addtogroup Performance_schema_buffers
@{
*/
extern my_bool pfs_enabled;
/** Key, naming a synch instrument (mutex, rwlock, cond). */
typedef unsigned int PFS_sync_key;
/** Key, naming a thread instrument. */
typedef unsigned int PFS_thread_key;
/** Key, naming a file instrument. */
typedef unsigned int PFS_file_key;
struct PFS_thread;
/** Information for all instrumentation. */
struct PFS_instr_class
{
/** Instrument name. */
char m_name[PFS_MAX_INFO_NAME_LENGTH];
/** Length in bytes of @c m_name. */
uint m_name_length;
/** Instrument flags. */
int m_flags;
/** True if this instrument is enabled. */
bool m_enabled;
/** True if this instrument is timed. */
bool m_timed;
/** Wait statistics chain. */
PFS_single_stat_chain m_wait_stat;
};
/** Instrumentation metadata for a MUTEX. */
struct PFS_mutex_class : public PFS_instr_class
{
/**
Lock statistics chain.
This statistic is not exposed in user visible tables yet.
*/
PFS_single_stat_chain m_lock_stat;
/** Self index in @c mutex_class_array. */
uint m_index;
};
/** Instrumentation metadata for a RWLOCK. */
struct PFS_rwlock_class : public PFS_instr_class
{
/**
Read lock statistics chain.
This statistic is not exposed in user visible tables yet.
*/
PFS_single_stat_chain m_read_lock_stat;
/**
Write lock statistics chain.
This statistic is not exposed in user visible tables yet.
*/
PFS_single_stat_chain m_write_lock_stat;
/** Self index in @c rwlock_class_array. */
uint m_index;
};
/** Instrumentation metadata for a COND. */
struct PFS_cond_class : public PFS_instr_class
{
/**
Condition usage statistics.
This statistic is not exposed in user visible tables yet.
*/
PFS_cond_stat m_cond_stat;
/** Self index in @c cond_class_array. */
uint m_index;
};
/** Instrumentation metadata of a thread. */
struct PFS_thread_class
{
/** Thread instrument name. */
char m_name[PFS_MAX_INFO_NAME_LENGTH];
/** Length in bytes of @c m_name. */
uint m_name_length;
/** True if this thread instrument is enabled. */
bool m_enabled;
};
#define PFS_TABLESHARE_HASHKEY_SIZE (NAME_LEN + 1 + NAME_LEN + 1)
/** Key identifying a table share. */
struct PFS_table_share_key
{
/**
Hash search key.
This has to be a string for LF_HASH,
the format is "<schema_name><0x00><object_name><0x00>"
@see create_table_def_key
*/
char m_hash_key[PFS_TABLESHARE_HASHKEY_SIZE];
/** Length in bytes of @c m_hash_key. */
uint m_key_length;
};
/** Instrumentation metadata for a table share. */
struct PFS_table_share
{
/** Internal lock. */
pfs_lock m_lock;
/** Search key. */
PFS_table_share_key m_key;
/** Schema name. */
const char *m_schema_name;
/** Length in bytes of @c m_schema_name. */
uint m_schema_name_length;
/** Table name. */
const char *m_table_name;
/** Length in bytes of @c m_table_name. */
uint m_table_name_length;
/** Wait statistics chain. */
PFS_single_stat_chain m_wait_stat;
/** True if this table instrument is enabled. */
bool m_enabled;
/** True if this table instrument is timed. */
bool m_timed;
/** True if this table instrument is aggregated. */
bool m_aggregated;
};
/**
Instrument controlling all tables.
This instrument is used as a default when there is no
entry present in SETUP_OBJECTS.
*/
extern PFS_instr_class global_table_class;
/** Instrumentation metadata for a file. */
struct PFS_file_class : public PFS_instr_class
{
/** File usage statistics. */
PFS_file_stat m_file_stat;
/** Self index in @c file_class_array. */
uint m_index;
};
int init_sync_class(uint mutex_class_sizing,
uint rwlock_class_sizing,
uint cond_class_sizing);
void cleanup_sync_class();
int init_thread_class(uint thread_class_sizing);
void cleanup_thread_class();
int init_table_share(uint table_share_sizing);
void cleanup_table_share();
int init_table_share_hash();
void cleanup_table_share_hash();
int init_file_class(uint file_class_sizing);
void cleanup_file_class();
PFS_sync_key register_mutex_class(const char *name, uint name_length,
int flags);
PFS_sync_key register_rwlock_class(const char *name, uint name_length,
int flags);
PFS_sync_key register_cond_class(const char *name, uint name_length,
int flags);
PFS_thread_key register_thread_class(const char *name, uint name_length,
int flags);
PFS_file_key register_file_class(const char *name, uint name_length,
int flags);
PFS_mutex_class *find_mutex_class(PSI_mutex_key key);
PFS_mutex_class *sanitize_mutex_class(PFS_mutex_class *unsafe);
PFS_rwlock_class *find_rwlock_class(PSI_rwlock_key key);
PFS_rwlock_class *sanitize_rwlock_class(PFS_rwlock_class *unsafe);
PFS_cond_class *find_cond_class(PSI_cond_key key);
PFS_cond_class *sanitize_cond_class(PFS_cond_class *unsafe);
PFS_thread_class *find_thread_class(PSI_thread_key key);
PFS_thread_class *sanitize_thread_class(PFS_thread_class *unsafe);
PFS_file_class *find_file_class(PSI_file_key key);
PFS_file_class *sanitize_file_class(PFS_file_class *unsafe);
const char *sanitize_table_schema_name(const char *unsafe);
const char *sanitize_table_object_name(const char *unsafe);
PFS_table_share *find_or_create_table_share(PFS_thread *thread,
const char *schema_name,
uint schema_name_length,
const char *table_name,
uint table_name_length);
PFS_table_share *sanitize_table_share(PFS_table_share *unsafe);
extern ulong mutex_class_max;
extern ulong mutex_class_lost;
extern ulong rwlock_class_max;
extern ulong rwlock_class_lost;
extern ulong cond_class_max;
extern ulong cond_class_lost;
extern ulong thread_class_max;
extern ulong thread_class_lost;
extern ulong file_class_max;
extern ulong file_class_lost;
extern ulong table_share_max;
extern ulong table_share_lost;
extern PFS_table_share *table_share_array;
void reset_instrument_class_waits();
void reset_file_class_io();
/** @} */
#endif
|