GCOV - Varnish Cache


/*-
 * Copyright (c) 2006 Verdens Gang AS
 * Copyright (c) 2006-2015 Varnish Software AS
 * All rights reserved.
 *
 * Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
 * Author: Dag-Erling Smørgrav <des@des.no>
 * Author: Guillaume Quintard <guillaume.quintard@gmail.com>
 *
 * SPDX-License-Identifier: BSD-2-Clause
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 *
 * Log tailer for Varnish
 */

#include "config.h"

#include <limits.h>
#include <math.h>
#include <pthread.h>
#include <stdarg.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#define VOPT_DEFINITION
#define VOPT_INC "varnishhist_options.h"

#include "vdef.h"
#include "vcurses.h"
#include "vapi/vsl.h"
#include "vapi/vsm.h"
#include "vapi/voptget.h"
#include "vapi/vsig.h"
#include "vas.h"
#include "vut.h"
#include "vtim.h"

#define HIST_N 2000             /* how far back we remember */
#define HIST_RES 100            /* bucket resolution */

static struct VUT *vut;

static int hist_low;
static int hist_high;
static int hist_range;
static unsigned hist_buckets;

static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;

static int end_of_file = 0;
static unsigned ms_delay = 1000;
static unsigned rr_hist[HIST_N];
static unsigned nhist;
static unsigned next_hist;
static unsigned *bucket_miss;
static unsigned *bucket_hit;
static char *format;
static int match_tag;
static double timebend = 0, t0;
static double vsl_t0 = 0, vsl_to, vsl_ts = 0;
static pthread_cond_t timebend_cv;
static double log_ten;
static char *ident;

static const unsigned scales[] = {
        1,
        2,
        3,
        4,
        5,
        10,
        15,
        20,
        25,
        50,
        100,
        250,
        500,
        1000,
        2500,
        5000,
        10000,
        25000,
        50000,
        100000,
        UINT_MAX
};

struct profile {
        const char *name;
        char VSL_arg;
        enum VSL_tag_e tag;
        const char *prefix;
        int field;
        int hist_low;
        int hist_high;
};

#define HIS_PROF(name,vsl_arg,tag,prefix,field,hist_low,high_high,doc)  \
        {name,vsl_arg,tag,prefix,field,hist_low,high_high},
#define HIS_NO_PREFIX   NULL
#define HIS_CLIENT      'c'
#define HIS_BACKEND     'b'
static const struct profile profiles[] = {
#include "varnishhist_profiles.h"
        { NULL }
};
#undef HIS_NO_PREFIX
#undef HIS_BACKEND
#undef HIS_CLIENT
#undef HIS_PROF

static const struct profile *active_profile;

static void
update(void)
{
        char t[VTIM_FORMAT_SIZE];
        const unsigned w = COLS / hist_range;
        const unsigned n = w * hist_range;
        unsigned bm[n], bh[n];
        unsigned max;
        unsigned scale;
        int i, j;
        unsigned k, l;

        /* Draw horizontal axis */
        for (k = 0; k < n; ++k)
                (void)mvaddch(LINES - 2, k, '-');
        for (i = 0, j = hist_low; i < hist_range; ++i, ++j) {
                (void)mvaddch(LINES - 2, w * i, '+');
                IC(mvprintw(LINES - 1, w * i, "|1e%d", j));
        }

        if (end_of_file)
                IC(mvprintw(0, 0, "%*s", COLS - 1, "EOF"));
        else
                IC(mvprintw(0, 0, "%*s", COLS - 1, ident));

        /* count our flock */
        memset(bm, 0, sizeof bm);
        memset(bh, 0, sizeof bh);
        for (k = 0, max = 1; k < hist_buckets; ++k) {
                l = k * n / hist_buckets;
                assert(l < n);
                bm[l] += bucket_miss[k];
                bh[l] += bucket_hit[k];
                max = vmax(max, bm[l] + bh[l]);
        }

        /* scale,time */
        assert(LINES - 3 >= 0);
        for (i = 0; max / scales[i] > (unsigned)(LINES - 3); ++i)
                /* nothing */ ;
        scale = scales[i];

        if (vsl_t0 > 0) {
                VTIM_format(vsl_ts, t);

                IC(mvprintw(0, 0, "1:%u, n = %u, d = %g @ %s x %g",
                    scale, nhist, 1e-3 * ms_delay, t, timebend));
        } else {
                IC(mvprintw(0, 0, "1:%u, n = %u, d = %g",
                    scale, nhist, 1e-3 * ms_delay));
        }

        for (j = 5; j < LINES - 2; j += 5)
                IC(mvprintw((LINES - 2) - j, 0, "%u_", j * scale));

        /* show them */
        for (k = 0; k < n; ++k) {
                for (l = 0; l < bm[k] / scale; ++l)
                        (void)mvaddch((LINES - 3) - l, k, '#');
                for (; l < (bm[k] + bh[k]) / scale; ++l)
                        (void)mvaddch((LINES - 3) - l, k, '|');
        }
}

inline static void
upd_vsl_ts(const char *p)
{

        if (timebend == 0)
                return;

        p = strchr(p, ' ');

        if (p == NULL)
                return;

        vsl_ts = vmax_t(double, vsl_ts, strtod(p + 1, NULL));
}

static void
delorean(void)
{
        int i;
        double t = VTIM_mono();

        if (vsl_t0 == 0)
                vsl_to = vsl_t0 = vsl_ts;

        assert(t > t0);
        vsl_to = vsl_t0 + (t - t0) * timebend;

        if (vsl_ts > vsl_to) {
                double when = VTIM_real() + vsl_ts - vsl_to;
                struct timespec ts = VTIM_timespec(when);
                i = pthread_cond_timedwait(&timebend_cv, &mtx, &ts);
                assert(i == 0 || i == ETIMEDOUT);
        }
}

static int v_matchproto_ (VSLQ_dispatch_f)
accumulate(struct VSL_data *vsl, struct VSL_transaction * const pt[],
    void *priv)
{
        int i, tag, skip, match, hit;
        unsigned u;
        double value = 0;
        struct VSL_transaction *tr;
        const char *tsp;
        enum vsl_status stat;

        (void)vsl;
        (void)priv;

        for (tr = pt[0]; tr != NULL; tr = *++pt) {
                if (VSIG_int || VSIG_term || VSIG_hup)
                        return (-1);

                if (tr->reason == VSL_r_esi) {
                        /* Skip ESI requests */
                        continue;
                }

                hit = 0;
                skip = 0;
                match = 0;
                tsp = NULL;
                while (skip == 0) {
                        stat = VSL_Next(tr->c);
                        if (stat == vsl_e_overrun) {
                                /* need to skip forward */
                                PTOK(pthread_mutex_lock(&mtx));
                                vsl_to = vsl_t0 = vsl_ts = 0;
                                t0 = VTIM_mono();
                                PTOK(pthread_mutex_unlock(&mtx));
                                break;
                        }
                        if (stat != vsl_more)
                                break;

                        /* get the value we want and register if it's a hit */
                        tag = VSL_TAG(tr->c->rec.ptr);

                        if (VSL_tagflags[tag])
                                continue;

                        switch (tag) {
                        case SLT_Hit:
                                hit = 1;
                                break;
                        case SLT_VCL_return:
                                if (!strcasecmp(VSL_CDATA(tr->c->rec.ptr),
                                    "restart") ||
                                    !strcasecmp(VSL_CDATA(tr->c->rec.ptr),
                                    "retry"))
                                        skip = 1;
                                break;
                        case SLT_Timestamp:
                                tsp = VSL_CDATA(tr->c->rec.ptr);
                                /* FALLTHROUGH */
                        default:
                                if (tag != match_tag)
                                        break;

                                if (active_profile->prefix &&
                                    strncmp(VSL_CDATA(tr->c->rec.ptr),
                                    active_profile->prefix,
                                    strlen(active_profile->prefix)) != 0)
                                        break;

                                i = sscanf(VSL_CDATA(tr->c->rec.ptr),
                                    format, &value);
                                if (i != 1)
                                        break;
                                match = 1;
                                break;
                        }
                }

                if (skip || !match || value <= 0)
                        continue;

                /* select bucket */
                i = vlimit_t(int, lround(HIST_RES * log(value) / log_ten),
                    hist_low * HIST_RES, hist_high * HIST_RES - 1) -
                        hist_low * HIST_RES;
                assert(i >= 0);
                assert((unsigned)i < hist_buckets);

                PTOK(pthread_mutex_lock(&mtx));

                /*
                 * only parse the last tsp seen in this transaction -
                 * it should be the latest.
                 */
                if (tsp)
                        upd_vsl_ts(tsp);

                /* phase out old data */
                if (nhist == HIST_N) {
                        u = rr_hist[next_hist];
                        if (u >= hist_buckets) {
                                u -= hist_buckets;
                                assert(u < hist_buckets);
                                assert(bucket_hit[u] > 0);
                                bucket_hit[u]--;
                        } else {
                                assert(bucket_miss[u] > 0);
                                bucket_miss[u]--;
                        }
                } else {
                        ++nhist;
                }

                /* phase in new data */
                if (hit) {
                        bucket_hit[i]++;
                        rr_hist[next_hist] = i + hist_buckets;
                } else {
                        bucket_miss[i]++;
                        rr_hist[next_hist] = i;
                }
                if (++next_hist == HIST_N) {
                        next_hist = 0;
                }
                if (vsl_ts >= vsl_to)
                        delorean();
                PTOK(pthread_mutex_unlock(&mtx));
        }
        return (0);
}

static void * v_matchproto_(pthread_t)
do_curses(void *arg)
{
        int ch;
        (void)arg;

        (void)initscr();
        AC(raw());
        AC(noecho());
        AC(nonl());
        AC(intrflush(stdscr, FALSE));
        IC(curs_set(0));
        AC(erase());
        while (!VSIG_int && !VSIG_term && !VSIG_hup) {

                AC(erase());
                PTOK(pthread_mutex_lock(&mtx));
                update();
                PTOK(pthread_mutex_unlock(&mtx));
                AC(refresh());

                assert(ms_delay > 0);
                timeout(ms_delay);
                switch ((ch = getch())) {
                case ERR:
                        break;
#ifdef KEY_RESIZE
                case KEY_RESIZE:
                        AC(erase());
                        break;
#endif
                case '\014':    /* Ctrl-L */
                case '\024':    /* Ctrl-T */
                        AC(redrawwin(stdscr));
                        AC(refresh());
                        break;
                case '\032':    /* Ctrl-Z */
                        AC(endwin());
                        AZ(raise(SIGTSTP));
                        break;
                case '\003':    /* Ctrl-C */
                case '\021':    /* Ctrl-Q */
                case 'Q':
                case 'q':
                        AZ(raise(SIGINT));
                        break;
                case '0':
                case '1':
                case '2':
                case '3':
                case '4':
                case '5':
                case '6':
                case '7':
                case '8':
                case '9':
                        ms_delay = 1000U << (ch - '0');
                        break;
                case '+':
                        ms_delay = vmax(ms_delay >> 1, 1U);
                        break;
                case '-':
                        ms_delay *= 2;
                        break;
                case '>':
                case '<':
                        /* see below */
                        break;
                default:
                        AC(beep());
                        break;
                }

                if (ch == '<' || ch == '>') {
                        PTOK(pthread_mutex_lock(&mtx));
                        vsl_to = vsl_t0 = vsl_ts;
                        t0 = VTIM_mono();
                        if (timebend == 0)
                                timebend = 1;
                        else if (ch == '<')
                                timebend /= 2;
                        else
                                timebend *= 2;
                        PTOK(pthread_cond_broadcast(&timebend_cv));
                        PTOK(pthread_mutex_unlock(&mtx));
                }
        }
        AC(endwin());
        return (NULL);
}

/*--------------------------------------------------------------------*/

static void v_noreturn_
profile_error(const char *s)
{
        fprintf(stderr, "-P: '%s' is not a valid"
            " profile name or definition\n", s);
        exit(1);
}

int
main(int argc, char **argv)
{
        int i;
        char *colon;
        const char *ptag, *profile = "responsetime";
        pthread_t thr;
        int fnum;
        struct profile cli_p = {0};

        vut = VUT_InitProg(argc, argv, &vopt_spec);
        AN(vut);
        PTOK(pthread_cond_init(&timebend_cv, NULL));

        while ((i = getopt(argc, argv, vopt_spec.vopt_optstring)) != -1) {
                switch (i) {
                case 'h':
                        /* Usage help */
                        VUT_Usage(vut, &vopt_spec, 0);
                case 'p':
                        ms_delay = lround(1e3 * strtod(optarg, NULL));
                        if (ms_delay == 0)
                                VUT_Error(vut, 1, "-p: invalid '%s'", optarg);
                        break;
                case 'P':
                        colon = strchr(optarg, ':');
                        /* no colon, take the profile as a name */
                        if (colon == NULL) {
                                profile = optarg;
                                break;
                        }
                        /* else check if valid definition */
                        if (colon == optarg + 1 && (*optarg == 'b' ||
                            *optarg == 'c' || *optarg == 'E')) {
                                cli_p.VSL_arg = *optarg;
                                ptag = colon + 1;
                                colon = strchr(colon + 1, ':');
                                if (colon == NULL)
                                        profile_error(optarg);
                        } else {
                                ptag = optarg;
                                cli_p.VSL_arg = 'c';
                        }

                        assert(colon);

                        match_tag = VSL_Name2Tag(ptag, colon - ptag);
                        if (match_tag < 0)
                                VUT_Error(vut, 1,
                                    "-P: '%s' is not a valid tag name",
                                    optarg);

                        if (VSL_tagflags[match_tag])
                                VUT_Error(vut, 1,
                                    "-P: '%s' is an unsafe or binary record",
                                    optarg);

                        cli_p.prefix = colon + 1;

                        colon = strchr(colon + 1, ':');
                        if (colon == NULL)
                                profile_error(optarg);

                        *colon = '\0';
                        if (*cli_p.prefix == '\0')
                                cli_p.prefix = NULL;

                        if (sscanf(colon + 1, "%d",  &cli_p.field) != 1)
                                profile_error(optarg);

                        cli_p.name = "custom";
                        cli_p.tag = (enum VSL_tag_e)match_tag;
                        cli_p.hist_low = -6;
                        cli_p.hist_high = 3;
                        profile = NULL;
                        active_profile = &cli_p;

                        colon = strchr(colon + 1, ':');
                        if (colon == NULL)
                                break;

                        if (sscanf(colon + 1, "%d:%d",  &cli_p.hist_low,
                                   &cli_p.hist_high) != 2)
                                profile_error(optarg);

                        break;
                case 'B':
                        timebend = strtod(optarg, NULL);
                        if (timebend == 0)
                                VUT_Error(vut, 1,
                                    "-B: being able to bend time does not"
                                    " mean we can stop it"
                                    " (invalid factor '%s')", optarg);
                        if (timebend < 0)
                                VUT_Error(vut, 1,
                                    "-B: being able to bend time does not"
                                    " mean we can make it go backwards"
                                    " (invalid factor '%s')", optarg);
                        break;
                default:
                        if (!VUT_Arg(vut, i, optarg))
                                VUT_Usage(vut, &vopt_spec, 1);
                }
        }

        if (optind != argc)
                VUT_Usage(vut, &vopt_spec, 1);

        /* Check for valid grouping mode */
        assert(vut->g_arg < VSL_g__MAX);
        if (vut->g_arg != VSL_g_vxid && vut->g_arg != VSL_g_request)
                VUT_Error(vut, 1, "Invalid grouping mode: %s"
                    " (only vxid and request are supported)",
                    VSLQ_grouping[vut->g_arg]);

        if (profile) {
                for (active_profile = profiles; active_profile->name;
                     active_profile++) {
                        if (strcmp(active_profile->name, profile) == 0)
                                break;
                }
        }
        AN(active_profile);
        if (!active_profile->name)
                VUT_Error(vut, 1, "-P: No such profile '%s'", profile);

        assert(active_profile->VSL_arg == 'b' ||
            active_profile->VSL_arg == 'c' ||
            active_profile->VSL_arg == 'E');
        assert(VUT_Arg(vut, active_profile->VSL_arg, NULL));
        match_tag = active_profile->tag;
        fnum = active_profile->field;
        hist_low = active_profile->hist_low;
        hist_high = active_profile->hist_high;

        hist_range = hist_high - hist_low;
        hist_buckets = hist_range * HIST_RES;
        bucket_hit = calloc(hist_buckets, sizeof *bucket_hit);
        bucket_miss = calloc(hist_buckets, sizeof *bucket_miss);

        if (timebend > 0)
                t0 = VTIM_mono();

        format = malloc(4L * fnum);
        AN(format);
        for (i = 0; i < fnum - 1; i++)
                strcpy(format + 4 * i, "%*s ");
        strcpy(format + 4 * (fnum - 1), "%lf");

        log_ten = log(10.0);

        VUT_Setup(vut);
        if (vut->vsm)
                ident = VSM_Dup(vut->vsm, "Arg", "-i");
        else
                ident = strdup("");
        PTOK(pthread_create(&thr, NULL, do_curses, NULL));
        vut->dispatch_f = accumulate;
        vut->dispatch_priv = NULL;
        (void)VUT_Main(vut);
        end_of_file = 1;
        PTOK(pthread_join(thr, NULL));
        VUT_Fini(&vut);
        exit(0);
}

		varnish-cache/bin/varnishhist/varnishhist.c
0		/*-
1		* Copyright (c) 2006 Verdens Gang AS
2		* Copyright (c) 2006-2015 Varnish Software AS
3		* All rights reserved.
4		*
5		* Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
6		* Author: Dag-Erling Smørgrav <des@des.no>
7		* Author: Guillaume Quintard <guillaume.quintard@gmail.com>
8		*
9		* SPDX-License-Identifier: BSD-2-Clause
10		*
11		* Redistribution and use in source and binary forms, with or without
12		* modification, are permitted provided that the following conditions
13		* are met:
14		* 1. Redistributions of source code must retain the above copyright
15		* notice, this list of conditions and the following disclaimer.
16		* 2. Redistributions in binary form must reproduce the above copyright
17		* notice, this list of conditions and the following disclaimer in the
18		* documentation and/or other materials provided with the distribution.
19		*
20		* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
21		* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
22		* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
23		* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
24		* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
25		* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
26		* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
27		* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
28		* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
29		* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
30		* SUCH DAMAGE.
31		*
32		* Log tailer for Varnish
33		*/
34
35		#include "config.h"
36
37		#include <limits.h>
38		#include <math.h>
39		#include <pthread.h>
40		#include <stdarg.h>
41		#include <stdlib.h>
42		#include <string.h>
43		#include <unistd.h>
44
45		#define VOPT_DEFINITION
46		#define VOPT_INC "varnishhist_options.h"
47
48		#include "vdef.h"
49		#include "vcurses.h"
50		#include "vapi/vsl.h"
51		#include "vapi/vsm.h"
52		#include "vapi/voptget.h"
53		#include "vapi/vsig.h"
54		#include "vas.h"
55		#include "vut.h"
56		#include "vtim.h"
57
58		#define HIST_N 2000 /* how far back we remember */
59		#define HIST_RES 100 /* bucket resolution */
60
61		static struct VUT *vut;
62
63		static int hist_low;
64		static int hist_high;
65		static int hist_range;
66		static unsigned hist_buckets;
67
68		static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;
69
70		static int end_of_file = 0;
71		static unsigned ms_delay = 1000;
72		static unsigned rr_hist[HIST_N];
73		static unsigned nhist;
74		static unsigned next_hist;
75		static unsigned *bucket_miss;
76		static unsigned *bucket_hit;
77		static char *format;
78		static int match_tag;
79		static double timebend = 0, t0;
80		static double vsl_t0 = 0, vsl_to, vsl_ts = 0;
81		static pthread_cond_t timebend_cv;
82		static double log_ten;
83		static char *ident;
84
85		static const unsigned scales[] = {
86		1,
87		2,
88		3,
89		4,
90		5,
91		10,
92		15,
93		20,
94		25,
95		50,
96		100,
97		250,
98		500,
99		1000,
100		2500,
101		5000,
102		10000,
103		25000,
104		50000,
105		100000,
106		UINT_MAX
107		};
108
109		struct profile {
110		const char *name;
111		char VSL_arg;
112		enum VSL_tag_e tag;
113		const char *prefix;
114		int field;
115		int hist_low;
116		int hist_high;
117		};
118
119		#define HIS_PROF(name,vsl_arg,tag,prefix,field,hist_low,high_high,doc) \
120		{name,vsl_arg,tag,prefix,field,hist_low,high_high},
121		#define HIS_NO_PREFIX NULL
122		#define HIS_CLIENT 'c'
123		#define HIS_BACKEND 'b'
124		static const struct profile profiles[] = {
125		#include "varnishhist_profiles.h"
126		{ NULL }
127		};
128		#undef HIS_NO_PREFIX
129		#undef HIS_BACKEND
130		#undef HIS_CLIENT
131		#undef HIS_PROF
132
133		static const struct profile *active_profile;
134
135		static void
136	47079	update(void)
137		{
138		char t[VTIM_FORMAT_SIZE];
139	47079	const unsigned w = COLS / hist_range;
140	47079	const unsigned n = w * hist_range;
141	47079	unsigned bm[n], bh[n];
142		unsigned max;
143		unsigned scale;
144		int i, j;
145		unsigned k, l;
146
147		/* Draw horizontal axis */
148	3439327	for (k = 0; k < n; ++k)
149	3392248	(void)mvaddch(LINES - 2, k, '-');
150	468550	for (i = 0, j = hist_low; i < hist_range; ++i, ++j) {
151	421471	(void)mvaddch(LINES - 2, w * i, '+');
152	421471	IC(mvprintw(LINES - 1, w * i, "\|1e%d", j));
153	421471	}
154
155	47079	if (end_of_file)
156	0	IC(mvprintw(0, 0, "%*s", COLS - 1, "EOF"));
157		else
158	47079	IC(mvprintw(0, 0, "%*s", COLS - 1, ident));
159
160		/* count our flock */
161	47079	memset(bm, 0, sizeof bm);
162	47079	memset(bh, 0, sizeof bh);
163	42194179	for (k = 0, max = 1; k < hist_buckets; ++k) {
164	42147100	l = k * n / hist_buckets;
165	42147100	assert(l < n);
166	42147100	bm[l] += bucket_miss[k];
167	42147100	bh[l] += bucket_hit[k];
168	42147100	max = vmax(max, bm[l] + bh[l]);
169	42147100	}
170
171		/* scale,time */
172	47079	assert(LINES - 3 >= 0);
173	47079	for (i = 0; max / scales[i] > (unsigned)(LINES - 3); ++i)
174		/* nothing */ ;
175	47079	scale = scales[i];
176
177	47079	if (vsl_t0 > 0) {
178	46123	VTIM_format(vsl_ts, t);
179
180	46123	IC(mvprintw(0, 0, "1:%u, n = %u, d = %g @ %s x %g",
181		scale, nhist, 1e-3 * ms_delay, t, timebend));
182	46123	} else {
183	956	IC(mvprintw(0, 0, "1:%u, n = %u, d = %g",
184		scale, nhist, 1e-3 * ms_delay));
185		}
186
187	235395	for (j = 5; j < LINES - 2; j += 5)
188	188316	IC(mvprintw((LINES - 2) - j, 0, "%u_", j * scale));
189
190		/* show them */
191	3439327	for (k = 0; k < n; ++k) {
192	3439100	for (l = 0; l < bm[k] / scale; ++l)
193	46852	(void)mvaddch((LINES - 3) - l, k, '#');
194	3392689	for (; l < (bm[k] + bh[k]) / scale; ++l)
195	441	(void)mvaddch((LINES - 3) - l, k, '\|');
196	3392248	}
197	47079	}
198
199		inline static void
200	160	upd_vsl_ts(const char *p)
201		{
202
203	160	if (timebend == 0)
204	120	return;
205
206	40	p = strchr(p, ' ');
207
208	40	if (p == NULL)
209	0	return;
210
211	40	vsl_ts = vmax_t(double, vsl_ts, strtod(p + 1, NULL));
212	160	}
213
214		static void
215	160	delorean(void)
216		{
217		int i;
218	160	double t = VTIM_mono();
219
220	160	if (vsl_t0 == 0)
221	160	vsl_to = vsl_t0 = vsl_ts;
222
223	160	assert(t > t0);
224	160	vsl_to = vsl_t0 + (t - t0) * timebend;
225
226	160	if (vsl_ts > vsl_to) {
227	0	double when = VTIM_real() + vsl_ts - vsl_to;
228	0	struct timespec ts = VTIM_timespec(when);
229	0	i = pthread_cond_timedwait(&timebend_cv, &mtx, &ts);
230	0	assert(i == 0 \|\| i == ETIMEDOUT);
231	0	}
232	160	}
233
234		static int v_matchproto_ (VSLQ_dispatch_f)
235	240	accumulate(struct VSL_data vsl, struct VSL_transaction const pt[],
236		void *priv)
237		{
238		int i, tag, skip, match, hit;
239		unsigned u;
240	240	double value = 0;
241		struct VSL_transaction *tr;
242		const char *tsp;
243		enum vsl_status stat;
244
245	240	(void)vsl;
246	240	(void)priv;
247
248	480	for (tr = pt[0]; tr != NULL; tr = *++pt) {
249	240	if (VSIG_int \|\| VSIG_term \|\| VSIG_hup)
250	0	return (-1);
251
252	240	if (tr->reason == VSL_r_esi) {
253		/* Skip ESI requests */
254	0	continue;
255		}
256
257	240	hit = 0;
258	240	skip = 0;
259	240	match = 0;
260	240	tsp = NULL;
261	7400	while (skip == 0) {
262	7400	stat = VSL_Next(tr->c);
263	7400	if (stat == vsl_e_overrun) {
264		/* need to skip forward */
265	0	PTOK(pthread_mutex_lock(&mtx));
266	0	vsl_to = vsl_t0 = vsl_ts = 0;
267	0	t0 = VTIM_mono();
268	0	PTOK(pthread_mutex_unlock(&mtx));
269	0	break;
270		}
271	7400	if (stat != vsl_more)
272	240	break;
273
274		/* get the value we want and register if it's a hit */
275	7160	tag = VSL_TAG(tr->c->rec.ptr);
276
277	7160	if (VSL_tagflags[tag])
278	800	continue;
279
280	6360	switch (tag) {
281		case SLT_Hit:
282	40	hit = 1;
283	40	break;
284		case SLT_VCL_return:
285	480	if (!strcasecmp(VSL_CDATA(tr->c->rec.ptr),
286	480	"restart") \|\|
287	480	!strcasecmp(VSL_CDATA(tr->c->rec.ptr),
288		"retry"))
289	0	skip = 1;
290	480	break;
291		case SLT_Timestamp:
292	920	tsp = VSL_CDATA(tr->c->rec.ptr);
293		/* FALLTHROUGH */
294		default:
295	5840	if (tag != match_tag)
296	5160	break;
297
298	680	if (active_profile->prefix &&
299	1280	strncmp(VSL_CDATA(tr->c->rec.ptr),
300	640	active_profile->prefix,
301	1280	strlen(active_profile->prefix)) != 0)
302	520	break;
303
304	320	i = sscanf(VSL_CDATA(tr->c->rec.ptr),
305	160	format, &value);
306	160	if (i != 1)
307	0	break;
308	160	match = 1;
309	160	break;
310		}
311		}
312
313	240	if (skip \|\| !match \|\| value <= 0)
314	80	continue;
315
316		/* select bucket */
317	160	i = vlimit_t(int, lround(HIST_RES * log(value) / log_ten),
318	160	hist_low * HIST_RES, hist_high * HIST_RES - 1) -
319	160	hist_low * HIST_RES;
320	160	assert(i >= 0);
321	160	assert((unsigned)i < hist_buckets);
322
323	160	PTOK(pthread_mutex_lock(&mtx));
324
325		/*
326		* only parse the last tsp seen in this transaction -
327		* it should be the latest.
328		*/
329	160	if (tsp)
330	160	upd_vsl_ts(tsp);
331
332		/* phase out old data */
333	160	if (nhist == HIST_N) {
334	0	u = rr_hist[next_hist];
335	0	if (u >= hist_buckets) {
336	0	u -= hist_buckets;
337	0	assert(u < hist_buckets);
338	0	assert(bucket_hit[u] > 0);
339	0	bucket_hit[u]--;
340	0	} else {
341	0	assert(bucket_miss[u] > 0);
342	0	bucket_miss[u]--;
343		}
344	0	} else {
345	160	++nhist;
346		}
347
348		/* phase in new data */
349	160	if (hit) {
350	40	bucket_hit[i]++;
351	40	rr_hist[next_hist] = i + hist_buckets;
352	40	} else {
353	120	bucket_miss[i]++;
354	120	rr_hist[next_hist] = i;
355		}
356	160	if (++next_hist == HIST_N) {
357	0	next_hist = 0;
358	0	}
359	160	if (vsl_ts >= vsl_to)
360	160	delorean();
361	160	PTOK(pthread_mutex_unlock(&mtx));
362	160	}
363	240	return (0);
364	240	}
365
366		static void * v_matchproto_(pthread_t)
367	120	do_curses(void *arg)
368		{
369		int ch;
370	120	(void)arg;
371
372	120	(void)initscr();
373	120	AC(raw());
374	120	AC(noecho());
375	120	AC(nonl());
376	120	AC(intrflush(stdscr, FALSE));
377	120	IC(curs_set(0));
378	120	AC(erase());
379	47199	while (!VSIG_int && !VSIG_term && !VSIG_hup) {
380
381	47079	AC(erase());
382	47079	PTOK(pthread_mutex_lock(&mtx));
383	47079	update();
384	47079	PTOK(pthread_mutex_unlock(&mtx));
385	47079	AC(refresh());
386
387	47079	assert(ms_delay > 0);
388	47079	timeout(ms_delay);
389	47079	switch ((ch = getch())) {
390		case ERR:
391	46119	break;
392		#ifdef KEY_RESIZE
393		case KEY_RESIZE:
394	40	AC(erase());
395	40	break;
396		#endif
397		case '\014': /* Ctrl-L */
398		case '\024': /* Ctrl-T */
399	40	AC(redrawwin(stdscr));
400	40	AC(refresh());
401	40	break;
402		case '\032': /* Ctrl-Z */
403	0	AC(endwin());
404	0	AZ(raise(SIGTSTP));
405	0	break;
406		case '\003': /* Ctrl-C */
407		case '\021': /* Ctrl-Q */
408		case 'Q':
409		case 'q':
410	40	AZ(raise(SIGINT));
411	40	break;
412		case '0':
413		case '1':
414		case '2':
415		case '3':
416		case '4':
417		case '5':
418		case '6':
419		case '7':
420		case '8':
421		case '9':
422	80	ms_delay = 1000U << (ch - '0');
423	80	break;
424		case '+':
425	480	ms_delay = vmax(ms_delay >> 1, 1U);
426	480	break;
427		case '-':
428	80	ms_delay *= 2;
429	80	break;
430		case '>':
431		case '<':
432		/* see below */
433	160	break;
434		default:
435	40	AC(beep());
436	40	break;
437		}
438
439	47079	if (ch == '<' \|\| ch == '>') {
440	160	PTOK(pthread_mutex_lock(&mtx));
441	160	vsl_to = vsl_t0 = vsl_ts;
442	160	t0 = VTIM_mono();
443	160	if (timebend == 0)
444	40	timebend = 1;
445	120	else if (ch == '<')
446	80	timebend /= 2;
447		else
448	40	timebend *= 2;
449	160	PTOK(pthread_cond_broadcast(&timebend_cv));
450	160	PTOK(pthread_mutex_unlock(&mtx));
451	160	}
452		}
453	120	AC(endwin());
454	120	return (NULL);
455		}
456
457		/--------------------------------------------------------------------/
458
459		static void v_noreturn_
460	200	profile_error(const char *s)
461		{
462	400	fprintf(stderr, "-P: '%s' is not a valid"
463	200	" profile name or definition\n", s);
464	200	exit(1);
465		}
466
467		int
468	760	main(int argc, char **argv)
469		{
470		int i;
471		char *colon;
472	760	const char ptag, profile = "responsetime";
473		pthread_t thr;
474		int fnum;
475	760	struct profile cli_p = {0};
476
477	760	vut = VUT_InitProg(argc, argv, &vopt_spec);
478	760	AN(vut);
479	760	PTOK(pthread_cond_init(&timebend_cv, NULL));
480
481	1120	while ((i = getopt(argc, argv, vopt_spec.vopt_optstring)) != -1) {
482	880	switch (i) {
483		case 'h':
484		/* Usage help */
485	40	VUT_Usage(vut, &vopt_spec, 0);
486		case 'p':
487	120	ms_delay = lround(1e3 * strtod(optarg, NULL));
488	120	if (ms_delay == 0)
489	80	VUT_Error(vut, 1, "-p: invalid '%s'", optarg);
490	40	break;
491		case 'P':
492	440	colon = strchr(optarg, ':');
493		/* no colon, take the profile as a name */
494	440	if (colon == NULL) {
495	80	profile = optarg;
496	80	break;
497		}
498		/* else check if valid definition */
499	360	if (colon == optarg + 1 && (*optarg == 'b' \|\|