| | varnish-cache/lib/libvcc/vcc_utils.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 |
|
* |
7 |
|
* SPDX-License-Identifier: BSD-2-Clause |
8 |
|
* |
9 |
|
* Redistribution and use in source and binary forms, with or without |
10 |
|
* modification, are permitted provided that the following conditions |
11 |
|
* are met: |
12 |
|
* 1. Redistributions of source code must retain the above copyright |
13 |
|
* notice, this list of conditions and the following disclaimer. |
14 |
|
* 2. Redistributions in binary form must reproduce the above copyright |
15 |
|
* notice, this list of conditions and the following disclaimer in the |
16 |
|
* documentation and/or other materials provided with the distribution. |
17 |
|
* |
18 |
|
* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND |
19 |
|
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE |
20 |
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE |
21 |
|
* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE |
22 |
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL |
23 |
|
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS |
24 |
|
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) |
25 |
|
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT |
26 |
|
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY |
27 |
|
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF |
28 |
|
* SUCH DAMAGE. |
29 |
|
*/ |
30 |
|
|
31 |
|
#include "config.h" |
32 |
|
|
33 |
|
#include <math.h> |
34 |
|
#include <string.h> |
35 |
|
#include <stdlib.h> |
36 |
|
#include <sys/socket.h> |
37 |
|
#include <sys/types.h> |
38 |
|
#include <unistd.h> |
39 |
|
|
40 |
|
#include "vcc_compile.h" |
41 |
|
|
42 |
|
#include "vre.h" |
43 |
|
#include "vnum.h" |
44 |
|
#include "vsa.h" |
45 |
|
#include "vss.h" |
46 |
|
#include "vtcp.h" |
47 |
|
|
48 |
|
/*--------------------------------------------------------------------*/ |
49 |
|
|
50 |
|
static void |
51 |
336400 |
vcc_cstrcat(struct vcc *tl, struct vsb *vsb) |
52 |
|
{ |
53 |
|
struct token *t1; |
54 |
|
|
55 |
336400 |
assert(tl->t->tok == CSTR); |
56 |
336400 |
VSB_cat(vsb, tl->t->dec); |
57 |
|
|
58 |
336400 |
t1 = vcc_PeekToken(tl); |
59 |
336400 |
AN(t1); |
60 |
|
|
61 |
336560 |
while (t1->tok == '+') { |
62 |
200 |
vcc_NextToken(tl); |
63 |
200 |
SkipToken(tl, '+'); |
64 |
200 |
ExpectErr(tl, CSTR); |
65 |
160 |
VSB_cat(vsb, tl->t->dec); |
66 |
160 |
t1 = vcc_PeekToken(tl); |
67 |
160 |
AN(t1); |
68 |
|
} |
69 |
336400 |
} |
70 |
|
|
71 |
|
void |
72 |
336400 |
vcc_regexp(struct vcc *tl, struct vsb *vgc_name) |
73 |
|
{ |
74 |
|
struct vsb *pattern; |
75 |
|
struct token *t0; |
76 |
|
char buf[BUFSIZ]; |
77 |
|
vre_t *t; |
78 |
|
int error, erroroffset; |
79 |
|
struct inifin *ifp; |
80 |
|
|
81 |
336400 |
t0 = tl->t; |
82 |
336400 |
pattern = VSB_new_auto(); |
83 |
336400 |
AN(pattern); |
84 |
336400 |
vcc_cstrcat(tl, pattern); |
85 |
336400 |
AZ(VSB_finish(pattern)); |
86 |
|
|
87 |
336400 |
t = VRE_compile(VSB_data(pattern), 0, &error, &erroroffset, 0); |
88 |
336400 |
if (t == NULL) { |
89 |
80 |
VSB_cat(tl->sb, "Regexp compilation error:\n\n"); |
90 |
80 |
AZ(VRE_error(tl->sb, error)); |
91 |
80 |
VSB_cat(tl->sb, "\n\n"); |
92 |
80 |
vcc_ErrWhere2(tl, t0, tl->t); |
93 |
80 |
VSB_destroy(&pattern); |
94 |
80 |
return; |
95 |
|
} |
96 |
336320 |
VRE_free(&t); |
97 |
336320 |
bprintf(buf, "VGC_re_%u", tl->unique++); |
98 |
336320 |
if (vgc_name) |
99 |
336320 |
VSB_cat(vgc_name, buf); |
100 |
|
|
101 |
336320 |
Fh(tl, 0, "static struct vre *%s;\n", buf); |
102 |
336320 |
ifp = New_IniFin(tl); |
103 |
336320 |
VSB_printf(ifp->ini, "\tVPI_re_init(&%s, ",buf); |
104 |
336320 |
VSB_quote(ifp->ini, VSB_data(pattern), -1, VSB_QUOTE_CSTR); |
105 |
336320 |
VSB_cat(ifp->ini, ");"); |
106 |
336320 |
VSB_printf(ifp->fin, "\t\tVPI_re_fini(%s);", buf); |
107 |
336320 |
VSB_destroy(&pattern); |
108 |
336400 |
} |
109 |
|
|
110 |
|
/* |
111 |
|
* The IPv6 crew royally screwed up the entire idea behind |
112 |
|
* struct sockaddr, see libvarnish/vsa.c for blow-by-blow account. |
113 |
|
* |
114 |
|
* There is no sane or even remotely portable way to initialize |
115 |
|
* a sockaddr for random protocols at compile time. |
116 |
|
* |
117 |
|
* In our case it is slightly more tricky than that, because we don't |
118 |
|
* even want to #include the struct sockaddr* definitions. |
119 |
|
* |
120 |
|
* Instead we make sure the sockaddr is sane (for our values of |
121 |
|
* sane) and dump it as our own "struct suckaddr" type, in binary, |
122 |
|
* using the widest integer type, hoping that this will ensure sufficient |
123 |
|
* alignment. |
124 |
|
*/ |
125 |
|
|
126 |
|
static void |
127 |
54280 |
vcc_suckaddr(struct vcc *tl, const char *host, const struct suckaddr *vsa, |
128 |
|
const char **ip, const char **ip_ascii, const char **p_ascii) |
129 |
|
{ |
130 |
|
char a[VTCP_ADDRBUFSIZE]; |
131 |
|
char p[VTCP_PORTBUFSIZE]; |
132 |
54280 |
const int sz = sizeof(unsigned long long); |
133 |
54280 |
const unsigned n = (vsa_suckaddr_len + sz - 1) / sz; |
134 |
54280 |
unsigned long long b[n]; |
135 |
|
unsigned len; |
136 |
|
char *q; |
137 |
|
|
138 |
54280 |
VTCP_name(vsa, a, sizeof a, p, sizeof p); |
139 |
54280 |
Fh(tl, 0, "\n/* \"%s\" -> %s */\n", host, a); |
140 |
54280 |
if (ip_ascii != NULL) |
141 |
53200 |
*ip_ascii = TlDup(tl, a); |
142 |
54280 |
if (p_ascii != NULL && *p_ascii == NULL) |
143 |
53160 |
*p_ascii = TlDup(tl, p); |
144 |
|
|
145 |
54280 |
Fh(tl, 0, "static const unsigned long long"); |
146 |
54280 |
Fh(tl, 0, " suckaddr_%u[%d] = {\n", tl->unique, n); |
147 |
54280 |
memcpy(b, vsa, vsa_suckaddr_len); |
148 |
271400 |
for (len = 0; len < n; len++) |
149 |
434240 |
Fh(tl, 0, "%s 0x%0*llxULL", |
150 |
217120 |
len ? ",\n" : "", sz * 2, b[len]); |
151 |
54280 |
Fh(tl, 0, "\n};\n"); |
152 |
|
|
153 |
54280 |
q = TlAlloc(tl, 40); |
154 |
54280 |
AN(q); |
155 |
54280 |
assert(snprintf(q, 40, "(const void*)suckaddr_%u", tl->unique) < 40); |
156 |
54280 |
*ip = q; |
157 |
54280 |
tl->unique++; |
158 |
54280 |
} |
159 |
|
|
160 |
|
/*-------------------------------------------------------------------- |
161 |
|
* This routine is a monster, but at least we only have one such monster. |
162 |
|
* Look up a IP number, and return IPv4/IPv6 address as VGC produced names |
163 |
|
* and optionally ascii strings. |
164 |
|
* |
165 |
|
* For IP compile time constants we only want one IP#, but it can be |
166 |
|
* IPv4 or IPv6. |
167 |
|
* |
168 |
|
* For backends, we accept up to one IPv4 and one IPv6. |
169 |
|
*/ |
170 |
|
|
171 |
|
struct rss { |
172 |
|
unsigned magic; |
173 |
|
#define RSS_MAGIC 0x11e966ab |
174 |
|
|
175 |
|
const struct suckaddr *vsa4; |
176 |
|
const struct suckaddr *vsa6; |
177 |
|
struct vsb *vsb; |
178 |
|
int retval; |
179 |
|
int wrong; |
180 |
|
}; |
181 |
|
|
182 |
|
static int v_matchproto_(vss_resolved_f) |
183 |
54360 |
rs_callback(void *priv, const struct suckaddr *vsa) |
184 |
|
{ |
185 |
|
struct rss *rss; |
186 |
|
int v; |
187 |
|
char a[VTCP_ADDRBUFSIZE]; |
188 |
|
char p[VTCP_PORTBUFSIZE]; |
189 |
|
|
190 |
54360 |
CAST_OBJ_NOTNULL(rss, priv, RSS_MAGIC); |
191 |
54360 |
assert(VSA_Sane(vsa)); |
192 |
|
|
193 |
54360 |
v = VSA_Get_Proto(vsa); |
194 |
54360 |
assert(v != AF_UNIX); |
195 |
54360 |
VTCP_name(vsa, a, sizeof a, p, sizeof p); |
196 |
54360 |
VSB_printf(rss->vsb, "\t%s:%s\n", a, p); |
197 |
54360 |
if (v == AF_INET) { |
198 |
53760 |
if (rss->vsa4 == NULL) |
199 |
53680 |
rss->vsa4 = VSA_Clone(vsa); |
200 |
80 |
else if (VSA_Compare(vsa, rss->vsa4)) |
201 |
80 |
rss->wrong++; |
202 |
53760 |
rss->retval++; |
203 |
54360 |
} else if (v == AF_INET6) { |
204 |
600 |
if (rss->vsa6 == NULL) |
205 |
600 |
rss->vsa6 = VSA_Clone(vsa); |
206 |
0 |
else if (VSA_Compare(vsa, rss->vsa6)) |
207 |
0 |
rss->wrong++; |
208 |
600 |
rss->retval++; |
209 |
600 |
} |
210 |
54360 |
return (0); |
211 |
|
} |
212 |
|
|
213 |
|
void |
214 |
54400 |
Resolve_Sockaddr(struct vcc *tl, |
215 |
|
const char *host, |
216 |
|
const char *def_port, |
217 |
|
const char **ipv4, |
218 |
|
const char **ipv4_ascii, |
219 |
|
const char **ipv6, |
220 |
|
const char **ipv6_ascii, |
221 |
|
const char **p_ascii, |
222 |
|
int maxips, |
223 |
|
const struct token *t_err, |
224 |
|
const char *errid) |
225 |
|
{ |
226 |
|
int error; |
227 |
|
struct rss rss[1]; |
228 |
|
const char *err; |
229 |
|
|
230 |
54400 |
*ipv4 = NULL; |
231 |
54400 |
*ipv6 = NULL; |
232 |
54400 |
if (p_ascii != NULL) |
233 |
53240 |
*p_ascii = NULL; |
234 |
|
|
235 |
54400 |
INIT_OBJ(rss, RSS_MAGIC); |
236 |
54400 |
rss->vsb = VSB_new_auto(); |
237 |
54400 |
AN(rss->vsb); |
238 |
|
|
239 |
54400 |
error = VSS_resolver(host, def_port, rs_callback, rss, &err); |
240 |
54400 |
AZ(VSB_finish(rss->vsb)); |
241 |
54400 |
if (err != NULL) { |
242 |
320 |
VSB_printf(tl->sb, |
243 |
|
"%s '%.*s' could not be resolved to an IP address:\n" |
244 |
|
"\t%s\n" |
245 |
|
"(Sorry if that error message is gibberish.)\n", |
246 |
160 |
errid, PF(t_err), err); |
247 |
160 |
vcc_ErrWhere(tl, t_err); |
248 |
160 |
if (rss->vsa4 != NULL) |
249 |
0 |
VSA_free(&rss->vsa4); |
250 |
160 |
if (rss->vsa6 != NULL) |
251 |
0 |
VSA_free(&rss->vsa6); |
252 |
160 |
VSB_destroy(&rss->vsb); |
253 |
160 |
ZERO_OBJ(rss, sizeof rss); |
254 |
160 |
return; |
255 |
|
} |
256 |
54240 |
AZ(error); |
257 |
54240 |
if (rss->vsa4 != NULL) { |
258 |
53680 |
vcc_suckaddr(tl, host, rss->vsa4, ipv4, ipv4_ascii, p_ascii); |
259 |
53680 |
VSA_free(&rss->vsa4); |
260 |
53680 |
} |
261 |
54240 |
if (rss->vsa6 != NULL) { |
262 |
600 |
vcc_suckaddr(tl, host, rss->vsa6, ipv6, ipv6_ascii, p_ascii); |
263 |
600 |
VSA_free(&rss->vsa6); |
264 |
600 |
} |
265 |
54240 |
if (rss->retval == 0) { |
266 |
0 |
VSB_printf(tl->sb, |
267 |
|
"%s '%.*s': resolves to " |
268 |
|
"neither IPv4 nor IPv6 addresses.\n", |
269 |
0 |
errid, PF(t_err) ); |
270 |
0 |
vcc_ErrWhere(tl, t_err); |
271 |
0 |
} |
272 |
54240 |
if (rss->wrong || rss->retval > maxips) { |
273 |
80 |
VSB_printf(tl->sb, |
274 |
|
"%s %.*s: resolves to too many addresses.\n" |
275 |
|
"Only one IPv4 %s IPv6 are allowed.\n" |
276 |
|
"Please specify which exact address " |
277 |
|
"you want to use, we found all of these:\n%s", |
278 |
40 |
errid, PF(t_err), |
279 |
40 |
maxips > 1 ? "and one" : "or", |
280 |
40 |
VSB_data(rss->vsb)); |
281 |
40 |
vcc_ErrWhere(tl, t_err); |
282 |
40 |
} |
283 |
54240 |
VSB_destroy(&rss->vsb); |
284 |
54240 |
ZERO_OBJ(rss, sizeof rss); |
285 |
54400 |
} |
286 |
|
|
287 |
|
/*-------------------------------------------------------------------- |
288 |
|
* Recognize boolean const "true" or "false" |
289 |
|
*/ |
290 |
|
|
291 |
|
uint8_t |
292 |
160 |
vcc_BoolVal(struct vcc *tl) |
293 |
|
{ |
294 |
|
struct symbol* sym; |
295 |
|
|
296 |
160 |
if (tl->t->tok != ID) { |
297 |
40 |
VSB_cat(tl->sb, "Expected \"true\" or \"false\"\n"); |
298 |
40 |
vcc_ErrWhere(tl, tl->t); |
299 |
40 |
return (0); |
300 |
|
} |
301 |
120 |
sym = VCC_SymbolGet(tl, SYM_MAIN, SYM_NONE, SYMTAB_NOERR, XREF_NONE); |
302 |
120 |
if (sym == NULL || sym->type != BOOL) { |
303 |
40 |
VSB_cat(tl->sb, "Expected \"true\" or \"false\"\n"); |
304 |
40 |
vcc_ErrWhere(tl, tl->t); |
305 |
40 |
return (0); |
306 |
|
} |
307 |
80 |
return (sym->eval_priv != NULL); |
308 |
160 |
} |
309 |
|
|
310 |
|
/*-------------------------------------------------------------------- |
311 |
|
* Recognize and convert units of duration, return seconds. |
312 |
|
*/ |
313 |
|
|
314 |
|
double |
315 |
232000 |
vcc_DurationUnit(struct vcc *tl) |
316 |
|
{ |
317 |
|
double sc; |
318 |
|
|
319 |
232000 |
assert(tl->t->tok == ID); |
320 |
232000 |
sc = VNUM_duration_unit(1.0, tl->t->b, tl->t->e); |
321 |
232000 |
if (!isnan(sc)) { |
322 |
231960 |
vcc_NextToken(tl); |
323 |
231960 |
return (sc); |
324 |
|
} |
325 |
40 |
VSB_cat(tl->sb, "Unknown duration unit "); |
326 |
40 |
vcc_ErrToken(tl, tl->t); |
327 |
40 |
VSB_printf(tl->sb, "\n%s\n", VNUM_LEGAL_DURATION); |
328 |
40 |
vcc_ErrWhere(tl, tl->t); |
329 |
40 |
return (1.0); |
330 |
232000 |
} |
331 |
|
|
332 |
|
/*-------------------------------------------------------------------- |
333 |
|
* Recognize and convert { CNUM } to unsigned value |
334 |
|
* The tokenizer made sure we only get digits. |
335 |
|
*/ |
336 |
|
|
337 |
|
uint64_t |
338 |
8600 |
vcc_UintVal(struct vcc *tl) |
339 |
|
{ |
340 |
|
int64_t retval; |
341 |
|
|
342 |
8600 |
if (tl->t->tok != CNUM) { |
343 |
0 |
Expect(tl, CNUM); |
344 |
0 |
return (0); |
345 |
|
} |
346 |
8600 |
retval = (int64_t)round(tl->t->num); |
347 |
8600 |
if (retval < 0) { |
348 |
0 |
VSB_cat(tl->sb, "UINT cannot be negative\n"); |
349 |
0 |
vcc_ErrWhere(tl, tl->t); |
350 |
0 |
return (0); |
351 |
|
} |
352 |
8600 |
vcc_NextToken(tl); |
353 |
8600 |
return (retval); |
354 |
8600 |
} |
355 |
|
|
356 |
|
static double |
357 |
1920 |
vcc_DoubleVal(struct vcc *tl) |
358 |
|
{ |
359 |
|
double retval; |
360 |
|
|
361 |
1920 |
if (tl->t->tok != CNUM && tl->t->tok != FNUM) { |
362 |
40 |
Expect(tl, CNUM); |
363 |
40 |
return (0); |
364 |
|
} |
365 |
1880 |
retval = tl->t->num; |
366 |
1880 |
vcc_NextToken(tl); |
367 |
1880 |
return (retval); |
368 |
1920 |
} |
369 |
|
|
370 |
|
/*--------------------------------------------------------------------*/ |
371 |
|
|
372 |
|
void |
373 |
1920 |
vcc_Duration(struct vcc *tl, double *d) |
374 |
|
{ |
375 |
|
double v, sc; |
376 |
|
|
377 |
1920 |
v = vcc_DoubleVal(tl); |
378 |
1920 |
ERRCHK(tl); |
379 |
1880 |
ExpectErr(tl, ID); |
380 |
1880 |
sc = vcc_DurationUnit(tl); |
381 |
1880 |
*d = v * sc; |
382 |
1920 |
} |
383 |
|
|
384 |
|
/*--------------------------------------------------------------------*/ |
385 |
|
|
386 |
|
void |
387 |
1920 |
vcc_ByteVal(struct vcc *tl, VCL_INT *d) |
388 |
|
{ |
389 |
|
double v; |
390 |
|
VCL_INT retval; |
391 |
|
const char *errtxt; |
392 |
|
|
393 |
1920 |
if (tl->t->tok != CNUM && tl->t->tok != FNUM) { |
394 |
0 |
Expect(tl, CNUM); |
395 |
0 |
return; |
396 |
|
} |
397 |
1920 |
v = tl->t->num; |
398 |
1920 |
vcc_NextToken(tl); |
399 |
1920 |
if (tl->t->tok != ID) { |
400 |
40 |
VSB_cat(tl->sb, "Expected BYTES unit (B, KB, MB...) got "); |
401 |
40 |
vcc_ErrToken(tl, tl->t); |
402 |
40 |
VSB_cat(tl->sb, "\n"); |
403 |
40 |
vcc_ErrWhere(tl, tl->t); |
404 |
40 |
return; |
405 |
|
} |
406 |
1880 |
retval = VNUM_bytes_unit(v, tl->t->b, tl->t->e, 0, &errtxt); |
407 |
1880 |
if (errno) { |
408 |
40 |
VSB_cat(tl->sb, errtxt); |
409 |
40 |
vcc_ErrToken(tl, tl->t); |
410 |
40 |
vcc_ErrWhere(tl, tl->t); |
411 |
40 |
return; |
412 |
|
} |
413 |
1840 |
vcc_NextToken(tl); |
414 |
1840 |
*d = retval; |
415 |
1920 |
} |
416 |
|
|
417 |
|
/*--------------------------------------------------------------------*/ |
418 |
|
|
419 |
|
int |
420 |
4160 |
vcc_IsFlagRaw(struct vcc *tl, const struct token *t1, const struct token *t2) |
421 |
|
{ |
422 |
|
|
423 |
4160 |
if (t1->tok != '-' && t1->tok != '+') |
424 |
3280 |
return (-1); |
425 |
880 |
if (t2->b != t1->e) { |
426 |
40 |
VSB_cat(tl->sb, "Expected a flag at:\n"); |
427 |
40 |
vcc_ErrWhere(tl, t1); |
428 |
40 |
return (-1); |
429 |
|
} |
430 |
840 |
return (t1->tok == '+' ? 1 : 0); |
431 |
4160 |
} |
432 |
|
|
433 |
|
int |
434 |
2200 |
vcc_IsFlag(struct vcc *tl) |
435 |
|
{ |
436 |
|
struct token *t; |
437 |
|
int retval; |
438 |
|
|
439 |
2200 |
t = vcc_PeekToken(tl); |
440 |
2200 |
if (t == NULL) |
441 |
0 |
return (-1); |
442 |
2200 |
retval = vcc_IsFlagRaw(tl, tl->t, t); |
443 |
2200 |
if (retval >= 0) |
444 |
640 |
vcc_NextToken(tl); |
445 |
2200 |
return (retval); |
446 |
2200 |
} |
447 |
|
|
448 |
|
char * |
449 |
25453800 |
vcc_Dup_be(const char *b, const char *e) |
450 |
|
{ |
451 |
|
char *p; |
452 |
|
|
453 |
25453800 |
AN(b); |
454 |
25453800 |
if (e == NULL) |
455 |
0 |
e = strchr(b, '\0'); |
456 |
25453800 |
AN(e); |
457 |
25453800 |
assert(e >= b); |
458 |
|
|
459 |
25453800 |
p = strndup(b, e - b); |
460 |
25453800 |
AN(p); |
461 |
25453800 |
return (p); |
462 |
|
} |
463 |
|
|
464 |
|
int |
465 |
96880 |
vcc_Has_vcl_prefix(const char *b) |
466 |
|
{ |
467 |
88640 |
return ( |
468 |
96880 |
(b[0] == 'v' || b[0] == 'V') && |
469 |
8360 |
(b[1] == 'c' || b[1] == 'C') && |
470 |
97000 |
(b[2] == 'l' || b[2] == 'L') && |
471 |
120 |
(b[3] == '_') |
472 |
|
); |
473 |
|
} |