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>
 *
 * 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.
 *
 * Statistics output program
 */

#include "config.h"

#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include <math.h>

#define VOPT_DEFINITION
#define VOPT_INC "varnishstat_options.h"

#include "vapi/voptget.h"
#include "vapi/vsl.h"
#include "vdef.h"
#include "vut.h"

#include "varnishstat.h"

static struct VUT *vut;
int has_f = 0;

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

static int v_matchproto_(VSC_iter_f)
do_xml_cb(void *priv, const struct VSC_point * const pt)
{
        uint64_t val;

        (void)priv;
        if (pt == NULL)
                return (0);
        AZ(strcmp(pt->ctype, "uint64_t"));
        val = VSC_Value(pt);

        printf("\t<stat>\n");
        printf("\t\t<name>%s</name>\n", pt->name);
        printf("\t\t<value>%ju</value>\n", (uintmax_t)val);
        printf("\t\t<flag>%c</flag>\n", pt->semantics);
        printf("\t\t<format>%c</format>\n", pt->format);
        printf("\t\t<description>%s</description>\n", pt->sdesc);
        printf("\t</stat>\n");
        return (0);
}

static void
do_xml(struct vsm *vsm, struct vsc *vsc)
{
        char time_stamp[20];
        time_t now;

        printf("<?xml version=\"1.0\"?>\n");
        now = time(NULL);
        (void)strftime(time_stamp, 20, "%Y-%m-%dT%H:%M:%S", localtime(&now));
        printf("<varnishstat timestamp=\"%s\">\n", time_stamp);
        (void)VSC_Iter(vsc, vsm, do_xml_cb, NULL);
        printf("</varnishstat>\n");
}


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

static int v_matchproto_(VSC_iter_f)
do_json_cb(void *priv, const struct VSC_point * const pt)
{
        const char **sep;
        uintmax_t val;

        if (pt == NULL)
                return (0);

        AZ(strcmp(pt->ctype, "uint64_t"));
        val = (uintmax_t)VSC_Value(pt);

        sep = priv;

        printf(
            "%s"
            "    \"%s\": {\n"
            "      \"description\": \"%s\",\n"
            "      \"flag\": \"%c\",\n"
            "      \"format\": \"%c\",\n"
            "      \"value\": %ju\n"
            "    }",
            *sep, pt->name, pt->sdesc, pt->semantics, pt->format, val);

        *sep = ",\n";
        return (0);
}

static void
do_json(struct vsm *vsm, struct vsc *vsc)
{
        const char *sep;
        char time_stamp[20];
        time_t now;

        sep = "";
        now = time(NULL);

        (void)strftime(time_stamp, 20, "%Y-%m-%dT%H:%M:%S", localtime(&now));
        printf(
            "{\n"
            "  \"version\": 1,\n"
            "  \"timestamp\": \"%s\",\n"
            "  \"counters\": {\n", time_stamp);
        (void)VSC_Iter(vsc, vsm, do_json_cb, &sep);
        printf(
            "\n"
            "  }\n"
            "}\n");
}


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

struct once_priv {
        double  up;
        int pad;
};

static int v_matchproto_(VSC_iter_f)
do_once_cb_first(void *priv, const struct VSC_point * const pt)
{
        struct once_priv *op;
        uint64_t val;

        if (pt == NULL)
                return (0);
        op = priv;
        AZ(strcmp(pt->ctype, "uint64_t"));
        if (strcmp(pt->name, "MAIN.uptime"))
                return (0);
        val = VSC_Value(pt);
        op->up = (double)val;
        return (1);
}

static int v_matchproto_(VSC_iter_f)
do_once_cb(void *priv, const struct VSC_point * const pt)
{
        struct once_priv *op;
        uint64_t val;
        int i;

        if (pt == NULL)
                return (0);
        op = priv;
        AZ(strcmp(pt->ctype, "uint64_t"));
        val = VSC_Value(pt);
        i = 0;
        i += printf("%s", pt->name);
        if (i >= op->pad)
                op->pad = i + 1;
        printf("%*.*s", op->pad - i, op->pad - i, "");
        if (pt->semantics == 'c')
                printf("%12ju %12.2f %s\n",
                    (uintmax_t)val, op->up ? val / op->up : 0,
                    pt->sdesc);
        else
                printf("%12ju %12s %s\n",
                    (uintmax_t)val, ".  ", pt->sdesc);
        return (0);
}

static void
do_once(struct vsm *vsm, struct vsc *vsc)
{
        struct vsc *vsconce = VSC_New();
        struct once_priv op;

        AN(vsconce);
        AN(VSC_Arg(vsconce, 'f', "MAIN.uptime"));

        memset(&op, 0, sizeof op);
        op.pad = 18;

        (void)VSC_Iter(vsconce, vsm, do_once_cb_first, &op);
        VSC_Destroy(&vsconce, vsm);
        (void)VSC_Iter(vsc, vsm, do_once_cb, &op);
}

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

static int v_matchproto_(VSC_iter_f)
do_list_cb(void *priv, const struct VSC_point * const pt)
{
        int i;

        (void)priv;

        if (pt == NULL)
                return (0);

        i = 0;
        i += printf("%s", pt->name);
        if (i < 30)
                printf("%*s", i - 30, "");
        printf(" %s\n", pt->sdesc);
        return (0);
}

static void
list_fields(struct vsm *vsm, struct vsc *vsc)
{
        printf("Varnishstat -f option fields:\n");
        printf("Field name                     Description\n");
        printf("----------                     -----------\n");

        (void)VSC_Iter(vsc, vsm, do_list_cb, NULL);
}

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

static void v_noreturn_
usage(int status)
{
        const char **opt;

        fprintf(stderr, "Usage: %s <options>\n\n", vut->progname);
        fprintf(stderr, "Options:\n");
        for (opt = vopt_spec.vopt_usage; *opt != NULL; opt +=2)
                fprintf(stderr, " %-25s %s\n", *opt, *(opt + 1));
        exit(status);
}

static int
key_bindings(void)
{

#define BINDING_KEY(chr, name, next)    \
        printf("<%s>" next, name);
#define BINDING(name, desc)             \
        printf("\n%s\n\n", desc);
#include "varnishstat_bindings.h"
        return (0);
}

int
main(int argc, char * const *argv)
{
        struct vsm *vd;
        int once = 0, xml = 0, json = 0, f_list = 0, curses = 0;
        signed char opt;
        int i;
        struct vsc *vsc;

        if (argc == 2 && !strcmp(argv[1], "--bindings"))
                exit(key_bindings());

        vut = VUT_InitProg(argc, argv, &vopt_spec);
        AN(vut);
        vd = VSM_New();
        AN(vd);
        vsc = VSC_New();
        AN(vsc);

        while ((opt = getopt(argc, argv, vopt_spec.vopt_optstring)) != -1) {
                switch (opt) {
                case '1':
                        once = 1;
                        break;
                case 'c':
                        curses = 1;
                        break;
                case 'h':
                        /* Usage help */
                        usage(0);
                        break;
                case 'l':
                        f_list = 1;
                        break;
                case 'x':
                        xml = 1;
                        break;
                case 'j':
                        json = 1;
                        break;
                case 'I':
                case 'X':
                case 'f':
                        AN(VSC_Arg(vsc, opt, optarg));
                        has_f = 1;
                        break;
                case 'r':
                        AN(VSC_Arg(vsc, opt, optarg));
                        break;
                case 'V':
                        AN(VUT_Arg(vut, opt, optarg));
                        break;
                default:
                        i = VSM_Arg(vd, opt, optarg);
                        if (i < 0)
                                VUT_Error(vut, 1, "%s", VSM_Error(vd));
                        if (!i)
                                usage(1);
                }
        }

        if (optind != argc)
                usage(1);

        if (!(curses || xml || json || once || f_list)) {
                curses = isatty(STDOUT_FILENO);
                once = !curses;
        }

        if (VSM_Attach(vd, STDERR_FILENO))
                VUT_Error(vut, 1, "%s", VSM_Error(vd));

        if (curses) {
                if (has_f) {
                        AN(VSC_Arg(vsc, 'R', "MGT.uptime"));
                        AN(VSC_Arg(vsc, 'R', "MAIN.uptime"));
                        AN(VSC_Arg(vsc, 'R', "MAIN.cache_hit"));
                        AN(VSC_Arg(vsc, 'R', "MAIN.cache_miss"));
                }
                do_curses(vd, vsc);
        }
        else if (xml)
                do_xml(vd, vsc);
        else if (json)
                do_json(vd, vsc);
        else if (once)
                do_once(vd, vsc);
        else if (f_list)
                list_fields(vd, vsc);
        else
                WRONG("undefined varnishstat mode");

        exit(0);
}

		varnish-cache/bin/varnishstat/varnishstat.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		*
8		* SPDX-License-Identifier: BSD-2-Clause
9		*
10		* Redistribution and use in source and binary forms, with or without
11		* modification, are permitted provided that the following conditions
12		* are met:
13		* 1. Redistributions of source code must retain the above copyright
14		* notice, this list of conditions and the following disclaimer.
15		* 2. Redistributions in binary form must reproduce the above copyright
16		* notice, this list of conditions and the following disclaimer in the
17		* documentation and/or other materials provided with the distribution.
18		*
19		* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
20		* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21		* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22		* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
23		* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24		* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25		* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26		* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27		* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28		* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29		* SUCH DAMAGE.
30		*
31		* Statistics output program
32		*/
33
34		#include "config.h"
35
36		#include <stdarg.h>
37		#include <stdio.h>
38		#include <stdlib.h>
39		#include <signal.h>
40		#include <string.h>
41		#include <time.h>
42		#include <unistd.h>
43		#include <math.h>
44
45		#define VOPT_DEFINITION
46		#define VOPT_INC "varnishstat_options.h"
47
48		#include "vapi/voptget.h"
49		#include "vapi/vsl.h"
50		#include "vdef.h"
51		#include "vut.h"
52
53		#include "varnishstat.h"
54
55		static struct VUT *vut;
56		int has_f = 0;
57
58		/--------------------------------------------------------------------/
59
60		static int v_matchproto_(VSC_iter_f)
61	15200	do_xml_cb(void priv, const struct VSC_point const pt)
62		{
63		uint64_t val;
64
65	15200	(void)priv;
66	15200	if (pt == NULL)
67	0	return (0);
68	15200	AZ(strcmp(pt->ctype, "uint64_t"));
69	15200	val = VSC_Value(pt);
70
71	15200	printf("\t<stat>\n");
72	15200	printf("\t\t<name>%s</name>\n", pt->name);
73	15200	printf("\t\t<value>%ju</value>\n", (uintmax_t)val);
74	15200	printf("\t\t<flag>%c</flag>\n", pt->semantics);
75	15200	printf("\t\t<format>%c</format>\n", pt->format);
76	15200	printf("\t\t<description>%s</description>\n", pt->sdesc);
77	15200	printf("\t</stat>\n");
78	15200	return (0);
79	15200	}
80
81		static void
82	40	do_xml(struct vsm vsm, struct vsc vsc)
83		{
84		char time_stamp[20];
85		time_t now;
86
87	40	printf("<?xml version=\"1.0\"?>\n");
88	40	now = time(NULL);
89	40	(void)strftime(time_stamp, 20, "%Y-%m-%dT%H:%M:%S", localtime(&now));
90	40	printf("<varnishstat timestamp=\"%s\">\n", time_stamp);
91	40	(void)VSC_Iter(vsc, vsm, do_xml_cb, NULL);
92	40	printf("</varnishstat>\n");
93	40	}
94
95
96		/--------------------------------------------------------------------/
97
98		static int v_matchproto_(VSC_iter_f)
99	60800	do_json_cb(void priv, const struct VSC_point const pt)
100		{
101		const char **sep;
102		uintmax_t val;
103
104	60800	if (pt == NULL)
105	0	return (0);
106
107	60800	AZ(strcmp(pt->ctype, "uint64_t"));
108	60800	val = (uintmax_t)VSC_Value(pt);
109
110	60800	sep = priv;
111
112	60800	printf(
113		"%s"
114		" \"%s\": {\n"
115		" \"description\": \"%s\",\n"
116		" \"flag\": \"%c\",\n"
117		" \"format\": \"%c\",\n"
118		" \"value\": %ju\n"
119		" }",
120	60800	*sep, pt->name, pt->sdesc, pt->semantics, pt->format, val);
121
122	60800	*sep = ",\n";
123	60800	return (0);
124	60800	}
125
126		static void
127	160	do_json(struct vsm vsm, struct vsc vsc)
128		{
129		const char *sep;
130		char time_stamp[20];
131		time_t now;
132
133	160	sep = "";
134	160	now = time(NULL);
135
136	160	(void)strftime(time_stamp, 20, "%Y-%m-%dT%H:%M:%S", localtime(&now));
137	160	printf(
138		"{\n"
139		" \"version\": 1,\n"
140		" \"timestamp\": \"%s\",\n"
141	160	" \"counters\": {\n", time_stamp);
142	160	(void)VSC_Iter(vsc, vsm, do_json_cb, &sep);
143	160	printf(
144		"\n"
145		" }\n"
146		"}\n");
147	160	}
148
149
150		/--------------------------------------------------------------------/
151
152		struct once_priv {
153		double up;
154		int pad;
155		};
156
157		static int v_matchproto_(VSC_iter_f)
158	400	do_once_cb_first(void priv, const struct VSC_point const pt)
159		{
160		struct once_priv *op;
161		uint64_t val;
162
163	400	if (pt == NULL)
164	0	return (0);
165	400	op = priv;
166	400	AZ(strcmp(pt->ctype, "uint64_t"));
167	400	if (strcmp(pt->name, "MAIN.uptime"))
168	0	return (0);
169	400	val = VSC_Value(pt);
170	400	op->up = (double)val;
171	400	return (1);
172	400	}
173
174		static int v_matchproto_(VSC_iter_f)
175	150200	do_once_cb(void priv, const struct VSC_point const pt)
176		{
177		struct once_priv *op;
178		uint64_t val;
179		int i;
180
181	150200	if (pt == NULL)
182	0	return (0);
183	150200	op = priv;
184	150200	AZ(strcmp(pt->ctype, "uint64_t"));
185	150200	val = VSC_Value(pt);
186	150200	i = 0;
187	150200	i += printf("%s", pt->name);
188	150200	if (i >= op->pad)
189	960	op->pad = i + 1;
190	150200	printf("%.s", op->pad - i, op->pad - i, "");
191	150200	if (pt->semantics == 'c')
192	133160	printf("%12ju %12.2f %s\n",
193	133160	(uintmax_t)val, op->up ? val / op->up : 0,
194	133160	pt->sdesc);
195		else
196	17040	printf("%12ju %12s %s\n",
197	17040	(uintmax_t)val, ". ", pt->sdesc);
198	150200	return (0);
199	150200	}
200
201		static void
202	400	do_once(struct vsm vsm, struct vsc vsc)
203		{
204	400	struct vsc *vsconce = VSC_New();
205		struct once_priv op;
206
207	400	AN(vsconce);
208	400	AN(VSC_Arg(vsconce, 'f', "MAIN.uptime"));
209
210	400	memset(&op, 0, sizeof op);
211	400	op.pad = 18;
212
213	400	(void)VSC_Iter(vsconce, vsm, do_once_cb_first, &op);
214	400	VSC_Destroy(&vsconce, vsm);
215	400	(void)VSC_Iter(vsc, vsm, do_once_cb, &op);
216	400	}
217
218		/--------------------------------------------------------------------/
219
220		static int v_matchproto_(VSC_iter_f)
221	15200	do_list_cb(void priv, const struct VSC_point const pt)
222		{
223		int i;
224
225	15200	(void)priv;
226
227	15200	if (pt == NULL)
228	0	return (0);
229
230	15200	i = 0;
231	15200	i += printf("%s", pt->name);
232	15200	if (i < 30)
233	15080	printf("%*s", i - 30, "");
234	15200	printf(" %s\n", pt->sdesc);
235	15200	return (0);
236	15200	}
237
238		static void
239	40	list_fields(struct vsm vsm, struct vsc vsc)
240		{
241	40	printf("Varnishstat -f option fields:\n");
242	40	printf("Field name Description\n");
243	40	printf("---------- -----------\n");
244
245	40	(void)VSC_Iter(vsc, vsm, do_list_cb, NULL);
246	40	}
247
248		/--------------------------------------------------------------------/
249
250		static void v_noreturn_
251	80	usage(int status)
252		{
253		const char **opt;
254
255	80	fprintf(stderr, "Usage: %s <options>\n\n", vut->progname);
256	80	fprintf(stderr, "Options:\n");
257	1120	for (opt = vopt_spec.vopt_usage; *opt != NULL; opt +=2)
258	1040	fprintf(stderr, " %-25s %s\n", opt, (opt + 1));
259	80	exit(status);
260		}
261
262		static int
263	40	key_bindings(void)
264		{
265
266		#define BINDING_KEY(chr, name, next) \
267		printf("<%s>" next, name);
268		#define BINDING(name, desc) \
269		printf("\n%s\n\n", desc);
270		#include "varnishstat_bindings.h"
271		return (0);
272		}
273
274		int
275	1240	main(int argc, char * const *argv)
276		{
277		struct vsm *vd;
278	1240	int once = 0, xml = 0, json = 0, f_list = 0, curses = 0;
279		signed char opt;
280		int i;
281		struct vsc *vsc;
282
283	1240	if (argc == 2 && !strcmp(argv[1], "--bindings"))
284	40	exit(key_bindings());
285
286	1200	vut = VUT_InitProg(argc, argv, &vopt_spec);
287	1200	AN(vut);
288	1200	vd = VSM_New();
289	1200	AN(vd);
290	1200	vsc = VSC_New();
291	1200	AN(vsc);
292
293	3600	while ((opt = getopt(argc, argv, vopt_spec.vopt_optstring)) != -1) {
294	2560	switch (opt) {
295		case '1':
296	400	once = 1;
297	400	break;
298		case 'c':
299	0	curses = 1;
300	0	break;
301		case 'h':
302		/* Usage help */
303	40	usage(0);
304		break;
305		case 'l':
306	40	f_list = 1;
307	40	break;
308		case 'x':
309	40	xml = 1;
310	40	break;
311		case 'j':
312	160	json = 1;
313	160	break;
314		case 'I':
315		case 'X':
316		case 'f':
317	760	AN(VSC_Arg(vsc, opt, optarg));
318	760	has_f = 1;
319	760	break;
320		case 'r':
321	0	AN(VSC_Arg(vsc, opt, optarg));
322	0	break;
323		case 'V':
324	0	AN(VUT_Arg(vut, opt, optarg));
325	0	break;
326		default:
327	1120	i = VSM_Arg(vd, opt, optarg);
328	1120	if (i < 0)
329	120	VUT_Error(vut, 1, "%s", VSM_Error(vd));
330	1000	if (!i)
331	0	usage(1);
332	1000	}
333		}
334
335	1040	if (optind != argc)
336	40	usage(1);
337
338	1000	if (!(curses \|\| xml \|\| json \|\| once \|\| f_list)) {
339	360	curses = isatty(STDOUT_FILENO);
340	360	once = !curses;
341	360	}
342
343	1000	if (VSM_Attach(vd, STDERR_FILENO))
344	80	VUT_Error(vut, 1, "%s", VSM_Error(vd));
345
346	920	if (curses) {
347	280	if (has_f) {
348	80	AN(VSC_Arg(vsc, 'R', "MGT.uptime"));
349	80	AN(VSC_Arg(vsc, 'R', "MAIN.uptime"));
350	80	AN(VSC_Arg(vsc, 'R', "MAIN.cache_hit"));
351	80	AN(VSC_Arg(vsc, 'R', "MAIN.cache_miss"));
352	80	}
353	280	do_curses(vd, vsc);
354	280	}
355	640	else if (xml)
356	40	do_xml(vd, vsc);
357	600	else if (json)
358	160	do_json(vd, vsc);
359	440	else if (once)
360	400	do_once(vd, vsc);
361	40	else if (f_list)
362	40	list_fields(vd, vsc);
363		else
364	0	WRONG("undefined varnishstat mode");
365
366	920	exit(0);
367		}