GCOV - Varnish Cache


/*-
 * Copyright (c) 2010-2017 Varnish Software AS
 * All rights reserved.
 *
 * Author: Poul-Henning Kamp <phk@FreeBSD.org>
 *
 * 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.
 */

#include "config.h"

#include <sys/stat.h>

#include <netinet/in.h>

#include <ctype.h>
#include <stdlib.h>
#include <string.h>
#include <syslog.h>
#include <sys/socket.h>
#include <fnmatch.h>

#include "cache/cache.h"

#include "vrnd.h"
#include "vtcp.h"
#include "vsa.h"
#include "vtim.h"
#include "vcl.h"

#include "vcc_std_if.h"

VCL_VOID v_matchproto_(td_std_set_ip_tos)
vmod_set_ip_tos(VRT_CTX, VCL_INT tos)
{
        struct suckaddr *sa;
        int fam, itos = tos;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        AZ(SES_Get_local_addr(ctx->req->sp, &sa));
        /* Silently ignore for non-IP addresses. */
        if (VSA_Compare(sa, bogo_ip) == 0)
                return;
        fam = VSA_Get_Proto(sa);
        switch (fam) {
        case PF_INET:
                VTCP_Assert(setsockopt(ctx->req->sp->fd,
                    IPPROTO_IP, IP_TOS, &itos, sizeof(itos)));
                break;
        case PF_INET6:
                VTCP_Assert(setsockopt(ctx->req->sp->fd,
                    IPPROTO_IPV6, IPV6_TCLASS, &itos, sizeof(itos)));
                break;
        default:
                INCOMPL();
        }
}

static const char *
vmod_updown(VRT_CTX, int up, VCL_STRANDS s)
{
        unsigned u;
        char *b, *e;
        const char *p;
        int i;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        CHECK_OBJ_NOTNULL(s, STRANDS_MAGIC);
        u = WS_ReserveAll(ctx->ws);
        e = b = WS_Reservation(ctx->ws);
        e += u;
        for (i = 0; i < s->n && b < e; i++) {
                p = s->p[i];
                while (p != NULL && *p != '\0' && b < e) {
                        if (up)
                                *b++ = (char)toupper(*p++);
                        else
                                *b++ = (char)tolower(*p++);
                }
        }
        if (b < e)
                *b = '\0';
        b++;
        if (b > e) {
                WS_MarkOverflow(ctx->ws);
                WS_Release(ctx->ws, 0);
                return (NULL);
        } else {
                e = b;
                b = WS_Reservation(ctx->ws);
                WS_Release(ctx->ws, e - b);
                return (b);
        }
}

VCL_STRING v_matchproto_(td_std_toupper)
vmod_toupper(VRT_CTX, VCL_STRANDS s)
{

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        return (vmod_updown(ctx, 1, s));
}

VCL_STRING v_matchproto_(td_std_tolower)
vmod_tolower(VRT_CTX, VCL_STRANDS s)
{

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        return (vmod_updown(ctx, 0, s));
}

VCL_REAL v_matchproto_(td_std_random)
vmod_random(VRT_CTX, VCL_REAL lo, VCL_REAL hi)
{
        double a;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        a = VRND_RandomTestableDouble();
        a *= hi - lo;
        a += lo;
        return (a);
}

VCL_VOID v_matchproto_(td_std_log)
vmod_log(VRT_CTX, VCL_STRANDS s)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);

        if (ctx->vsl != NULL)
                VSLbs(ctx->vsl, SLT_VCL_Log, s);
        else
                VSLs(SLT_VCL_Log, NO_VXID, s);
}

/* XXX use vsyslog() ? */
VCL_VOID v_matchproto_(td_std_syslog)
vmod_syslog(VRT_CTX, VCL_INT fac, VCL_STRANDS s)
{
        const char *p;
        uintptr_t sn;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        sn = WS_Snapshot(ctx->ws);
        p = VRT_StrandsWS(ctx->ws, NULL, s);
        if (p != NULL)
                syslog((int)fac, "%s", p);
        WS_Reset(ctx->ws, sn);
}

VCL_BOOL v_matchproto_(td_std_file_exists)
vmod_file_exists(VRT_CTX, VCL_STRING file_name)
{
        struct stat st;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        return (stat(file_name, &st) == 0);
}

VCL_VOID v_matchproto_(td_std_collect)
vmod_collect(VRT_CTX, VCL_HEADER hdr, VCL_STRING sep)
{
        struct http *hp;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (hdr == NULL) {
                VRT_fail(ctx, "std.collect(): header argument is NULL");
                return;
        }
        hp = VRT_selecthttp(ctx, hdr->where);
        if (hp == NULL) {
                VRT_fail(ctx, "std.collect(): header argument "
                    "cannot be used here");
                return;
        }
        http_CollectHdrSep(hp, hdr->what, sep);
}

VCL_BOOL v_matchproto_(td_std_healthy)
vmod_healthy(VRT_CTX, VCL_BACKEND be)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        CHECK_OBJ_ORNULL(be, DIRECTOR_MAGIC);
        return (VRT_Healthy(ctx, be, NULL));
}

VCL_INT v_matchproto_(td_std_port)
vmod_port(VRT_CTX, VCL_IP ip)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (ip == NULL)
                return (0);
        return (VSA_Port(ip));
}

VCL_VOID v_matchproto_(td_std_rollback)
vmod_rollback(VRT_CTX, VCL_HTTP hp)
{
        VRT_Rollback(ctx, hp);
}

VCL_VOID v_matchproto_(td_std_timestamp)
vmod_timestamp(VRT_CTX, VCL_STRING label)
{

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (label == NULL)
                return;
        if (*label == '\0')
                return;
        if (ctx->bo != NULL && ctx->req == NULL) {
                /* Called from backend vcl methods */
                CHECK_OBJ_NOTNULL(ctx->bo, BUSYOBJ_MAGIC);
                VSLb_ts_busyobj(ctx->bo, label, VTIM_real());
        } else if (ctx->req != NULL) {
                /* Called from request vcl methods */
                CHECK_OBJ(ctx->req, REQ_MAGIC);
                VSLb_ts_req(ctx->req, label, VTIM_real());
        }
}

VCL_BOOL v_matchproto_(td_std_cache_req_body)
vmod_cache_req_body(VRT_CTX, VCL_BYTES size)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        size = vmax_t(VCL_BYTES, size, 0);
        if (VRT_CacheReqBody(ctx, (size_t)size) < 0)
                return (0);
        return (1);
}

VCL_STRING v_matchproto_(td_std_strstr)
vmod_strstr(VRT_CTX, VCL_STRING s1, VCL_STRING s2)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (s1 == NULL || s2 == NULL)
                return (NULL);
        return (strstr(s1, s2));
}

VCL_STRING v_matchproto_(td_std_getenv)
vmod_getenv(VRT_CTX, VCL_STRING name)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (name == NULL || *name == '\0')
                return (NULL);
        return (getenv(name));
}

VCL_VOID v_matchproto_(td_std_late_100_continue)
vmod_late_100_continue(VRT_CTX, VCL_BOOL late)
{
        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        assert(ctx->method == VCL_MET_RECV);
        CHECK_OBJ_NOTNULL(ctx->req, REQ_MAGIC);
        if (ctx->req->want100cont)
                ctx->req->late100cont = late;
}

VCL_BOOL v_matchproto_(td_std_syntax)
vmod_syntax(VRT_CTX, VCL_REAL r)
{

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        assert(ctx->syntax == 40 || ctx->syntax == 41);
        /*
         * We need to be careful because non-integer numbers have imprecise
         * IEE754 representation (4.1 is 0x1.0666666666666p+2 = 4.09999...)
         * By scaling up and rounding, this is taken care of.
         */
        return (round(r * 10) <= ctx->syntax);
}

VCL_BOOL v_matchproto_(td_std_fnmatch)
vmod_fnmatch(VRT_CTX, VCL_STRING pattern, VCL_STRING subject,
             VCL_BOOL pathname, VCL_BOOL noescape, VCL_BOOL period)
{
        int flags = 0;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        if (pattern == NULL) {
                VRT_fail(ctx, "std.fnmatch(): pattern is NULL");
                return (0);
        }
        if (subject == NULL) {
                VRT_fail(ctx, "std.fnmatch(): subject is NULL");
                return (0);
        }

        if (pathname)
                flags |= FNM_PATHNAME;
        if (noescape)
                flags |= FNM_NOESCAPE;
        if (period)
                flags |= FNM_PERIOD;
        return (fnmatch(pattern, subject, flags) != FNM_NOMATCH);
}

static const void * const priv_task_id_ban = &priv_task_id_ban;

VCL_BOOL v_matchproto_(td_std_ban)
vmod_ban(VRT_CTX, VCL_STRING s)
{
        struct vmod_priv *priv_task;
        VCL_STRING r;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);

        r = VRT_ban_string(ctx, s);
        priv_task = VRT_priv_task_get(ctx, priv_task_id_ban);

        if (r == NULL && priv_task == NULL)
                return (1);

        if (priv_task == NULL)
                priv_task = VRT_priv_task(ctx, priv_task_id_ban);

        if (priv_task == NULL) {
                VRT_fail(ctx, "std.ban(): no priv_task (out of workspace?)");
                return (0);
        }

        /*
         * TRUST_ME: the ban error is const. We save it in the un-const priv
         * pointer, but promise to only ever return it as a (const) VCL_STRING
         */
        priv_task->priv = TRUST_ME(r);

        return (r == NULL);
}

VCL_STRING v_matchproto_(td_std_ban_error)
vmod_ban_error(VRT_CTX)
{
        struct vmod_priv *priv_task;
        VCL_STRING r;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);

        priv_task = VRT_priv_task_get(ctx, priv_task_id_ban);
        if (priv_task == NULL)
                return ("");

        r = priv_task->priv;
        if (r == NULL)
                r = "";
        return (r);
}

VCL_TIME v_matchproto_(td_std_now)
vmod_now(VRT_CTX)
{

        (void) ctx;
        return (VTIM_real());
}

VCL_DURATION v_matchproto_(td_std_timed_call)
vmod_timed_call(VRT_CTX, VCL_SUB sub)
{
        vtim_mono b;

        CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
        b = VTIM_mono();
        VRT_call(ctx, sub);
        return (VTIM_mono() - b);
}

		varnish-cache/vmod/vmod_std.c
0		/*-
1		* Copyright (c) 2010-2017 Varnish Software AS
2		* All rights reserved.
3		*
4		* Author: Poul-Henning Kamp <phk@FreeBSD.org>
5		*
6		* SPDX-License-Identifier: BSD-2-Clause
7		*
8		* Redistribution and use in source and binary forms, with or without
9		* modification, are permitted provided that the following conditions
10		* are met:
11		* 1. Redistributions of source code must retain the above copyright
12		* notice, this list of conditions and the following disclaimer.
13		* 2. Redistributions in binary form must reproduce the above copyright
14		* notice, this list of conditions and the following disclaimer in the
15		* documentation and/or other materials provided with the distribution.
16		*
17		* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18		* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19		* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20		* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
21		* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22		* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23		* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24		* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25		* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26		* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27		* SUCH DAMAGE.
28		*/
29
30		#include "config.h"
31
32		#include <sys/stat.h>
33
34		#include <netinet/in.h>
35
36		#include <ctype.h>
37		#include <stdlib.h>
38		#include <string.h>
39		#include <syslog.h>
40		#include <sys/socket.h>
41		#include <fnmatch.h>
42
43		#include "cache/cache.h"
44
45		#include "vrnd.h"
46		#include "vtcp.h"
47		#include "vsa.h"
48		#include "vtim.h"
49		#include "vcl.h"
50
51		#include "vcc_std_if.h"
52
53		VCL_VOID v_matchproto_(td_std_set_ip_tos)
54	8	vmod_set_ip_tos(VRT_CTX, VCL_INT tos)
55		{
56		struct suckaddr *sa;
57	8	int fam, itos = tos;
58
59	8	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
60	8	AZ(SES_Get_local_addr(ctx->req->sp, &sa));
61		/* Silently ignore for non-IP addresses. */
62	8	if (VSA_Compare(sa, bogo_ip) == 0)
63	4	return;
64	4	fam = VSA_Get_Proto(sa);
65	4	switch (fam) {
66		case PF_INET:
67	4	VTCP_Assert(setsockopt(ctx->req->sp->fd,
68		IPPROTO_IP, IP_TOS, &itos, sizeof(itos)));
69	4	break;
70		case PF_INET6:
71	0	VTCP_Assert(setsockopt(ctx->req->sp->fd,
72		IPPROTO_IPV6, IPV6_TCLASS, &itos, sizeof(itos)));
73	0	break;
74		default:
75	0	INCOMPL();
76	0	}
77	8	}
78
79		static const char *
80	48	vmod_updown(VRT_CTX, int up, VCL_STRANDS s)
81		{
82		unsigned u;
83		char b, e;
84		const char *p;
85		int i;
86
87	48	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
88	48	CHECK_OBJ_NOTNULL(s, STRANDS_MAGIC);
89	48	u = WS_ReserveAll(ctx->ws);
90	48	e = b = WS_Reservation(ctx->ws);
91	48	e += u;
92	96	for (i = 0; i < s->n && b < e; i++) {
93	48	p = s->p[i];
94	8776	while (p != NULL && *p != '\0' && b < e) {
95	8728	if (up)
96	4328	b++ = (char)toupper(p++);
97		else
98	4400	b++ = (char)tolower(p++);
99		}
100	48	}
101	48	if (b < e)
102	48	*b = '\0';
103	48	b++;
104	48	if (b > e) {
105	0	WS_MarkOverflow(ctx->ws);
106	0	WS_Release(ctx->ws, 0);
107	0	return (NULL);
108		} else {
109	48	e = b;
110	48	b = WS_Reservation(ctx->ws);
111	48	WS_Release(ctx->ws, e - b);
112	48	return (b);
113		}
114	48	}
115
116		VCL_STRING v_matchproto_(td_std_toupper)
117	16	vmod_toupper(VRT_CTX, VCL_STRANDS s)
118		{
119
120	16	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
121	16	return (vmod_updown(ctx, 1, s));
122		}
123
124		VCL_STRING v_matchproto_(td_std_tolower)
125	32	vmod_tolower(VRT_CTX, VCL_STRANDS s)
126		{
127
128	32	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
129	32	return (vmod_updown(ctx, 0, s));
130		}
131
132		VCL_REAL v_matchproto_(td_std_random)
133	20	vmod_random(VRT_CTX, VCL_REAL lo, VCL_REAL hi)
134		{
135		double a;
136
137	20	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
138	20	a = VRND_RandomTestableDouble();
139	20	a *= hi - lo;
140	20	a += lo;
141	20	return (a);
142		}
143
144		VCL_VOID v_matchproto_(td_std_log)
145	596	vmod_log(VRT_CTX, VCL_STRANDS s)
146		{
147	596	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
148
149	596	if (ctx->vsl != NULL)
150	464	VSLbs(ctx->vsl, SLT_VCL_Log, s);
151		else
152	132	VSLs(SLT_VCL_Log, NO_VXID, s);
153	596	}
154
155		/* XXX use vsyslog() ? */
156		VCL_VOID v_matchproto_(td_std_syslog)
157	20	vmod_syslog(VRT_CTX, VCL_INT fac, VCL_STRANDS s)
158		{
159		const char *p;
160		uintptr_t sn;
161
162	20	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
163	20	sn = WS_Snapshot(ctx->ws);
164	20	p = VRT_StrandsWS(ctx->ws, NULL, s);
165	20	if (p != NULL)
166	16	syslog((int)fac, "%s", p);
167	20	WS_Reset(ctx->ws, sn);
168	20	}
169
170		VCL_BOOL v_matchproto_(td_std_file_exists)
171	8	vmod_file_exists(VRT_CTX, VCL_STRING file_name)
172		{
173		struct stat st;
174
175	8	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
176	8	return (stat(file_name, &st) == 0);
177		}
178
179		VCL_VOID v_matchproto_(td_std_collect)
180	52	vmod_collect(VRT_CTX, VCL_HEADER hdr, VCL_STRING sep)
181		{
182		struct http *hp;
183
184	52	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
185	52	if (hdr == NULL) {
186	0	VRT_fail(ctx, "std.collect(): header argument is NULL");
187	0	return;
188		}
189	52	hp = VRT_selecthttp(ctx, hdr->where);
190	52	if (hp == NULL) {
191	4	VRT_fail(ctx, "std.collect(): header argument "
192		"cannot be used here");
193	4	return;
194		}
195	48	http_CollectHdrSep(hp, hdr->what, sep);
196	52	}
197
198		VCL_BOOL v_matchproto_(td_std_healthy)
199	148	vmod_healthy(VRT_CTX, VCL_BACKEND be)
200		{
201	148	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
202	148	CHECK_OBJ_ORNULL(be, DIRECTOR_MAGIC);
203	148	return (VRT_Healthy(ctx, be, NULL));
204		}
205
206		VCL_INT v_matchproto_(td_std_port)
207	448	vmod_port(VRT_CTX, VCL_IP ip)
208		{
209	448	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
210	448	if (ip == NULL)
211	0	return (0);
212	448	return (VSA_Port(ip));
213	448	}
214
215		VCL_VOID v_matchproto_(td_std_rollback)
216	92	vmod_rollback(VRT_CTX, VCL_HTTP hp)
217		{
218	92	VRT_Rollback(ctx, hp);
219	92	}
220
221		VCL_VOID v_matchproto_(td_std_timestamp)
222	84	vmod_timestamp(VRT_CTX, VCL_STRING label)
223		{
224
225	84	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
226	84	if (label == NULL)
227	0	return;
228	84	if (*label == '\0')
229	0	return;
230	84	if (ctx->bo != NULL && ctx->req == NULL) {
231		/* Called from backend vcl methods */
232	4	CHECK_OBJ_NOTNULL(ctx->bo, BUSYOBJ_MAGIC);
233	4	VSLb_ts_busyobj(ctx->bo, label, VTIM_real());
234	84	} else if (ctx->req != NULL) {
235		/* Called from request vcl methods */
236	76	CHECK_OBJ(ctx->req, REQ_MAGIC);
237	76	VSLb_ts_req(ctx->req, label, VTIM_real());
238	76	}
239	84	}
240
241		VCL_BOOL v_matchproto_(td_std_cache_req_body)
242	140	vmod_cache_req_body(VRT_CTX, VCL_BYTES size)
243		{
244	140	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
245	140	size = vmax_t(VCL_BYTES, size, 0);
246	140	if (VRT_CacheReqBody(ctx, (size_t)size) < 0)
247	20	return (0);
248	120	return (1);
249	140	}
250
251		VCL_STRING v_matchproto_(td_std_strstr)
252	12	vmod_strstr(VRT_CTX, VCL_STRING s1, VCL_STRING s2)
253		{
254	12	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
255	12	if (s1 == NULL \|\| s2 == NULL)
256	4	return (NULL);
257	8	return (strstr(s1, s2));
258	12	}
259
260		VCL_STRING v_matchproto_(td_std_getenv)
261	12	vmod_getenv(VRT_CTX, VCL_STRING name)
262		{
263	12	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
264	12	if (name == NULL \|\| *name == '\0')
265	4	return (NULL);
266	8	return (getenv(name));
267	12	}
268
269		VCL_VOID v_matchproto_(td_std_late_100_continue)
270	20	vmod_late_100_continue(VRT_CTX, VCL_BOOL late)
271		{
272	20	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
273	20	assert(ctx->method == VCL_MET_RECV);
274	20	CHECK_OBJ_NOTNULL(ctx->req, REQ_MAGIC);
275	20	if (ctx->req->want100cont)
276	20	ctx->req->late100cont = late;
277	20	}
278
279		VCL_BOOL v_matchproto_(td_std_syntax)
280	24	vmod_syntax(VRT_CTX, VCL_REAL r)
281		{
282
283	24	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
284	24	assert(ctx->syntax == 40 \|\| ctx->syntax == 41);
285		/*
286		* We need to be careful because non-integer numbers have imprecise
287		* IEE754 representation (4.1 is 0x1.0666666666666p+2 = 4.09999...)
288		* By scaling up and rounding, this is taken care of.
289		*/
290	24	return (round(r * 10) <= ctx->syntax);
291		}
292
293		VCL_BOOL v_matchproto_(td_std_fnmatch)
294	248	vmod_fnmatch(VRT_CTX, VCL_STRING pattern, VCL_STRING subject,
295		VCL_BOOL pathname, VCL_BOOL noescape, VCL_BOOL period)
296		{
297	248	int flags = 0;
298
299	248	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
300	248	if (pattern == NULL) {
301	4	VRT_fail(ctx, "std.fnmatch(): pattern is NULL");
302	4	return (0);
303		}
304	244	if (subject == NULL) {
305	4	VRT_fail(ctx, "std.fnmatch(): subject is NULL");
306	4	return (0);
307		}
308
309	240	if (pathname)
310	180	flags \|= FNM_PATHNAME;
311	240	if (noescape)
312	60	flags \|= FNM_NOESCAPE;
313	240	if (period)
314	60	flags \|= FNM_PERIOD;
315	240	return (fnmatch(pattern, subject, flags) != FNM_NOMATCH);
316	248	}
317
318		static const void * const priv_task_id_ban = &priv_task_id_ban;
319
320		VCL_BOOL v_matchproto_(td_std_ban)
321	88	vmod_ban(VRT_CTX, VCL_STRING s)
322		{
323		struct vmod_priv *priv_task;
324		VCL_STRING r;
325
326	88	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
327
328	88	r = VRT_ban_string(ctx, s);
329	88	priv_task = VRT_priv_task_get(ctx, priv_task_id_ban);
330
331	88	if (r == NULL && priv_task == NULL)
332	40	return (1);
333
334	48	if (priv_task == NULL)
335	8	priv_task = VRT_priv_task(ctx, priv_task_id_ban);
336
337	48	if (priv_task == NULL) {
338	0	VRT_fail(ctx, "std.ban(): no priv_task (out of workspace?)");
339	0	return (0);
340		}
341
342		/*
343		* TRUST_ME: the ban error is const. We save it in the un-const priv
344		* pointer, but promise to only ever return it as a (const) VCL_STRING
345		*/
346	48	priv_task->priv = TRUST_ME(r);
347
348	48	return (r == NULL);
349	88	}
350
351		VCL_STRING v_matchproto_(td_std_ban_error)
352	48	vmod_ban_error(VRT_CTX)
353		{
354		struct vmod_priv *priv_task;
355		VCL_STRING r;
356
357	48	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
358
359	48	priv_task = VRT_priv_task_get(ctx, priv_task_id_ban);
360	48	if (priv_task == NULL)
361	0	return ("");
362
363	48	r = priv_task->priv;
364	48	if (r == NULL)
365	4	r = "";
366	48	return (r);
367	48	}
368
369		VCL_TIME v_matchproto_(td_std_now)
370	8	vmod_now(VRT_CTX)
371		{
372
373	8	(void) ctx;
374	8	return (VTIM_real());
375		}
376
377		VCL_DURATION v_matchproto_(td_std_timed_call)
378	4	vmod_timed_call(VRT_CTX, VCL_SUB sub)
379		{
380		vtim_mono b;
381
382	4	CHECK_OBJ_NOTNULL(ctx, VRT_CTX_MAGIC);
383	4	b = VTIM_mono();
384	4	VRT_call(ctx, sub);
385	4	return (VTIM_mono() - b);
386		}