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	1168	update(void)
137		{
138		char t[VTIM_FORMAT_SIZE];
139	1168	const unsigned w = COLS / hist_range;
140	1168	const unsigned n = w * hist_range;
141	1168	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	85328	for (k = 0; k < n; ++k)
149	84160	(void)mvaddch(LINES - 2, k, '-');
150	11624	for (i = 0, j = hist_low; i < hist_range; ++i, ++j) {
151	10456	(void)mvaddch(LINES - 2, w * i, '+');
152	10456	IC(mvprintw(LINES - 1, w * i, "\|1e%d", j));
153	10456	}
154
155	1168	if (end_of_file)
156	0	IC(mvprintw(0, 0, "%*s", COLS - 1, "EOF"));
157		else
158	1168	IC(mvprintw(0, 0, "%*s", COLS - 1, ident));
159
160		/* count our flock */
161	1168	memset(bm, 0, sizeof bm);
162	1168	memset(bh, 0, sizeof bh);
163	1046768	for (k = 0, max = 1; k < hist_buckets; ++k) {
164	1045600	l = k * n / hist_buckets;
165	1045600	assert(l < n);
166	1045600	bm[l] += bucket_miss[k];
167	1045600	bh[l] += bucket_hit[k];
168	1045600	max = vmax(max, bm[l] + bh[l]);
169	1045600	}
170
171		/* scale,time */
172	1168	assert(LINES - 3 >= 0);
173	1168	for (i = 0; max / scales[i] > (unsigned)(LINES - 3); ++i)
174		/* nothing */ ;
175	1168	scale = scales[i];
176
177	1168	if (vsl_t0 > 0) {
178	1145	VTIM_format(vsl_ts, t);
179
180	1145	IC(mvprintw(0, 0, "1:%u, n = %u, d = %g @ %s x %g",
181		scale, nhist, 1e-3 * ms_delay, t, timebend));
182	1145	} else {
183	23	IC(mvprintw(0, 0, "1:%u, n = %u, d = %g",
184		scale, nhist, 1e-3 * ms_delay));
185		}
186
187	5840	for (j = 5; j < LINES - 2; j += 5)
188	4672	IC(mvprintw((LINES - 2) - j, 0, "%u_", j * scale));
189
190		/* show them */
191	85328	for (k = 0; k < n; ++k) {
192	85324	for (l = 0; l < bm[k] / scale; ++l)
193	1164	(void)mvaddch((LINES - 3) - l, k, '#');
194	84171	for (; l < (bm[k] + bh[k]) / scale; ++l)
195	11	(void)mvaddch((LINES - 3) - l, k, '\|');
196	84160	}
197	1168	}
198
199		inline static void
200	4	upd_vsl_ts(const char *p)
201		{
202
203	4	if (timebend == 0)
204	3	return;
205
206	1	p = strchr(p, ' ');
207
208	1	if (p == NULL)
209	0	return;
210
211	1	vsl_ts = vmax_t(double, vsl_ts, strtod(p + 1, NULL));
212	4	}
213
214		static void
215	4	delorean(void)
216		{
217		int i;
218	4	double t = VTIM_mono();
219
220	4	if (vsl_t0 == 0)
221	4	vsl_to = vsl_t0 = vsl_ts;
222
223	4	assert(t > t0);
224	4	vsl_to = vsl_t0 + (t - t0) * timebend;
225
226	4	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	4	}
233
234		static int v_matchproto_ (VSLQ_dispatch_f)
235	6	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	6	double value = 0;
241		struct VSL_transaction *tr;
242		const char *tsp;
243		enum vsl_status stat;
244
245	6	(void)vsl;
246	6	(void)priv;
247
248	12	for (tr = pt[0]; tr != NULL; tr = *++pt) {
249	6	if (VSIG_int \|\| VSIG_term \|\| VSIG_hup)
250	0	return (-1);
251
252	6	if (tr->reason == VSL_r_esi) {
253		/* Skip ESI requests */
254	0	continue;
255		}
256
257	6	hit = 0;
258	6	skip = 0;
259	6	match = 0;
260	6	tsp = NULL;
261	185	while (skip == 0) {
262	185	stat = VSL_Next(tr->c);
263	185	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	185	if (stat != vsl_more)
272	6	break;
273
274		/* get the value we want and register if it's a hit */
275	179	tag = VSL_TAG(tr->c->rec.ptr);
276
277	179	if (VSL_tagflags[tag])
278	20	continue;
279
280	159	switch (tag) {
281		case SLT_Hit:
282	1	hit = 1;
283	1	break;
284		case SLT_VCL_return:
285	12	if (!strcasecmp(VSL_CDATA(tr->c->rec.ptr),
286	12	"restart") \|\|
287	12	!strcasecmp(VSL_CDATA(tr->c->rec.ptr),
288		"retry"))
289	0	skip = 1;
290	12	break;
291		case SLT_Timestamp:
292	23	tsp = VSL_CDATA(tr->c->rec.ptr);
293		/* FALLTHROUGH */
294		default:
295	146	if (tag != match_tag)
296	129	break;
297
298	17	if (active_profile->prefix &&
299	32	strncmp(VSL_CDATA(tr->c->rec.ptr),
300	16	active_profile->prefix,
301	32	strlen(active_profile->prefix)) != 0)
302	13	break;
303
304	8	i = sscanf(VSL_CDATA(tr->c->rec.ptr),
305	4	format, &value);
306	4	if (i != 1)
307	0	break;
308	4	match = 1;
309	4	break;
310		}
311		}
312
313	6	if (skip \|\| !match \|\| value <= 0)
314	2	continue;
315
316		/* select bucket */
317	4	i = vlimit_t(int, lround(HIST_RES * log(value) / log_ten),
318	4	hist_low * HIST_RES, hist_high * HIST_RES - 1) -
319	4	hist_low * HIST_RES;
320	4	assert(i >= 0);
321	4	assert((unsigned)i < hist_buckets);
322
323	4	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	4	if (tsp)
330	4	upd_vsl_ts(tsp);
331
332		/* phase out old data */
333	4	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	4	++nhist;
346		}
347
348		/* phase in new data */
349	4	if (hit) {
350	1	bucket_hit[i]++;
351	1	rr_hist[next_hist] = i + hist_buckets;
352	1	} else {
353	3	bucket_miss[i]++;
354	3	rr_hist[next_hist] = i;
355		}
356	4	if (++next_hist == HIST_N) {
357	0	next_hist = 0;
358	0	}
359	4	if (vsl_ts >= vsl_to)
360	4	delorean();
361	4	PTOK(pthread_mutex_unlock(&mtx));
362	4	}
363	6	return (0);
364	6	}
365
366		static void * v_matchproto_(pthread_t)
367	3	do_curses(void *arg)
368		{
369		int ch;
370	3	(void)arg;
371
372	3	(void)initscr();
373	3	AC(raw());
374	3	AC(noecho());
375	3	AC(nonl());
376	3	AC(intrflush(stdscr, FALSE));
377	3	IC(curs_set(0));
378	3	AC(erase());
379	1171	while (!VSIG_int && !VSIG_term && !VSIG_hup) {
380
381	1168	AC(erase());
382	1168	PTOK(pthread_mutex_lock(&mtx));
383	1168	update();
384	1168	PTOK(pthread_mutex_unlock(&mtx));
385	1168	AC(refresh());
386
387	1168	assert(ms_delay > 0);
388	1168	timeout(ms_delay);
389	1168	switch ((ch = getch())) {
390		case ERR:
391	1144	break;
392		#ifdef KEY_RESIZE
393		case KEY_RESIZE:
394	1	AC(erase());
395	1	break;
396		#endif
397		case '\014': /* Ctrl-L */
398		case '\024': /* Ctrl-T */
399	1	AC(redrawwin(stdscr));
400	1	AC(refresh());
401	1	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	1	AZ(raise(SIGINT));
411	1	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	2	ms_delay = 1000U << (ch - '0');
423	2	break;
424		case '+':
425	12	ms_delay = vmax(ms_delay >> 1, 1U);
426	12	break;
427		case '-':
428	2	ms_delay *= 2;
429	2	break;
430		case '>':
431		case '<':
432		/* see below */
433	4	break;
434		default:
435	1	AC(beep());
436	1	break;
437		}
438
439	1168	if (ch == '<' \|\| ch == '>') {
440	4	PTOK(pthread_mutex_lock(&mtx));
441	4	vsl_to = vsl_t0 = vsl_ts;
442	4	t0 = VTIM_mono();
443	4	if (timebend == 0)
444	1	timebend = 1;
445	3	else if (ch == '<')
446	2	timebend /= 2;
447		else
448	1	timebend *= 2;
449	4	PTOK(pthread_cond_broadcast(&timebend_cv));
450	4	PTOK(pthread_mutex_unlock(&mtx));
451	4	}
452		}
453	3	AC(endwin());
454	3	return (NULL);
455		}
456
457		/--------------------------------------------------------------------/
458
459		static void v_noreturn_
460	5	profile_error(const char *s)
461		{
462	10	fprintf(stderr, "-P: '%s' is not a valid"
463	5	" profile name or definition\n", s);
464	5	exit(1);
465		}
466
467		int
468	19	main(int argc, char **argv)
469		{
470		int i;
471		char *colon;
472	19	const char ptag, profile = "responsetime";
473		pthread_t thr;
474		int fnum;
475	19	struct profile cli_p = {0};
476
477	19	vut = VUT_InitProg(argc, argv, &vopt_spec);
478	19	AN(vut);
479	19	PTOK(pthread_cond_init(&timebend_cv, NULL));
480
481	28	while ((i = getopt(argc, argv, vopt_spec.vopt_optstring)) != -1) {
482	22	switch (i) {
483		case 'h':
484		/* Usage help */
485	1	VUT_Usage(vut, &vopt_spec, 0);
486		case 'p':
487	3	ms_delay = lround(1e3 * strtod(optarg, NULL));
488	3	if (ms_delay == 0)
489	2	VUT_Error(vut, 1, "-p: invalid '%s'", optarg);
490	1	break;
491		case 'P':
492	11	colon = strchr(optarg, ':');
493		/* no colon, take the profile as a name */
494	11	if (colon == NULL) {
495	2	profile = optarg;
496	2	break;
497		}
498		/* else check if valid definition */
499	9	if (colon == optarg + 1 && (*optarg == 'b' \|\|