1
/* Copyright (C) 2005 PrimeBase Technologies GmbH
5
* This program is free software; you can redistribute it and/or modify
6
* it under the terms of the GNU General Public License as published by
7
* the Free Software Foundation; either version 2 of the License, or
8
* (at your option) any later version.
10
* This program is distributed in the hope that it will be useful,
11
* but WITHOUT ANY WARRANTY; without even the implied warranty of
12
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13
* GNU General Public License for more details.
15
* You should have received a copy of the GNU General Public License
16
* along with this program; if not, write to the Free Software
17
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
19
* 2008-11-19 Paul McCullagh
24
#include "xt_config.h"
32
#include "strutil_xt.h"
35
//#define DEBUG_INTERRUPT
41
#define OPT_PASSWORD 3
42
#define OPT_DATABASE 4
46
#define OPT_PROTOCOL 8
49
#define OPT_HAS_VALUE 1
50
#define OPT_OPTIONAL 2
53
llong record_cache_size;
54
llong index_cache_size;
57
llong accumulative_values[XT_STAT_CURRENT_MAX];
64
} display_order[XT_STAT_CURRENT_MAX];
72
const char *opt_value_str;
76
{ OPT_HELP, '?', "help", 0,
77
"Prints help text", NULL, 0, false },
78
{ OPT_HOST, 'h', "host", OPT_HAS_VALUE,
79
"Connect to host", NULL, 0, false },
80
{ OPT_USER, 'u', "user", OPT_HAS_VALUE,
81
"User for login if not current user", NULL, 0, false },
82
{ OPT_PASSWORD, 'p', "password", OPT_HAS_VALUE | OPT_OPTIONAL,
83
"Password to use when connecting to server. If password is not given it's asked from the tty", NULL, 0, false },
84
{ OPT_DATABASE, 'd', "database", OPT_HAS_VALUE,
85
"Database to be used (pbxt or information_schema required), default is information_schema", "information_schema", 0, false },
86
{ OPT_PORT, 'P', "port", OPT_HAS_VALUE | OPT_INTEGER,
87
"Port number to use for connection", NULL, 3306, false },
88
{ OPT_SOCKET, 'S', "socket", OPT_HAS_VALUE,
89
"Socket file to use for connection", NULL, 0, false },
90
{ OPT_DELAY, 'D', "delay", OPT_HAS_VALUE | OPT_INTEGER,
91
"Delay in seconds between polls of the database", NULL, 1, false },
92
{ OPT_PROTOCOL, 0, "protocol", OPT_HAS_VALUE,
93
"Connection protocol to use: default/tcp/socket/pipe/memory", "default", MYSQL_PROTOCOL_DEFAULT, false },
94
{ OPT_DISPLAY, 0, "display", OPT_HAS_VALUE,
95
"Columns to display: use short names separated by |, partial match allowed", "time-msec,commt,row-ins,rec,ind,ilog,xlog,data,to,dirty", 0, false },
96
{ OPT_NONE, 0, NULL, 0, NULL, NULL, 0, false }
100
#define atoll _atoi64
103
void add_statistic(int stat)
105
/* Check if column has already been added: */
106
for (int i=0; i<columns_used; i++) {
107
if (display_order[i].do_statistic == stat)
110
display_order[columns_used].do_statistic = stat;
111
display_order[columns_used].do_combo = false;
115
void determine_display_order()
117
const char *cols = options[OPT_DISPLAY].opt_value_str;
118
char column_1[21], column_2[21];
120
bool add, added, add_combo;
121
XTStatMetaDataPtr meta, meta2;
123
if (strcmp(cols, "all") == 0)
124
cols = "time,xact,stat,rec,ind,ilog,xlog,data,to,sweep,scan,row";
128
while (*cols && *cols != '-' && *cols != ',') {
140
while (*cols && *cols != '-' && *cols != ',') {
153
if (strcmp(column_1, "ms") == 0)
154
strcpy(column_1, "msec");
155
if (strcmp(column_2, "ms") == 0)
156
strcpy(column_2, "msec");
158
if (strcmp(column_1, "syncs/ms") == 0) {
159
strcpy(column_1, "syncs");
162
if (strcmp(column_2, "syncs/ms") == 0) {
163
strcpy(column_2, "syncs");
168
for (i=0; i<XT_STAT_MAXIMUM; i++) {
169
meta = xt_get_stat_meta_data(xt_get_stat_meta_order(i));
171
if (strcmp(meta->sm_short_line_1, column_1) == 0) {
173
if (strcmp(meta->sm_short_line_2, column_2) == 0)
177
if (xt_get_stat_meta_order(i) != XT_STAT_XLOG_CACHE_USAGE)
181
else if (!column_2[0]) {
182
if (strcmp(meta->sm_short_line_2, column_1) == 0) {
183
/* XT_STAT_XLOG_CACHE_USAGE is ignored, unless explicity listed! */
184
if (xt_get_stat_meta_order(i) != XT_STAT_XLOG_CACHE_USAGE)
190
add_statistic(xt_get_stat_meta_order(i));
192
add_statistic(xt_get_stat_meta_order(i+1));
197
fprintf(stderr, "ERROR: No statistic matches display option: '%s-%s'\n", column_1, column_2);
199
fprintf(stderr, "ERROR: No statistic matches display option: '%s'\n", column_1);
200
fprintf(stderr, "Display options: %s\n", options[OPT_DISPLAY].opt_value_str);
205
/* Setup "combo" fields: */
206
for (i=0; i<columns_used; i++) {
207
meta = xt_get_stat_meta_data(display_order[i].do_statistic);
208
if (meta->sm_flags & XT_STAT_COMBO_FIELD) {
209
if (i+1 < columns_used) {
210
meta2 = xt_get_stat_meta_data(display_order[i+1].do_statistic);
211
if (meta2->sm_flags & XT_STAT_COMBO_FIELD_2) {
212
if (strcmp(meta->sm_short_line_1, meta2->sm_short_line_1) == 0)
213
display_order[i].do_combo = true;
220
void format_percent_value(char *buffer, double value, double perc)
222
value = value * (double) 100 / (double) perc;
224
sprintf(buffer, "%.0f", value);
226
sprintf(buffer, "%.1f", value);
228
if (buffer[3] == '.')
232
#define XT_1_K ((double) 1024)
233
#define XT_1_M ((double) 1024 * (double) 1024)
234
#define XT_1_G ((double) 1024 * (double) 1024 * (double) 1024)
235
#define XT_1_T ((double) 1024 * (double) 1024 * (double) 1024 * (double) 1024)
236
#define XT_10000_K ((double) 10000 * XT_1_K)
237
#define XT_10000_M ((double) 10000 * XT_1_M)
238
#define XT_10000_G ((double) 10000 * XT_1_G)
240
void format_byte_value(char *buffer, double value)
246
if (value < (double) 100000) {
247
/* byte value from 0 to 99999: */
248
sprintf(buffer, "%.0f", value);
252
if (value < XT_10000_K) {
253
dval = value / XT_1_K;
256
else if (value < XT_10000_M) {
257
dval = value / XT_1_M;
260
else if (value < XT_10000_G) {
261
dval = value / XT_1_G;
265
dval = value / XT_1_T;
269
if (dval < (double) 10.0)
270
sprintf(string, "%.2f", dval);
271
else if (dval < (double) 100.0)
272
sprintf(string, "%.1f", dval);
274
sprintf(string, "%.0f", dval);
275
if (string[3] == '.')
279
sprintf(buffer, "%s%c", string, ch);
288
void format_mini_count_value(char *buffer, double value)
294
if (value < (double) 100) {
295
/* Value from 0 to 99: */
296
sprintf(buffer, "%.0f", value);
300
if (value < (double) 1000) {
301
sprintf(buffer, "<t");
305
if (value < (double) 10000) {
306
/* Value is less than 1m */
307
dval = value / (double) 1000.0;
310
else if (value < (double) 1000000) {
311
sprintf(buffer, "<m");
314
else if (value < (double) 10000000) {
315
/* Value is less than 1b */
316
dval = value / (double) 1000000.0;
319
else if (value < (double) 1000000000) {
320
sprintf(buffer, "<b");
324
/* Value is greater than 1 billion */
325
dval = value / (double) 1000000000.0;
329
sprintf(string, "%1.0f", dval);
331
sprintf(buffer, "%s%c", string, ch);
334
#define XT_1_THOUSAND ((double) 1000)
335
#define XT_1_MILLION ((double) 1000 * (double) 1000)
336
#define XT_1_BILLION ((double) 1000 * (double) 1000 * (double) 1000)
337
#define XT_1_TRILLION ((double) 1000 * (double) 1000 * (double) 1000 * (double) 1000)
338
#define XT_10_THOUSAND ((double) 10 * (double) 1000)
339
#define XT_10_MILLION ((double) 10 * (double) 1000 * (double) 1000)
340
#define XT_10_BILLION ((double) 10 * (double) 1000 * (double) 1000 * (double) 1000)
341
#define XT_10_TRILLION ((double) 10 * (double) 1000 * (double) 1000 * (double) 1000 * (double) 1000)
343
void format_count_value(char *buffer, double value)
349
if (value < (double) 0) {
354
if (value < XT_10_THOUSAND) {
355
/* byte value from 0 to 99999: */
356
sprintf(buffer, "%.0f", value);
360
if (value < XT_10_MILLION) {
361
/* Value is less than 10 million */
362
dval = value / XT_1_THOUSAND;
365
else if (value < XT_10_BILLION) {
366
/* Value is less than 10 million */
367
dval = value / XT_1_MILLION;
370
else if (value < XT_10_TRILLION) {
371
/* Value is less than 10 trillion */
372
dval = value / XT_1_BILLION;
376
dval = value / XT_1_TRILLION;
380
if (dval < (double) 10.0)
381
sprintf(string, "%.2f", dval);
382
else if (dval < (double) 100.0)
383
sprintf(string, "%.1f", dval);
385
sprintf(string, "%.0f", dval);
386
if (string[3] == '.')
390
sprintf(buffer, "%s%c", string, ch);
398
printf("Usage: xtstat [ options ]\n");
399
printf("e.g. xtstat -D10 : Poll every 10 seconds\n");
401
printf("Options :-\n");
402
while (opt->opt_id != OPT_NONE) {
403
strcpy(command, opt->opt_name);
404
if (opt->opt_flags & OPT_HAS_VALUE) {
405
if (opt->opt_flags & OPT_OPTIONAL)
406
strcat(command, "[=value]");
408
strcat(command, "=value");
411
printf("-%c, --%-16s %s.\n", opt->opt_char, command, opt->opt_desc);
413
printf(" --%-16s %s.\n", command, opt->opt_desc);
418
void print_stat_key()
421
printf("K = Kilobytes (1,024 bytes)\n");
422
printf("M = Megabytes (1,048,576 bytes)\n");
423
printf("G = Gigabytes (1,073,741,024 bytes)\n");
424
printf("T = Terabytes (1,099,511,627,776 bytes)\n");
425
printf("t = thousands (1,000s)\n");
426
printf("m = millions (1,000,000s)\n");
427
printf("b = billions (1,000,000,000s)\n");
430
void print_stat_info()
432
XTStatMetaDataPtr meta;
436
printf("Statistics :-\n");
437
for (int i=0; i<XT_STAT_CURRENT_MAX; i++) {
438
meta = xt_get_stat_meta_data(i);
439
sprintf(desc, meta->sm_description, "milli");
440
sprintf(buffer, "%s-%s", meta->sm_short_line_1, meta->sm_short_line_2);
441
if (meta->sm_flags & XT_STAT_COMBO_FIELD) {
442
/* Combine next 2 fields: */
444
strcat(buffer, "/ms");
445
strcat(desc, "/time taken in milliseconds");
447
printf("%-13s %-21s - %s.\n", buffer, meta->sm_name, desc);
451
bool match_arg(char *what, const char *opt, char **value)
453
while (*what && *opt && isalpha(*what)) {
470
void parse_args(int argc, char **argv)
486
while (opt->opt_id != OPT_NONE) {
487
if (match_arg(ptr, opt->opt_name, &value)) {
489
opt->opt_value_str = value;
490
opt->opt_value_bool = true;
498
while (opt->opt_id != OPT_NONE) {
499
if (*ptr == opt->opt_char) {
502
opt->opt_value_str = ptr;
504
opt->opt_value_str = NULL;
508
opt->opt_value_str = ptr;
514
opt->opt_value_bool = true;
523
fprintf(stderr, "Unknown option: %s\n", argv[i]);
528
if (opt->opt_flags & OPT_HAS_VALUE) {
529
if (!(opt->opt_flags & OPT_OPTIONAL)) {
530
if (!opt->opt_value_str) {
531
fprintf(stderr, "Option requires a value: %s\n", argv[i]);
532
printf("Use --help for help on commands and usage\n");
538
if (opt->opt_value_str) {
539
fprintf(stderr, "Option does not accept a value: %s\n", argv[i]);
540
printf("Use --help for help on commands and usage\n");
545
if (opt->opt_value_str && (opt->opt_flags & OPT_INTEGER))
546
opt->opt_value_int = atoi(opt->opt_value_str);
548
if (opt->opt_id == OPT_HELP) {
559
#ifdef DEBUG_INTERRUPT
560
void interrupt_pbxt(MYSQL *conn)
564
if (mysql_query(conn, "show engine pbxt status")) {
565
fprintf(stderr, "%s\n", mysql_error(conn));
569
res = mysql_use_result(conn);
570
mysql_free_result(res);
574
static bool display_parameters(MYSQL *conn)
580
if (mysql_query(conn, "show variables like 'pbxt_%'"))
583
if (!(res = mysql_use_result(conn)))
586
/* output table name */
587
printf("-- PBXT System Variables --\n");
588
while ((row = mysql_fetch_row(res)) != NULL) {
589
if (strcmp(row[0], "pbxt_index_cache_size") == 0)
590
index_cache_size = xt_byte_size_to_int8(row[1]);
591
else if (strcmp(row[0], "pbxt_record_cache_size") == 0)
592
record_cache_size = xt_byte_size_to_int8(row[1]);
593
else if (strcmp(row[0], "pbxt_log_cache_size") == 0)
594
log_cache_size = xt_byte_size_to_int8(row[1]);
595
printf("%-29s= %s\n", row[0], row[1]);
598
mysql_free_result(res);
600
for (int i=0; i<XT_STAT_CURRENT_MAX; i++)
601
accumulative_values[i] = 0;
603
printf("Display options: %s\n", options[OPT_DISPLAY].opt_value_str);
607
static bool connect(MYSQL *conn)
611
if (strcasecmp(options[OPT_PROTOCOL].opt_value_str, "tcp") == 0)
612
type = MYSQL_PROTOCOL_TCP;
613
else if (strcasecmp(options[OPT_PROTOCOL].opt_value_str, "socket") == 0)
614
type = MYSQL_PROTOCOL_SOCKET;
615
else if (strcasecmp(options[OPT_PROTOCOL].opt_value_str, "pipe") == 0)
616
type = MYSQL_PROTOCOL_PIPE;
617
else if (strcasecmp(options[OPT_PROTOCOL].opt_value_str, "memory") == 0)
618
type = MYSQL_PROTOCOL_MEMORY;
620
type = MYSQL_PROTOCOL_DEFAULT;
622
if (mysql_options(conn, MYSQL_OPT_PROTOCOL, (char *) &type))
625
if (mysql_options(conn, MYSQL_READ_DEFAULT_GROUP, "xtstat"))
628
if (strcasecmp(options[OPT_DATABASE].opt_value_str, "pbxt") == 0)
630
else if (strcasecmp(options[OPT_DATABASE].opt_value_str, "information_schema") == 0)
635
/* Connect to database */
636
if (!mysql_real_connect(conn,
637
options[OPT_HOST].opt_value_str,
638
options[OPT_USER].opt_value_str,
639
options[OPT_PASSWORD].opt_value_str,
640
options[OPT_DATABASE].opt_value_str,
641
options[OPT_PORT].opt_value_int,
642
options[OPT_SOCKET].opt_value_str,
649
int main(int argc, char **argv)
654
llong current_values[XT_STAT_CURRENT_MAX];
657
XTStatMetaDataPtr meta;
661
bool select_worked = true;
663
xt_set_time_unit("msec");
664
parse_args(argc, argv);
666
determine_display_order();
668
if (!(conn = mysql_init(NULL))) {
669
fprintf(stderr, "Insufficient memory\n");
673
if (!connect(conn) || !display_parameters(conn)) {
674
fprintf(stderr, "%s\n", mysql_error(conn));
679
for (int loop = 0; ; loop++) {
681
err = mysql_query(conn, "select id, Value from information_schema.pbxt_statistics order by ID");
683
err = mysql_query(conn, "select id, Value from pbxt.statistics order by ID");
687
if (!(res = mysql_use_result(conn)))
689
select_worked = true;
691
while ((row = mysql_fetch_row(res)) != NULL) {
692
stat = atoi(row[0])-1;
693
current_values[stat] = atoll(row[1]);
695
mysql_free_result(res);
697
#ifdef DEBUG_INTERRUPT
698
if (current_values[XT_STAT_COMMITS] - accumulative_values[XT_STAT_COMMITS] == 0 &&
699
current_values[XT_STAT_STAT_READS] - accumulative_values[XT_STAT_STAT_READS] == 0 &&
700
#ifdef XT_TIME_DISK_WRITES
701
current_values[XT_STAT_REC_WRITE_TIME] - accumulative_values[XT_STAT_REC_WRITE_TIME] == 0 &&
702
current_values[XT_STAT_IND_WRITE_TIME] - accumulative_values[XT_STAT_IND_WRITE_TIME] == 0 &&
703
current_values[XT_STAT_ILOG_WRITE_TIME] - accumulative_values[XT_STAT_ILOG_WRITE_TIME] == 0 &&
705
current_values[XT_STAT_STAT_WRITES] - accumulative_values[XT_STAT_STAT_WRITES] == 0)
706
interrupt_pbxt(conn);
709
if ((loop % 25) == 0) {
710
for (int column=0; column<columns_used; column++) {
712
meta = xt_get_stat_meta_data(display_order[column].do_statistic);
713
strcpy(str_value, meta->sm_short_line_1);
714
if (display_order[column].do_combo) {
715
/* Combine next 2 fields: */
719
else if (meta->sm_flags & XT_STAT_PERCENTAGE)
721
else if (meta->sm_flags & XT_STAT_DATE)
723
printf("%*s ", len, str_value);
726
for (int column=0; column<columns_used; column++) {
728
meta = xt_get_stat_meta_data(display_order[column].do_statistic);
729
strcpy(str_value, meta->sm_short_line_2);
730
if (display_order[column].do_combo) {
731
/* Combine next 2 fields: */
734
strcat(str_value, "/ms");
736
else if (meta->sm_flags & XT_STAT_PERCENTAGE)
738
else if (meta->sm_flags & XT_STAT_DATE)
740
printf("%*s ", len, str_value);
745
for (int column=0; column<columns_used; column++) {
747
stat = display_order[column].do_statistic;
748
meta = xt_get_stat_meta_data(stat);
749
if (meta->sm_flags & XT_STAT_ACCUMULATIVE) {
750
/* Take care of overflow! */
751
if (current_values[stat] < accumulative_values[stat])
752
value = (double) (0xFFFFFFFF - (accumulative_values[stat] - current_values[stat]));
754
value = (double) (current_values[stat] - accumulative_values[stat]);
757
value = (double) current_values[stat];
758
accumulative_values[stat] = current_values[stat];
759
if (meta->sm_flags & XT_STAT_TIME_VALUE)
760
value = value / (double) 1000;
761
if (display_order[column].do_combo) {
762
format_mini_count_value(str_value, value);
763
strcat(str_value, "/");
765
stat = display_order[column].do_statistic;
766
value = (double) (current_values[stat] - accumulative_values[stat]);
767
accumulative_values[stat] = current_values[stat];
768
value = value / (double) 1000;
769
format_count_value(&str_value[strlen(str_value)], value);
772
else if (meta->sm_flags & XT_STAT_PERCENTAGE) {
775
case XT_STAT_REC_CACHE_USAGE: perc = (double) record_cache_size; break;
776
case XT_STAT_IND_CACHE_USAGE: perc = (double) index_cache_size; break;
777
case XT_STAT_IND_CACHE_DIRTY: perc = (double) index_cache_size; break;
778
case XT_STAT_XLOG_CACHE_USAGE: perc = (double) log_cache_size; break;
780
format_percent_value(str_value, value, perc);
783
else if (meta->sm_flags & XT_STAT_DATE) {
784
time_t ticks = (time_t) value;
785
const struct tm *ltime = localtime(&ticks);
786
strftime(str_value, 99, "%y%m%d %H:%M:%S", ltime);
789
else if (meta->sm_flags & XT_STAT_BYTE_COUNT)
790
format_byte_value(str_value, value);
792
format_count_value(str_value, value);
793
if (column == columns_used-1)
794
printf("%*s\n", len, str_value);
796
printf("%*s ", len, str_value);
799
sleep(options[OPT_DELAY].opt_value_int);
802
/* close connection */
809
/* Only print message if the SELECT worked.
810
* or we will get a screen full of messages:
812
fprintf(stderr, "%s\n", mysql_error(conn));
813
printf("Reconnecting...\n");
816
if (!(conn = mysql_init(NULL))) {
817
fprintf(stderr, "Insufficient memory\n");
822
} while (!connect(conn));
823
select_worked = false;
added
removed
plugin/pbxt/bin/xtstat_xt.cc
