mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2025-08-07 23:56:57 +02:00
Code Issues Projects Releases Wiki Activity

[MINOR] halog: add '-tc' to sort by termination codes

Browse Source 
This output lists all encountered termination codes by number of
occurrences.
This commit is contained in:
Willy Tarreau 2010-09-12 17:56:16 +02:00
parent 6cbd64773b
commit d8fc1103a5
1 changed files with 28 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
contrib/halog/halog.c
View File

@ -1,5 +1,5 @@
/* /*
* haproxy log time reporter * haproxy log statistics reporter
* *
* Copyright 2000-2010 Willy Tarreau <w@1wt.eu> * Copyright 2000-2010 Willy Tarreau <w@1wt.eu>
* *
@ -10,14 +10,6 @@
* *
*/ */
/*
* gcc -O2 -o halog2 halog2.c -Iinclude src/ebtree.c src/eb32tree.c fgets2.c
*
* Usage:
* $0 [ min_delay [ min_count [ field_shift ]]] < haproxy.log
* Note: if min_delay < 0, it only outputs lines with status codes 5xx.
*/
#include <errno.h> #include <errno.h>
#include <fcntl.h> #include <fcntl.h>
#include <stdio.h> #include <stdio.h>
@ -35,6 +27,7 @@
#define SERVER_FIELD 8 #define SERVER_FIELD 8
#define TIME_FIELD 9 #define TIME_FIELD 9
#define STATUS_FIELD 10 #define STATUS_FIELD 10
#define TERM_CODES_FIELD 14
#define CONN_FIELD 15 #define CONN_FIELD 15
#define MAXLINE 16384 #define MAXLINE 16384
#define QBITS 4 #define QBITS 4
@ -75,6 +68,7 @@ struct srv_st {
#define FILT_COUNT_STATUS 0x800 #define FILT_COUNT_STATUS 0x800
#define FILT_COUNT_SRV_STATUS 0x1000 #define FILT_COUNT_SRV_STATUS 0x1000
#define FILT_COUNT_TERM_CODES 0x2000
unsigned int filter = 0; unsigned int filter = 0;
unsigned int filter_invert = 0; unsigned int filter_invert = 0;
@ -86,7 +80,7 @@ void die(const char *msg)
{ {
fprintf(stderr, fprintf(stderr,
"%s" "%s"
"Usage: halog [-q] [-c] [-v] [-gt] [-pct] [-st] [-srv] [-s <skip>] [-e|-E] [-rt|-RT <time>] [-ad <delay>] [-ac <count>] < file.log\n" "Usage: halog [-q] [-c] [-v] {-gt|-pct|-st|-tc|-srv} [-s <skip>] [-e|-E] [-rt|-RT <time>] [-ad <delay>] [-ac <count>] < file.log\n"
"\n", "\n",
msg ? msg : "" msg ? msg : ""
); );
@ -425,6 +419,8 @@ int main(int argc, char **argv)
filter |= FILT_COUNT_STATUS; filter |= FILT_COUNT_STATUS;
else if (strcmp(argv[0], "-srv") == 0) else if (strcmp(argv[0], "-srv") == 0)
filter |= FILT_COUNT_SRV_STATUS; filter |= FILT_COUNT_SRV_STATUS;
else if (strcmp(argv[0], "-tc") == 0)
filter |= FILT_COUNT_TERM_CODES;
else if (strcmp(argv[0], "-o") == 0) { else if (strcmp(argv[0], "-o") == 0) {
if (output_file) if (output_file)
die("Fatal: output file name already specified.\n"); die("Fatal: output file name already specified.\n");
@ -619,6 +615,19 @@ int main(int argc, char **argv)
continue; continue;
} }
if (unlikely(filter & FILT_COUNT_TERM_CODES)) {
b = field_start(line, TERM_CODES_FIELD + skip_fields);
if (!*b) {
truncated_line(linenum, line);
continue;
}
val = 256 * b[0] + b[1];
t2 = insert_value(&timers[0], &t, val);
t2->count++;
continue;
}
if (unlikely(filter & FILT_COUNT_SRV_STATUS)) { if (unlikely(filter & FILT_COUNT_SRV_STATUS)) {
char *srv_name; char *srv_name;
struct ebmb_node *srv_node; struct ebmb_node *srv_node;
@ -870,6 +879,15 @@ int main(int argc, char **argv)
tot++; tot++;
} }
} }
else if (filter & FILT_COUNT_TERM_CODES) {
/* output all statuses in the form of <code> <occurrences> */
n = eb32_first(&timers[0]);
while (n) {
t = container_of(n, struct timer, node);
printf("%c%c %d\n", (n->key >> 8), (n->key) & 255, t->count);
n = eb32_next(n);
}
}
empty: empty:
if (!(filter & FILT_QUIET)) if (!(filter & FILT_QUIET))