From e1e14b5d2a0ff3097c93f4605f33b38df1e3e266 Mon Sep 17 00:00:00 2001 From: Willy Tarreau Date: Tue, 13 Nov 2012 20:48:15 +0100 Subject: BUG: halog: fix broken output limitation Commit 667c905f introduced parameter -m to halog which limits the size of the output. Unfortunately it is completely broken in that it doesn't check that the limit was previously set or not, and also prevents a simple counting operation from returning anything if a limit is not set. Note that the -gt and -pct outputs behave differently in face of this limit, since they count the valid output lines BEFORE actually producing the data, so the limit really applies to valid input lines. (cherry picked from commit a1629a59d17208897622d4e0d8ecddf157d55074) --- contrib/halog/halog.c | 26 +++++++++++--------------- 1 files changed, 11 insertions(+), 15 deletions(-) diff --git a/contrib/halog/halog.c b/contrib/halog/halog.c index 7e16cd5..61034ec 100644 --- a/contrib/halog/halog.c +++ b/contrib/halog/halog.c @@ -708,11 +708,11 @@ int main(int argc, char **argv) posix_fadvise(0, 0, 0, POSIX_FADV_SEQUENTIAL); #endif - if (!line_filter && lines_max >= 0 && + if (!line_filter && /* FILT_COUNT_ONLY ( see above), and no input filter (see below) */ !(filter & (FILT_HTTP_ONLY|FILT_TIME_RESP|FILT_ERRORS_ONLY|FILT_HTTP_STATUS|FILT_QUEUE_ONLY|FILT_QUEUE_SRV_ONLY|FILT_TERM_CODE_NAME))) { - /* read the whole file at once first */ + /* read the whole file at once first, ignore it if inverted output */ if (!filter_invert) - while (fgets2(stdin) != NULL) + while ((lines_max < 0 || lines_out < lines_max) && fgets2(stdin) != NULL) lines_out++; goto skip_filters; @@ -872,8 +872,8 @@ int main(int argc, char **argv) if (line_filter) line_filter(accept_field, time_field, &t); else - lines_out++; /* we're just counting lines */ - if (lines_out >= lines_max) + lines_out++; /* FILT_COUNT_ONLY was used, so we're just counting lines */ + if (lines_max >= 0 && lines_out >= lines_max) break; } @@ -914,7 +914,7 @@ int main(int argc, char **argv) m = h % 60; h = h / 60; printf("%02d:%02d:%02d.%03d %d %d %d\n", h, m, s, ms, last, d, t->count); lines_out++; - if (lines_out >= lines_max) + if (lines_max >= 0 && lines_out >= lines_max) break; } n = eb32_next(n); @@ -944,12 +944,8 @@ int main(int argc, char **argv) else d = val; - if (d > 0.0) { + if (d > 0.0) printf("%d %d %f\n", f, last, d+1.0); - lines_out++; - if (lines_out >= lines_max) - break; - } n = eb32_next(n); } @@ -1006,7 +1002,7 @@ int main(int argc, char **argv) t = container_of(n, struct timer, node); printf("%d %d\n", n->key, t->count); lines_out++; - if (lines_out >= lines_max) + if (lines_max >= 0 && lines_out >= lines_max) break; n = eb32_next(n); } @@ -1035,7 +1031,7 @@ int main(int argc, char **argv) (int)(srv->cum_ct / (srv->nb_ct?srv->nb_ct:1)), (int)(srv->cum_rt / (srv->nb_rt?srv->nb_rt:1))); srv_node = ebmb_next(srv_node); lines_out++; - if (lines_out >= lines_max) + if (lines_max >= 0 && lines_out >= lines_max) break; } } @@ -1046,7 +1042,7 @@ int main(int argc, char **argv) t = container_of(n, struct timer, node); printf("%c%c %d\n", (n->key >> 8), (n->key) & 255, t->count); lines_out++; - if (lines_out >= lines_max) + if (lines_max >= 0 && lines_out >= lines_max) break; n = eb32_next(n); } @@ -1110,7 +1106,7 @@ int main(int argc, char **argv) node = eb_prev(node); lines_out++; - if (lines_out >= lines_max) + if (lines_max >= 0 && lines_out >= lines_max) break; } } -- 1.7.1