Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1 | /* |
| 2 | * ACL management functions. |
| 3 | * |
Willy Tarreau | 0e69854 | 2011-09-16 08:32:32 +0200 | [diff] [blame] | 4 | * Copyright 2000-2011 Willy Tarreau <w@1wt.eu> |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 5 | * |
| 6 | * This program is free software; you can redistribute it and/or |
| 7 | * modify it under the terms of the GNU General Public License |
| 8 | * as published by the Free Software Foundation; either version |
| 9 | * 2 of the License, or (at your option) any later version. |
| 10 | * |
| 11 | */ |
| 12 | |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 13 | #include <ctype.h> |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 14 | #include <stdio.h> |
| 15 | #include <string.h> |
| 16 | |
| 17 | #include <common/config.h> |
| 18 | #include <common/mini-clist.h> |
| 19 | #include <common/standard.h> |
Krzysztof Piotr Oledzki | 8c8bd45 | 2010-01-29 19:29:32 +0100 | [diff] [blame] | 20 | #include <common/uri_auth.h> |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 21 | |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 22 | #include <types/global.h> |
| 23 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 24 | #include <proto/acl.h> |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 25 | #include <proto/arg.h> |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 26 | #include <proto/auth.h> |
Willy Tarreau | c7e4238 | 2012-08-24 19:22:53 +0200 | [diff] [blame] | 27 | #include <proto/channel.h> |
Willy Tarreau | 404e8ab | 2009-07-26 19:40:40 +0200 | [diff] [blame] | 28 | #include <proto/log.h> |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 29 | #include <proto/proxy.h> |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 30 | #include <proto/stick_table.h> |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 31 | |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 32 | #include <ebsttree.h> |
| 33 | |
Willy Tarreau | a980263 | 2008-07-25 19:13:19 +0200 | [diff] [blame] | 34 | /* The capabilities of filtering hooks describe the type of information |
| 35 | * available to each of them. |
| 36 | */ |
| 37 | const unsigned int filt_cap[] = { |
| 38 | [ACL_HOOK_REQ_FE_TCP] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY, |
Willy Tarreau | 0645787 | 2010-05-23 12:24:38 +0200 | [diff] [blame] | 39 | [ACL_HOOK_REQ_FE_TCP_CONTENT] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY, |
| 40 | [ACL_HOOK_REQ_FE_HTTP_IN] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 41 | [ACL_HOOK_REQ_FE_SWITCH] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 42 | [ACL_HOOK_REQ_BE_TCP_CONTENT] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 43 | [ACL_HOOK_REQ_BE_HTTP_IN] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 44 | [ACL_HOOK_REQ_BE_SWITCH] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 45 | [ACL_HOOK_REQ_FE_HTTP_OUT] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
| 46 | [ACL_HOOK_REQ_BE_HTTP_OUT] = ACL_USE_TCP4_ANY|ACL_USE_TCP6_ANY|ACL_USE_TCP_ANY|ACL_USE_L6REQ_ANY|ACL_USE_L7REQ_ANY|ACL_USE_HDR_ANY, |
Willy Tarreau | a980263 | 2008-07-25 19:13:19 +0200 | [diff] [blame] | 47 | |
Willy Tarreau | 0645787 | 2010-05-23 12:24:38 +0200 | [diff] [blame] | 48 | [ACL_HOOK_RTR_BE_TCP_CONTENT] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY, |
| 49 | [ACL_HOOK_RTR_BE_HTTP_IN] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY|ACL_USE_L7RTR_ANY, |
| 50 | [ACL_HOOK_RTR_FE_TCP_CONTENT] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY|ACL_USE_L7RTR_ANY, |
| 51 | [ACL_HOOK_RTR_FE_HTTP_IN] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY|ACL_USE_L7RTR_ANY, |
| 52 | [ACL_HOOK_RTR_BE_HTTP_OUT] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY|ACL_USE_L7RTR_ANY, |
| 53 | [ACL_HOOK_RTR_FE_HTTP_OUT] = ACL_USE_REQ_PERMANENT|ACL_USE_REQ_CACHEABLE|ACL_USE_L6RTR_ANY|ACL_USE_L7RTR_ANY, |
Willy Tarreau | a980263 | 2008-07-25 19:13:19 +0200 | [diff] [blame] | 54 | }; |
| 55 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 56 | /* List head of all known ACL keywords */ |
| 57 | static struct acl_kw_list acl_keywords = { |
| 58 | .list = LIST_HEAD_INIT(acl_keywords.list) |
| 59 | }; |
| 60 | |
| 61 | |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 62 | /* |
| 63 | * These functions are only used for debugging complex configurations. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 64 | */ |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 65 | |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 66 | /* force TRUE to be returned at the fetch level */ |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 67 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 68 | acl_fetch_true(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 69 | const struct arg *args, struct sample *smp) |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 70 | { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 71 | smp->type = SMP_T_BOOL; |
Willy Tarreau | 197e10a | 2012-04-23 19:18:42 +0200 | [diff] [blame] | 72 | smp->data.uint = 1; |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 73 | return 1; |
| 74 | } |
| 75 | |
Willy Tarreau | b6fb420 | 2008-07-20 11:18:28 +0200 | [diff] [blame] | 76 | /* wait for more data as long as possible, then return TRUE. This should be |
| 77 | * used with content inspection. |
| 78 | */ |
| 79 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 80 | acl_fetch_wait_end(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 81 | const struct arg *args, struct sample *smp) |
Willy Tarreau | b6fb420 | 2008-07-20 11:18:28 +0200 | [diff] [blame] | 82 | { |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 83 | if (!(opt & SMP_OPT_FINAL)) { |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 84 | smp->flags |= SMP_F_MAY_CHANGE; |
Willy Tarreau | b6fb420 | 2008-07-20 11:18:28 +0200 | [diff] [blame] | 85 | return 0; |
| 86 | } |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 87 | smp->type = SMP_T_BOOL; |
Willy Tarreau | 197e10a | 2012-04-23 19:18:42 +0200 | [diff] [blame] | 88 | smp->data.uint = 1; |
Willy Tarreau | b6fb420 | 2008-07-20 11:18:28 +0200 | [diff] [blame] | 89 | return 1; |
| 90 | } |
| 91 | |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 92 | /* force FALSE to be returned at the fetch level */ |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 93 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 94 | acl_fetch_false(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 95 | const struct arg *args, struct sample *smp) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 96 | { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 97 | smp->type = SMP_T_BOOL; |
Willy Tarreau | 197e10a | 2012-04-23 19:18:42 +0200 | [diff] [blame] | 98 | smp->data.uint = 0; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 99 | return 1; |
| 100 | } |
| 101 | |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 102 | /* return the number of bytes in the request buffer */ |
| 103 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 104 | acl_fetch_req_len(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 105 | const struct arg *args, struct sample *smp) |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 106 | { |
| 107 | if (!l4 || !l4->req) |
| 108 | return 0; |
| 109 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 110 | smp->type = SMP_T_UINT; |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 111 | smp->data.uint = l4->req->buf->i; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 112 | smp->flags = SMP_F_VOLATILE | SMP_F_MAY_CHANGE; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 113 | return 1; |
| 114 | } |
| 115 | |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 116 | |
| 117 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 118 | acl_fetch_ssl_hello_type(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 119 | const struct arg *args, struct sample *smp) |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 120 | { |
| 121 | int hs_len; |
| 122 | int hs_type, bleft; |
Willy Tarreau | f332af7 | 2012-10-12 23:58:13 +0200 | [diff] [blame] | 123 | struct channel *chn; |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 124 | const unsigned char *data; |
| 125 | |
| 126 | if (!l4) |
| 127 | goto not_ssl_hello; |
| 128 | |
Willy Tarreau | f332af7 | 2012-10-12 23:58:13 +0200 | [diff] [blame] | 129 | chn = ((opt & SMP_OPT_DIR) == SMP_OPT_DIR_RES) ? l4->rep : l4->req; |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 130 | |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 131 | bleft = chn->buf->i; |
| 132 | data = (const unsigned char *)chn->buf->p; |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 133 | |
| 134 | if (!bleft) |
| 135 | goto too_short; |
| 136 | |
| 137 | if ((*data >= 0x14 && *data <= 0x17) || (*data == 0xFF)) { |
| 138 | /* SSLv3 header format */ |
| 139 | if (bleft < 9) |
| 140 | goto too_short; |
| 141 | |
| 142 | /* ssl version 3 */ |
| 143 | if ((data[1] << 16) + data[2] < 0x00030000) |
| 144 | goto not_ssl_hello; |
| 145 | |
| 146 | /* ssl message len must present handshake type and len */ |
| 147 | if ((data[3] << 8) + data[4] < 4) |
| 148 | goto not_ssl_hello; |
| 149 | |
| 150 | /* format introduced with SSLv3 */ |
| 151 | |
| 152 | hs_type = (int)data[5]; |
| 153 | hs_len = ( data[6] << 16 ) + ( data[7] << 8 ) + data[8]; |
| 154 | |
| 155 | /* not a full handshake */ |
| 156 | if (bleft < (9 + hs_len)) |
| 157 | goto too_short; |
| 158 | |
| 159 | } |
| 160 | else { |
| 161 | goto not_ssl_hello; |
| 162 | } |
| 163 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 164 | smp->type = SMP_T_UINT; |
| 165 | smp->data.uint = hs_type; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 166 | smp->flags = SMP_F_VOLATILE; |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 167 | |
| 168 | return 1; |
| 169 | |
| 170 | too_short: |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 171 | smp->flags = SMP_F_MAY_CHANGE; |
Emeric Brun | 38e7176 | 2010-09-23 17:59:18 +0200 | [diff] [blame] | 172 | |
| 173 | not_ssl_hello: |
| 174 | |
| 175 | return 0; |
| 176 | } |
| 177 | |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 178 | /* Return the version of the SSL protocol in the request. It supports both |
| 179 | * SSLv3 (TLSv1) header format for any message, and SSLv2 header format for |
| 180 | * the hello message. The SSLv3 format is described in RFC 2246 p49, and the |
| 181 | * SSLv2 format is described here, and completed p67 of RFC 2246 : |
| 182 | * http://wp.netscape.com/eng/security/SSL_2.html |
| 183 | * |
| 184 | * Note: this decoder only works with non-wrapping data. |
| 185 | */ |
| 186 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 187 | acl_fetch_req_ssl_ver(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 188 | const struct arg *args, struct sample *smp) |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 189 | { |
| 190 | int version, bleft, msg_len; |
| 191 | const unsigned char *data; |
| 192 | |
| 193 | if (!l4 || !l4->req) |
| 194 | return 0; |
| 195 | |
| 196 | msg_len = 0; |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 197 | bleft = l4->req->buf->i; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 198 | if (!bleft) |
| 199 | goto too_short; |
| 200 | |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 201 | data = (const unsigned char *)l4->req->buf->p; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 202 | if ((*data >= 0x14 && *data <= 0x17) || (*data == 0xFF)) { |
| 203 | /* SSLv3 header format */ |
| 204 | if (bleft < 5) |
| 205 | goto too_short; |
| 206 | |
| 207 | version = (data[1] << 16) + data[2]; /* version: major, minor */ |
| 208 | msg_len = (data[3] << 8) + data[4]; /* record length */ |
| 209 | |
| 210 | /* format introduced with SSLv3 */ |
| 211 | if (version < 0x00030000) |
| 212 | goto not_ssl; |
| 213 | |
| 214 | /* message length between 1 and 2^14 + 2048 */ |
| 215 | if (msg_len < 1 || msg_len > ((1<<14) + 2048)) |
| 216 | goto not_ssl; |
| 217 | |
| 218 | bleft -= 5; data += 5; |
| 219 | } else { |
| 220 | /* SSLv2 header format, only supported for hello (msg type 1) */ |
| 221 | int rlen, plen, cilen, silen, chlen; |
| 222 | |
| 223 | if (*data & 0x80) { |
| 224 | if (bleft < 3) |
| 225 | goto too_short; |
| 226 | /* short header format : 15 bits for length */ |
| 227 | rlen = ((data[0] & 0x7F) << 8) | data[1]; |
| 228 | plen = 0; |
| 229 | bleft -= 2; data += 2; |
| 230 | } else { |
| 231 | if (bleft < 4) |
| 232 | goto too_short; |
| 233 | /* long header format : 14 bits for length + pad length */ |
| 234 | rlen = ((data[0] & 0x3F) << 8) | data[1]; |
| 235 | plen = data[2]; |
| 236 | bleft -= 3; data += 2; |
| 237 | } |
| 238 | |
| 239 | if (*data != 0x01) |
| 240 | goto not_ssl; |
| 241 | bleft--; data++; |
| 242 | |
| 243 | if (bleft < 8) |
| 244 | goto too_short; |
| 245 | version = (data[0] << 16) + data[1]; /* version: major, minor */ |
| 246 | cilen = (data[2] << 8) + data[3]; /* cipher len, multiple of 3 */ |
| 247 | silen = (data[4] << 8) + data[5]; /* session_id_len: 0 or 16 */ |
| 248 | chlen = (data[6] << 8) + data[7]; /* 16<=challenge length<=32 */ |
| 249 | |
| 250 | bleft -= 8; data += 8; |
| 251 | if (cilen % 3 != 0) |
| 252 | goto not_ssl; |
| 253 | if (silen && silen != 16) |
| 254 | goto not_ssl; |
| 255 | if (chlen < 16 || chlen > 32) |
| 256 | goto not_ssl; |
| 257 | if (rlen != 9 + cilen + silen + chlen) |
| 258 | goto not_ssl; |
| 259 | |
| 260 | /* focus on the remaining data length */ |
| 261 | msg_len = cilen + silen + chlen + plen; |
| 262 | } |
| 263 | /* We could recursively check that the buffer ends exactly on an SSL |
| 264 | * fragment boundary and that a possible next segment is still SSL, |
| 265 | * but that's a bit pointless. However, we could still check that |
| 266 | * all the part of the request which fits in a buffer is already |
| 267 | * there. |
| 268 | */ |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 269 | if (msg_len > buffer_max_len(l4->req) + l4->req->buf->data - l4->req->buf->p) |
| 270 | msg_len = buffer_max_len(l4->req) + l4->req->buf->data - l4->req->buf->p; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 271 | |
| 272 | if (bleft < msg_len) |
| 273 | goto too_short; |
| 274 | |
| 275 | /* OK that's enough. We have at least the whole message, and we have |
| 276 | * the protocol version. |
| 277 | */ |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 278 | smp->type = SMP_T_UINT; |
| 279 | smp->data.uint = version; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 280 | smp->flags = SMP_F_VOLATILE; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 281 | return 1; |
| 282 | |
| 283 | too_short: |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 284 | smp->flags = SMP_F_MAY_CHANGE; |
Willy Tarreau | 44b90cc | 2010-05-24 20:27:29 +0200 | [diff] [blame] | 285 | not_ssl: |
| 286 | return 0; |
| 287 | } |
| 288 | |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 289 | /* Try to extract the Server Name Indication that may be presented in a TLS |
| 290 | * client hello handshake message. The format of the message is the following |
| 291 | * (cf RFC5246 + RFC6066) : |
| 292 | * TLS frame : |
| 293 | * - uint8 type = 0x16 (Handshake) |
| 294 | * - uint16 version >= 0x0301 (TLSv1) |
| 295 | * - uint16 length (frame length) |
| 296 | * - TLS handshake : |
| 297 | * - uint8 msg_type = 0x01 (ClientHello) |
| 298 | * - uint24 length (handshake message length) |
| 299 | * - ClientHello : |
| 300 | * - uint16 client_version >= 0x0301 (TLSv1) |
Willy Tarreau | d017f11 | 2012-04-09 09:24:11 +0200 | [diff] [blame] | 301 | * - uint8 Random[32] (4 first ones are timestamp) |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 302 | * - SessionID : |
| 303 | * - uint8 session_id_len (0..32) (SessionID len in bytes) |
| 304 | * - uint8 session_id[session_id_len] |
| 305 | * - CipherSuite : |
| 306 | * - uint16 cipher_len >= 2 (Cipher length in bytes) |
| 307 | * - uint16 ciphers[cipher_len/2] |
| 308 | * - CompressionMethod : |
| 309 | * - uint8 compression_len >= 1 (# of supported methods) |
| 310 | * - uint8 compression_methods[compression_len] |
| 311 | * - optional client_extension_len (in bytes) |
| 312 | * - optional sequence of ClientHelloExtensions (as many bytes as above): |
| 313 | * - uint16 extension_type = 0 for server_name |
| 314 | * - uint16 extension_len |
| 315 | * - opaque extension_data[extension_len] |
| 316 | * - uint16 server_name_list_len (# of bytes here) |
| 317 | * - opaque server_names[server_name_list_len bytes] |
| 318 | * - uint8 name_type = 0 for host_name |
| 319 | * - uint16 name_len |
| 320 | * - opaque hostname[name_len bytes] |
| 321 | */ |
| 322 | static int |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 323 | acl_fetch_ssl_hello_sni(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 324 | const struct arg *args, struct sample *smp) |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 325 | { |
| 326 | int hs_len, ext_len, bleft; |
Willy Tarreau | f332af7 | 2012-10-12 23:58:13 +0200 | [diff] [blame] | 327 | struct channel *chn; |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 328 | unsigned char *data; |
| 329 | |
| 330 | if (!l4) |
| 331 | goto not_ssl_hello; |
| 332 | |
Willy Tarreau | f332af7 | 2012-10-12 23:58:13 +0200 | [diff] [blame] | 333 | chn = ((opt & SMP_OPT_DIR) == SMP_OPT_DIR_RES) ? l4->rep : l4->req; |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 334 | |
Willy Tarreau | 9b28e03 | 2012-10-12 23:49:43 +0200 | [diff] [blame] | 335 | bleft = chn->buf->i; |
| 336 | data = (unsigned char *)chn->buf->p; |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 337 | |
| 338 | /* Check for SSL/TLS Handshake */ |
| 339 | if (!bleft) |
| 340 | goto too_short; |
| 341 | if (*data != 0x16) |
| 342 | goto not_ssl_hello; |
| 343 | |
| 344 | /* Check for TLSv1 or later (SSL version >= 3.1) */ |
| 345 | if (bleft < 3) |
| 346 | goto too_short; |
| 347 | if (data[1] < 0x03 || data[2] < 0x01) |
| 348 | goto not_ssl_hello; |
| 349 | |
| 350 | if (bleft < 5) |
| 351 | goto too_short; |
| 352 | hs_len = (data[3] << 8) + data[4]; |
| 353 | if (hs_len < 1 + 3 + 2 + 32 + 1 + 2 + 2 + 1 + 1 + 2 + 2) |
| 354 | goto not_ssl_hello; /* too short to have an extension */ |
| 355 | |
| 356 | data += 5; /* enter TLS handshake */ |
| 357 | bleft -= 5; |
| 358 | |
| 359 | /* Check for a complete client hello starting at <data> */ |
| 360 | if (bleft < 1) |
| 361 | goto too_short; |
| 362 | if (data[0] != 0x01) /* msg_type = Client Hello */ |
| 363 | goto not_ssl_hello; |
| 364 | |
| 365 | /* Check the Hello's length */ |
| 366 | if (bleft < 4) |
| 367 | goto too_short; |
| 368 | hs_len = (data[1] << 16) + (data[2] << 8) + data[3]; |
| 369 | if (hs_len < 2 + 32 + 1 + 2 + 2 + 1 + 1 + 2 + 2) |
| 370 | goto not_ssl_hello; /* too short to have an extension */ |
| 371 | |
| 372 | /* We want the full handshake here */ |
| 373 | if (bleft < hs_len) |
| 374 | goto too_short; |
| 375 | |
| 376 | data += 4; |
| 377 | /* Start of the ClientHello message */ |
| 378 | if (data[0] < 0x03 || data[1] < 0x01) /* TLSv1 minimum */ |
| 379 | goto not_ssl_hello; |
| 380 | |
Willy Tarreau | d017f11 | 2012-04-09 09:24:11 +0200 | [diff] [blame] | 381 | ext_len = data[34]; /* session_id_len */ |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 382 | if (ext_len > 32 || ext_len > (hs_len - 35)) /* check for correct session_id len */ |
| 383 | goto not_ssl_hello; |
| 384 | |
| 385 | /* Jump to cipher suite */ |
| 386 | hs_len -= 35 + ext_len; |
| 387 | data += 35 + ext_len; |
| 388 | |
| 389 | if (hs_len < 4 || /* minimum one cipher */ |
| 390 | (ext_len = (data[0] << 8) + data[1]) < 2 || /* minimum 2 bytes for a cipher */ |
| 391 | ext_len > hs_len) |
| 392 | goto not_ssl_hello; |
| 393 | |
| 394 | /* Jump to the compression methods */ |
| 395 | hs_len -= 2 + ext_len; |
| 396 | data += 2 + ext_len; |
| 397 | |
| 398 | if (hs_len < 2 || /* minimum one compression method */ |
| 399 | data[0] < 1 || data[0] > hs_len) /* minimum 1 bytes for a method */ |
| 400 | goto not_ssl_hello; |
| 401 | |
| 402 | /* Jump to the extensions */ |
| 403 | hs_len -= 1 + data[0]; |
| 404 | data += 1 + data[0]; |
| 405 | |
| 406 | if (hs_len < 2 || /* minimum one extension list length */ |
| 407 | (ext_len = (data[0] << 8) + data[1]) > hs_len - 2) /* list too long */ |
| 408 | goto not_ssl_hello; |
| 409 | |
| 410 | hs_len = ext_len; /* limit ourselves to the extension length */ |
| 411 | data += 2; |
| 412 | |
| 413 | while (hs_len >= 4) { |
| 414 | int ext_type, name_type, srv_len, name_len; |
| 415 | |
| 416 | ext_type = (data[0] << 8) + data[1]; |
| 417 | ext_len = (data[2] << 8) + data[3]; |
| 418 | |
| 419 | if (ext_len > hs_len - 4) /* Extension too long */ |
| 420 | goto not_ssl_hello; |
| 421 | |
| 422 | if (ext_type == 0) { /* Server name */ |
| 423 | if (ext_len < 2) /* need one list length */ |
| 424 | goto not_ssl_hello; |
| 425 | |
| 426 | srv_len = (data[4] << 8) + data[5]; |
| 427 | if (srv_len < 4 || srv_len > hs_len - 6) |
| 428 | goto not_ssl_hello; /* at least 4 bytes per server name */ |
| 429 | |
| 430 | name_type = data[6]; |
| 431 | name_len = (data[7] << 8) + data[8]; |
| 432 | |
| 433 | if (name_type == 0) { /* hostname */ |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 434 | smp->type = SMP_T_CSTR; |
| 435 | smp->data.str.str = (char *)data + 9; |
| 436 | smp->data.str.len = name_len; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 437 | smp->flags = SMP_F_VOLATILE; |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 438 | return 1; |
| 439 | } |
| 440 | } |
| 441 | |
| 442 | hs_len -= 4 + ext_len; |
| 443 | data += 4 + ext_len; |
| 444 | } |
| 445 | /* server name not found */ |
| 446 | goto not_ssl_hello; |
| 447 | |
| 448 | too_short: |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 449 | smp->flags = SMP_F_MAY_CHANGE; |
Willy Tarreau | b6672b5 | 2011-12-12 17:23:41 +0100 | [diff] [blame] | 450 | |
| 451 | not_ssl_hello: |
| 452 | |
| 453 | return 0; |
| 454 | } |
| 455 | |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 456 | /* |
| 457 | * These functions are exported and may be used by any other component. |
| 458 | */ |
| 459 | |
| 460 | /* ignore the current line */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 461 | int acl_parse_nothing(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 462 | { |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 463 | return 1; |
| 464 | } |
| 465 | |
| 466 | /* always fake a data retrieval */ |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 467 | int acl_fetch_nothing(struct proxy *px, struct session *l4, void *l7, unsigned int opt, |
Willy Tarreau | 24e32d8 | 2012-04-23 23:55:44 +0200 | [diff] [blame] | 468 | const struct arg *args, struct sample *smp) |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 469 | { |
| 470 | return 1; |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 471 | } |
| 472 | |
| 473 | /* always return false */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 474 | int acl_match_nothing(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 475 | { |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 476 | return ACL_PAT_FAIL; |
Willy Tarreau | a590983 | 2007-06-17 20:40:25 +0200 | [diff] [blame] | 477 | } |
| 478 | |
| 479 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 480 | /* NB: For two strings to be identical, it is required that their lengths match */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 481 | int acl_match_str(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 482 | { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 483 | int icase; |
| 484 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 485 | if (pattern->len != smp->data.str.len) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 486 | return ACL_PAT_FAIL; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 487 | |
| 488 | icase = pattern->flags & ACL_PAT_F_IGNORE_CASE; |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 489 | if ((icase && strncasecmp(pattern->ptr.str, smp->data.str.str, smp->data.str.len) == 0) || |
| 490 | (!icase && strncmp(pattern->ptr.str, smp->data.str.str, smp->data.str.len) == 0)) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 491 | return ACL_PAT_PASS; |
| 492 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 493 | } |
| 494 | |
Emeric Brun | 07ca496 | 2012-10-17 13:38:19 +0200 | [diff] [blame] | 495 | /* NB: For two binaries buf to be identical, it is required that their lengths match */ |
| 496 | int acl_match_bin(struct sample *smp, struct acl_pattern *pattern) |
| 497 | { |
| 498 | if (pattern->len != smp->data.str.len) |
| 499 | return ACL_PAT_FAIL; |
| 500 | |
| 501 | if (memcmp(pattern->ptr.str, smp->data.str.str, smp->data.str.len) == 0) |
| 502 | return ACL_PAT_PASS; |
| 503 | return ACL_PAT_FAIL; |
| 504 | } |
| 505 | |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 506 | /* Lookup a string in the expression's pattern tree. The node is returned if it |
| 507 | * exists, otherwise NULL. |
| 508 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 509 | static void *acl_lookup_str(struct sample *smp, struct acl_expr *expr) |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 510 | { |
| 511 | /* data are stored in a tree */ |
| 512 | struct ebmb_node *node; |
| 513 | char prev; |
| 514 | |
| 515 | /* we may have to force a trailing zero on the test pattern */ |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 516 | prev = smp->data.str.str[smp->data.str.len]; |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 517 | if (prev) |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 518 | smp->data.str.str[smp->data.str.len] = '\0'; |
| 519 | node = ebst_lookup(&expr->pattern_tree, smp->data.str.str); |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 520 | if (prev) |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 521 | smp->data.str.str[smp->data.str.len] = prev; |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 522 | return node; |
| 523 | } |
| 524 | |
Willy Tarreau | 21e5b0e | 2012-04-23 19:25:44 +0200 | [diff] [blame] | 525 | /* Executes a regex. It temporarily changes the data to add a trailing zero, |
| 526 | * and restores the previous character when leaving. |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 527 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 528 | int acl_match_reg(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 529 | { |
| 530 | char old_char; |
| 531 | int ret; |
| 532 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 533 | old_char = smp->data.str.str[smp->data.str.len]; |
| 534 | smp->data.str.str[smp->data.str.len] = 0; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 535 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 536 | if (regexec(pattern->ptr.reg, smp->data.str.str, 0, NULL, 0) == 0) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 537 | ret = ACL_PAT_PASS; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 538 | else |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 539 | ret = ACL_PAT_FAIL; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 540 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 541 | smp->data.str.str[smp->data.str.len] = old_char; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 542 | return ret; |
| 543 | } |
| 544 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 545 | /* Checks that the pattern matches the beginning of the tested string. */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 546 | int acl_match_beg(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 547 | { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 548 | int icase; |
| 549 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 550 | if (pattern->len > smp->data.str.len) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 551 | return ACL_PAT_FAIL; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 552 | |
| 553 | icase = pattern->flags & ACL_PAT_F_IGNORE_CASE; |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 554 | if ((icase && strncasecmp(pattern->ptr.str, smp->data.str.str, pattern->len) != 0) || |
| 555 | (!icase && strncmp(pattern->ptr.str, smp->data.str.str, pattern->len) != 0)) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 556 | return ACL_PAT_FAIL; |
| 557 | return ACL_PAT_PASS; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 558 | } |
| 559 | |
| 560 | /* Checks that the pattern matches the end of the tested string. */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 561 | int acl_match_end(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 562 | { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 563 | int icase; |
| 564 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 565 | if (pattern->len > smp->data.str.len) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 566 | return ACL_PAT_FAIL; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 567 | icase = pattern->flags & ACL_PAT_F_IGNORE_CASE; |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 568 | if ((icase && strncasecmp(pattern->ptr.str, smp->data.str.str + smp->data.str.len - pattern->len, pattern->len) != 0) || |
| 569 | (!icase && strncmp(pattern->ptr.str, smp->data.str.str + smp->data.str.len - pattern->len, pattern->len) != 0)) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 570 | return ACL_PAT_FAIL; |
| 571 | return ACL_PAT_PASS; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 572 | } |
| 573 | |
| 574 | /* Checks that the pattern is included inside the tested string. |
| 575 | * NB: Suboptimal, should be rewritten using a Boyer-Moore method. |
| 576 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 577 | int acl_match_sub(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 578 | { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 579 | int icase; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 580 | char *end; |
| 581 | char *c; |
| 582 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 583 | if (pattern->len > smp->data.str.len) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 584 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 585 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 586 | end = smp->data.str.str + smp->data.str.len - pattern->len; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 587 | icase = pattern->flags & ACL_PAT_F_IGNORE_CASE; |
| 588 | if (icase) { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 589 | for (c = smp->data.str.str; c <= end; c++) { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 590 | if (tolower(*c) != tolower(*pattern->ptr.str)) |
| 591 | continue; |
| 592 | if (strncasecmp(pattern->ptr.str, c, pattern->len) == 0) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 593 | return ACL_PAT_PASS; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 594 | } |
| 595 | } else { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 596 | for (c = smp->data.str.str; c <= end; c++) { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 597 | if (*c != *pattern->ptr.str) |
| 598 | continue; |
| 599 | if (strncmp(pattern->ptr.str, c, pattern->len) == 0) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 600 | return ACL_PAT_PASS; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 601 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 602 | } |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 603 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 604 | } |
| 605 | |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 606 | /* Background: Fast way to find a zero byte in a word |
| 607 | * http://graphics.stanford.edu/~seander/bithacks.html#ZeroInWord |
| 608 | * hasZeroByte = (v - 0x01010101UL) & ~v & 0x80808080UL; |
| 609 | * |
| 610 | * To look for 4 different byte values, xor the word with those bytes and |
| 611 | * then check for zero bytes: |
| 612 | * |
| 613 | * v = (((unsigned char)c * 0x1010101U) ^ delimiter) |
| 614 | * where <delimiter> is the 4 byte values to look for (as an uint) |
| 615 | * and <c> is the character that is being tested |
| 616 | */ |
| 617 | static inline unsigned int is_delimiter(unsigned char c, unsigned int mask) |
| 618 | { |
| 619 | mask ^= (c * 0x01010101); /* propagate the char to all 4 bytes */ |
| 620 | return (mask - 0x01010101) & ~mask & 0x80808080U; |
| 621 | } |
| 622 | |
| 623 | static inline unsigned int make_4delim(unsigned char d1, unsigned char d2, unsigned char d3, unsigned char d4) |
| 624 | { |
| 625 | return d1 << 24 | d2 << 16 | d3 << 8 | d4; |
| 626 | } |
| 627 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 628 | /* This one is used by other real functions. It checks that the pattern is |
| 629 | * included inside the tested string, but enclosed between the specified |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 630 | * delimiters or at the beginning or end of the string. The delimiters are |
| 631 | * provided as an unsigned int made by make_4delim() and match up to 4 different |
| 632 | * delimiters. Delimiters are stripped at the beginning and end of the pattern. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 633 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 634 | static int match_word(struct sample *smp, struct acl_pattern *pattern, unsigned int delimiters) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 635 | { |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 636 | int may_match, icase; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 637 | char *c, *end; |
| 638 | char *ps; |
| 639 | int pl; |
| 640 | |
| 641 | pl = pattern->len; |
| 642 | ps = pattern->ptr.str; |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 643 | |
| 644 | while (pl > 0 && is_delimiter(*ps, delimiters)) { |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 645 | pl--; |
| 646 | ps++; |
| 647 | } |
| 648 | |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 649 | while (pl > 0 && is_delimiter(ps[pl - 1], delimiters)) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 650 | pl--; |
| 651 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 652 | if (pl > smp->data.str.len) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 653 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 654 | |
| 655 | may_match = 1; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 656 | icase = pattern->flags & ACL_PAT_F_IGNORE_CASE; |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 657 | end = smp->data.str.str + smp->data.str.len - pl; |
| 658 | for (c = smp->data.str.str; c <= end; c++) { |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 659 | if (is_delimiter(*c, delimiters)) { |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 660 | may_match = 1; |
| 661 | continue; |
| 662 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 663 | |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 664 | if (!may_match) |
| 665 | continue; |
| 666 | |
| 667 | if (icase) { |
| 668 | if ((tolower(*c) == tolower(*ps)) && |
| 669 | (strncasecmp(ps, c, pl) == 0) && |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 670 | (c == end || is_delimiter(c[pl], delimiters))) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 671 | return ACL_PAT_PASS; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 672 | } else { |
| 673 | if ((*c == *ps) && |
| 674 | (strncmp(ps, c, pl) == 0) && |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 675 | (c == end || is_delimiter(c[pl], delimiters))) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 676 | return ACL_PAT_PASS; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 677 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 678 | may_match = 0; |
| 679 | } |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 680 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 681 | } |
| 682 | |
| 683 | /* Checks that the pattern is included inside the tested string, but enclosed |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 684 | * between the delimiters '?' or '/' or at the beginning or end of the string. |
| 685 | * Delimiters at the beginning or end of the pattern are ignored. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 686 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 687 | int acl_match_dir(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 688 | { |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 689 | return match_word(smp, pattern, make_4delim('/', '?', '?', '?')); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 690 | } |
| 691 | |
| 692 | /* Checks that the pattern is included inside the tested string, but enclosed |
Finn Arne Gangstad | e8c7ecc | 2011-09-09 16:09:50 +0200 | [diff] [blame] | 693 | * between the delmiters '/', '?', '.' or ":" or at the beginning or end of |
| 694 | * the string. Delimiters at the beginning or end of the pattern are ignored. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 695 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 696 | int acl_match_dom(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 697 | { |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 698 | return match_word(smp, pattern, make_4delim('/', '?', '.', ':')); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 699 | } |
| 700 | |
| 701 | /* Checks that the integer in <test> is included between min and max */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 702 | int acl_match_int(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 703 | { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 704 | if ((!pattern->val.range.min_set || pattern->val.range.min <= smp->data.uint) && |
| 705 | (!pattern->val.range.max_set || smp->data.uint <= pattern->val.range.max)) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 706 | return ACL_PAT_PASS; |
| 707 | return ACL_PAT_FAIL; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 708 | } |
| 709 | |
Willy Tarreau | 0e69854 | 2011-09-16 08:32:32 +0200 | [diff] [blame] | 710 | /* Checks that the length of the pattern in <test> is included between min and max */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 711 | int acl_match_len(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | 0e69854 | 2011-09-16 08:32:32 +0200 | [diff] [blame] | 712 | { |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 713 | if ((!pattern->val.range.min_set || pattern->val.range.min <= smp->data.str.len) && |
| 714 | (!pattern->val.range.max_set || smp->data.str.len <= pattern->val.range.max)) |
Willy Tarreau | 0e69854 | 2011-09-16 08:32:32 +0200 | [diff] [blame] | 715 | return ACL_PAT_PASS; |
| 716 | return ACL_PAT_FAIL; |
| 717 | } |
| 718 | |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 719 | int acl_match_ip(struct sample *smp, struct acl_pattern *pattern) |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 720 | { |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 721 | unsigned int v4; /* in network byte order */ |
| 722 | struct in6_addr *v6; |
| 723 | int bits, pos; |
| 724 | struct in6_addr tmp6; |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 725 | |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 726 | if (pattern->type == SMP_T_IPV4) { |
| 727 | if (smp->type == SMP_T_IPV4) { |
| 728 | v4 = smp->data.ipv4.s_addr; |
| 729 | } |
| 730 | else if (smp->type == SMP_T_IPV6) { |
| 731 | /* v4 match on a V6 sample. We want to check at least for |
| 732 | * the following forms : |
| 733 | * - ::ffff:ip:v4 (ipv4 mapped) |
| 734 | * - ::0000:ip:v4 (old ipv4 mapped) |
| 735 | * - 2002:ip:v4:: (6to4) |
| 736 | */ |
| 737 | if (*(uint32_t*)&smp->data.ipv6.s6_addr[0] == 0 && |
| 738 | *(uint32_t*)&smp->data.ipv6.s6_addr[4] == 0 && |
| 739 | (*(uint32_t*)&smp->data.ipv6.s6_addr[8] == 0 || |
| 740 | *(uint32_t*)&smp->data.ipv6.s6_addr[8] == htonl(0xFFFF))) { |
| 741 | v4 = *(uint32_t*)&smp->data.ipv6.s6_addr[12]; |
| 742 | } |
| 743 | else if (*(uint16_t*)&smp->data.ipv6.s6_addr[0] == htons(0x2002)) { |
| 744 | v4 = htonl((ntohs(*(uint16_t*)&smp->data.ipv6.s6_addr[2]) << 16) + |
| 745 | ntohs(*(uint16_t*)&smp->data.ipv6.s6_addr[4])); |
| 746 | } |
| 747 | else |
| 748 | return ACL_PAT_FAIL; |
| 749 | } |
| 750 | else |
| 751 | return ACL_PAT_FAIL; |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 752 | |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 753 | if (((v4 ^ pattern->val.ipv4.addr.s_addr) & pattern->val.ipv4.mask.s_addr) == 0) |
| 754 | return ACL_PAT_PASS; |
| 755 | else |
| 756 | return ACL_PAT_FAIL; |
| 757 | } |
| 758 | else if (pattern->type == SMP_T_IPV6) { |
| 759 | if (smp->type == SMP_T_IPV4) { |
| 760 | /* Convert the IPv4 sample address to IPv4 with the |
| 761 | * mapping method using the ::ffff: prefix. |
| 762 | */ |
| 763 | memset(&tmp6, 0, 10); |
| 764 | *(uint16_t*)&tmp6.s6_addr[10] = htons(0xffff); |
| 765 | *(uint32_t*)&tmp6.s6_addr[12] = smp->data.ipv4.s_addr; |
| 766 | v6 = &tmp6; |
| 767 | } |
| 768 | else if (smp->type == SMP_T_IPV6) { |
| 769 | v6 = &smp->data.ipv6; |
| 770 | } |
| 771 | else { |
| 772 | return ACL_PAT_FAIL; |
| 773 | } |
| 774 | |
| 775 | bits = pattern->val.ipv6.mask; |
| 776 | for (pos = 0; bits > 0; pos += 4, bits -= 32) { |
| 777 | v4 = *(uint32_t*)&v6->s6_addr[pos] ^ *(uint32_t*)&pattern->val.ipv6.addr.s6_addr[pos]; |
| 778 | if (bits < 32) |
Cyril Bonté | 4c01beb | 2012-10-23 21:28:31 +0200 | [diff] [blame] | 779 | v4 &= htonl((~0U) << (32-bits)); |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 780 | if (v4) |
| 781 | return ACL_PAT_FAIL; |
| 782 | } |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 783 | return ACL_PAT_PASS; |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 784 | } |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 785 | return ACL_PAT_FAIL; |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 786 | } |
| 787 | |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 788 | /* Lookup an IPv4 address in the expression's pattern tree using the longest |
| 789 | * match method. The node is returned if it exists, otherwise NULL. |
| 790 | */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 791 | static void *acl_lookup_ip(struct sample *smp, struct acl_expr *expr) |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 792 | { |
| 793 | struct in_addr *s; |
| 794 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 795 | if (smp->type != SMP_T_IPV4) |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 796 | return ACL_PAT_FAIL; |
| 797 | |
Willy Tarreau | f853c46 | 2012-04-23 18:53:56 +0200 | [diff] [blame] | 798 | s = &smp->data.ipv4; |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 799 | return ebmb_lookup_longest(&expr->pattern_tree, &s->s_addr); |
| 800 | } |
| 801 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 802 | /* Parse a string. It is allocated and duplicated. */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 803 | int acl_parse_str(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 804 | { |
| 805 | int len; |
| 806 | |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 807 | len = strlen(*text); |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 808 | pattern->type = SMP_T_CSTR; |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 809 | |
| 810 | if (pattern->flags & ACL_PAT_F_TREE_OK) { |
| 811 | /* we're allowed to put the data in a tree whose root is pointed |
| 812 | * to by val.tree. |
| 813 | */ |
| 814 | struct ebmb_node *node; |
| 815 | |
| 816 | node = calloc(1, sizeof(*node) + len + 1); |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 817 | if (!node) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 818 | memprintf(err, "out of memory while loading string pattern"); |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 819 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 820 | } |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 821 | memcpy(node->key, *text, len + 1); |
| 822 | if (ebst_insert(pattern->val.tree, node) != node) |
| 823 | free(node); /* was a duplicate */ |
| 824 | pattern->flags |= ACL_PAT_F_TREE; /* this pattern now contains a tree */ |
| 825 | return 1; |
| 826 | } |
| 827 | |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 828 | pattern->ptr.str = strdup(*text); |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 829 | if (!pattern->ptr.str) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 830 | memprintf(err, "out of memory while loading string pattern"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 831 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 832 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 833 | pattern->len = len; |
| 834 | return 1; |
| 835 | } |
| 836 | |
Emeric Brun | 07ca496 | 2012-10-17 13:38:19 +0200 | [diff] [blame] | 837 | /* Parse a binary written in hexa. It is allocated. */ |
| 838 | int acl_parse_bin(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
| 839 | { |
| 840 | int len; |
| 841 | const char *p = *text; |
| 842 | int i,j; |
| 843 | |
| 844 | len = strlen(p); |
| 845 | if (len%2) { |
| 846 | memprintf(err, "an even number of hex digit is expected"); |
| 847 | return 0; |
| 848 | } |
| 849 | |
| 850 | pattern->type = SMP_T_CBIN; |
| 851 | pattern->len = len >> 1; |
| 852 | pattern->ptr.str = malloc(pattern->len); |
| 853 | if (!pattern->ptr.str) { |
| 854 | memprintf(err, "out of memory while loading string pattern"); |
| 855 | return 0; |
| 856 | } |
| 857 | |
| 858 | i = j = 0; |
| 859 | while (j < pattern->len) { |
| 860 | if (!ishex(p[i++])) |
| 861 | goto bad_input; |
| 862 | if (!ishex(p[i++])) |
| 863 | goto bad_input; |
| 864 | pattern->ptr.str[j++] = (hex2i(p[i-2]) << 4) + hex2i(p[i-1]); |
| 865 | } |
| 866 | return 1; |
| 867 | |
| 868 | bad_input: |
| 869 | memprintf(err, "an hex digit is expected (found '%c')", p[i-1]); |
| 870 | free(pattern->ptr.str); |
| 871 | return 0; |
| 872 | } |
| 873 | |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 874 | /* Parse and concatenate all further strings into one. */ |
| 875 | int |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 876 | acl_parse_strcat(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 877 | { |
| 878 | |
| 879 | int len = 0, i; |
| 880 | char *s; |
| 881 | |
| 882 | for (i = 0; *text[i]; i++) |
| 883 | len += strlen(text[i])+1; |
| 884 | |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 885 | pattern->type = SMP_T_CSTR; |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 886 | pattern->ptr.str = s = calloc(1, len); |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 887 | if (!pattern->ptr.str) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 888 | memprintf(err, "out of memory while loading pattern"); |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 889 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 890 | } |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 891 | |
| 892 | for (i = 0; *text[i]; i++) |
| 893 | s += sprintf(s, i?" %s":"%s", text[i]); |
| 894 | |
| 895 | pattern->len = len; |
| 896 | |
| 897 | return i; |
| 898 | } |
| 899 | |
Krzysztof Piotr Oledzki | 8001d61 | 2008-05-31 13:53:23 +0200 | [diff] [blame] | 900 | /* Free data allocated by acl_parse_reg */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 901 | static void acl_free_reg(void *ptr) |
| 902 | { |
Krzysztof Piotr Oledzki | 8001d61 | 2008-05-31 13:53:23 +0200 | [diff] [blame] | 903 | regfree((regex_t *)ptr); |
| 904 | } |
| 905 | |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 906 | /* Parse a regex. It is allocated. */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 907 | int acl_parse_reg(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 908 | { |
| 909 | regex_t *preg; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 910 | int icase; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 911 | |
| 912 | preg = calloc(1, sizeof(regex_t)); |
| 913 | |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 914 | if (!preg) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 915 | memprintf(err, "out of memory while loading pattern"); |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 916 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 917 | } |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 918 | |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 919 | icase = (pattern->flags & ACL_PAT_F_IGNORE_CASE) ? REG_ICASE : 0; |
| 920 | if (regcomp(preg, *text, REG_EXTENDED | REG_NOSUB | icase) != 0) { |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 921 | free(preg); |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 922 | memprintf(err, "regex '%s' is invalid", *text); |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 923 | return 0; |
| 924 | } |
| 925 | |
| 926 | pattern->ptr.reg = preg; |
Krzysztof Piotr Oledzki | 8001d61 | 2008-05-31 13:53:23 +0200 | [diff] [blame] | 927 | pattern->freeptrbuf = &acl_free_reg; |
Willy Tarreau | f3d2598 | 2007-05-08 22:45:09 +0200 | [diff] [blame] | 928 | return 1; |
| 929 | } |
| 930 | |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 931 | /* Parse a range of positive integers delimited by either ':' or '-'. If only |
| 932 | * one integer is read, it is set as both min and max. An operator may be |
| 933 | * specified as the prefix, among this list of 5 : |
| 934 | * |
| 935 | * 0:eq, 1:gt, 2:ge, 3:lt, 4:le |
| 936 | * |
| 937 | * The default operator is "eq". It supports range matching. Ranges are |
| 938 | * rejected for other operators. The operator may be changed at any time. |
| 939 | * The operator is stored in the 'opaque' argument. |
| 940 | * |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 941 | * If err is non-NULL, an error message will be returned there on errors and |
| 942 | * the caller will have to free it. |
| 943 | * |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 944 | */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 945 | int acl_parse_int(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 946 | { |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 947 | signed long long i; |
| 948 | unsigned int j, last, skip = 0; |
| 949 | const char *ptr = *text; |
| 950 | |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 951 | pattern->type = SMP_T_UINT; |
Willy Tarreau | 8f8e645 | 2007-06-17 21:51:38 +0200 | [diff] [blame] | 952 | while (!isdigit((unsigned char)*ptr)) { |
Willy Tarreau | 1c7cc5b | 2010-07-18 10:46:33 +0200 | [diff] [blame] | 953 | switch (get_std_op(ptr)) { |
| 954 | case STD_OP_EQ: *opaque = 0; break; |
| 955 | case STD_OP_GT: *opaque = 1; break; |
| 956 | case STD_OP_GE: *opaque = 2; break; |
| 957 | case STD_OP_LT: *opaque = 3; break; |
| 958 | case STD_OP_LE: *opaque = 4; break; |
| 959 | default: |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 960 | memprintf(err, "'%s' is neither a number nor a supported operator", ptr); |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 961 | return 0; |
Willy Tarreau | 1c7cc5b | 2010-07-18 10:46:33 +0200 | [diff] [blame] | 962 | } |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 963 | |
| 964 | skip++; |
| 965 | ptr = text[skip]; |
| 966 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 967 | |
| 968 | last = i = 0; |
| 969 | while (1) { |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 970 | j = *ptr++; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 971 | if ((j == '-' || j == ':') && !last) { |
| 972 | last++; |
| 973 | pattern->val.range.min = i; |
| 974 | i = 0; |
| 975 | continue; |
| 976 | } |
| 977 | j -= '0'; |
| 978 | if (j > 9) |
| 979 | // also catches the terminating zero |
| 980 | break; |
| 981 | i *= 10; |
| 982 | i += j; |
| 983 | } |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 984 | |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 985 | if (last && *opaque >= 1 && *opaque <= 4) { |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 986 | /* having a range with a min or a max is absurd */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 987 | memprintf(err, "integer range '%s' specified with a comparison operator", text[skip]); |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 988 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 989 | } |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 990 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 991 | if (!last) |
| 992 | pattern->val.range.min = i; |
| 993 | pattern->val.range.max = i; |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 994 | |
| 995 | switch (*opaque) { |
| 996 | case 0: /* eq */ |
| 997 | pattern->val.range.min_set = 1; |
| 998 | pattern->val.range.max_set = 1; |
| 999 | break; |
| 1000 | case 1: /* gt */ |
| 1001 | pattern->val.range.min++; /* gt = ge + 1 */ |
| 1002 | case 2: /* ge */ |
| 1003 | pattern->val.range.min_set = 1; |
| 1004 | pattern->val.range.max_set = 0; |
| 1005 | break; |
| 1006 | case 3: /* lt */ |
| 1007 | pattern->val.range.max--; /* lt = le - 1 */ |
| 1008 | case 4: /* le */ |
| 1009 | pattern->val.range.min_set = 0; |
| 1010 | pattern->val.range.max_set = 1; |
| 1011 | break; |
| 1012 | } |
| 1013 | return skip + 1; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1014 | } |
| 1015 | |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1016 | /* Parse a range of positive 2-component versions delimited by either ':' or |
| 1017 | * '-'. The version consists in a major and a minor, both of which must be |
| 1018 | * smaller than 65536, because internally they will be represented as a 32-bit |
| 1019 | * integer. |
| 1020 | * If only one version is read, it is set as both min and max. Just like for |
| 1021 | * pure integers, an operator may be specified as the prefix, among this list |
| 1022 | * of 5 : |
| 1023 | * |
| 1024 | * 0:eq, 1:gt, 2:ge, 3:lt, 4:le |
| 1025 | * |
| 1026 | * The default operator is "eq". It supports range matching. Ranges are |
| 1027 | * rejected for other operators. The operator may be changed at any time. |
| 1028 | * The operator is stored in the 'opaque' argument. This allows constructs |
| 1029 | * such as the following one : |
| 1030 | * |
| 1031 | * acl obsolete_ssl ssl_req_proto lt 3 |
| 1032 | * acl unsupported_ssl ssl_req_proto gt 3.1 |
| 1033 | * acl valid_ssl ssl_req_proto 3.0-3.1 |
| 1034 | * |
| 1035 | */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1036 | int acl_parse_dotted_ver(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1037 | { |
| 1038 | signed long long i; |
| 1039 | unsigned int j, last, skip = 0; |
| 1040 | const char *ptr = *text; |
| 1041 | |
| 1042 | |
| 1043 | while (!isdigit((unsigned char)*ptr)) { |
Willy Tarreau | 1c7cc5b | 2010-07-18 10:46:33 +0200 | [diff] [blame] | 1044 | switch (get_std_op(ptr)) { |
| 1045 | case STD_OP_EQ: *opaque = 0; break; |
| 1046 | case STD_OP_GT: *opaque = 1; break; |
| 1047 | case STD_OP_GE: *opaque = 2; break; |
| 1048 | case STD_OP_LT: *opaque = 3; break; |
| 1049 | case STD_OP_LE: *opaque = 4; break; |
| 1050 | default: |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1051 | memprintf(err, "'%s' is neither a number nor a supported operator", ptr); |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1052 | return 0; |
Willy Tarreau | 1c7cc5b | 2010-07-18 10:46:33 +0200 | [diff] [blame] | 1053 | } |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1054 | |
| 1055 | skip++; |
| 1056 | ptr = text[skip]; |
| 1057 | } |
| 1058 | |
| 1059 | last = i = 0; |
| 1060 | while (1) { |
| 1061 | j = *ptr++; |
| 1062 | if (j == '.') { |
| 1063 | /* minor part */ |
| 1064 | if (i >= 65536) |
| 1065 | return 0; |
| 1066 | i <<= 16; |
| 1067 | continue; |
| 1068 | } |
| 1069 | if ((j == '-' || j == ':') && !last) { |
| 1070 | last++; |
| 1071 | if (i < 65536) |
| 1072 | i <<= 16; |
| 1073 | pattern->val.range.min = i; |
| 1074 | i = 0; |
| 1075 | continue; |
| 1076 | } |
| 1077 | j -= '0'; |
| 1078 | if (j > 9) |
| 1079 | // also catches the terminating zero |
| 1080 | break; |
| 1081 | i = (i & 0xFFFF0000) + (i & 0xFFFF) * 10; |
| 1082 | i += j; |
| 1083 | } |
| 1084 | |
| 1085 | /* if we only got a major version, let's shift it now */ |
| 1086 | if (i < 65536) |
| 1087 | i <<= 16; |
| 1088 | |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1089 | if (last && *opaque >= 1 && *opaque <= 4) { |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1090 | /* having a range with a min or a max is absurd */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1091 | memprintf(err, "version range '%s' specified with a comparison operator", text[skip]); |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1092 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1093 | } |
Willy Tarreau | 4a26d2f | 2008-07-15 16:05:33 +0200 | [diff] [blame] | 1094 | |
| 1095 | if (!last) |
| 1096 | pattern->val.range.min = i; |
| 1097 | pattern->val.range.max = i; |
| 1098 | |
| 1099 | switch (*opaque) { |
| 1100 | case 0: /* eq */ |
| 1101 | pattern->val.range.min_set = 1; |
| 1102 | pattern->val.range.max_set = 1; |
| 1103 | break; |
| 1104 | case 1: /* gt */ |
| 1105 | pattern->val.range.min++; /* gt = ge + 1 */ |
| 1106 | case 2: /* ge */ |
| 1107 | pattern->val.range.min_set = 1; |
| 1108 | pattern->val.range.max_set = 0; |
| 1109 | break; |
| 1110 | case 3: /* lt */ |
| 1111 | pattern->val.range.max--; /* lt = le - 1 */ |
| 1112 | case 4: /* le */ |
| 1113 | pattern->val.range.min_set = 0; |
| 1114 | pattern->val.range.max_set = 1; |
| 1115 | break; |
| 1116 | } |
| 1117 | return skip + 1; |
| 1118 | } |
| 1119 | |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 1120 | /* Parse an IP address and an optional mask in the form addr[/mask]. |
| 1121 | * The addr may either be an IPv4 address or a hostname. The mask |
| 1122 | * may either be a dotted mask or a number of bits. Returns 1 if OK, |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 1123 | * otherwise 0. NOTE: IP address patterns are typed (IPV4/IPV6). |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 1124 | */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1125 | int acl_parse_ip(const char **text, struct acl_pattern *pattern, int *opaque, char **err) |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 1126 | { |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1127 | struct eb_root *tree = NULL; |
| 1128 | if (pattern->flags & ACL_PAT_F_TREE_OK) |
| 1129 | tree = pattern->val.tree; |
| 1130 | |
| 1131 | if (str2net(*text, &pattern->val.ipv4.addr, &pattern->val.ipv4.mask)) { |
| 1132 | unsigned int mask = ntohl(pattern->val.ipv4.mask.s_addr); |
| 1133 | struct ebmb_node *node; |
| 1134 | /* check if the mask is contiguous so that we can insert the |
| 1135 | * network into the tree. A continuous mask has only ones on |
| 1136 | * the left. This means that this mask + its lower bit added |
| 1137 | * once again is null. |
| 1138 | */ |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 1139 | pattern->type = SMP_T_IPV4; |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1140 | if (mask + (mask & -mask) == 0 && tree) { |
| 1141 | mask = mask ? 33 - flsnz(mask & -mask) : 0; /* equals cidr value */ |
| 1142 | /* FIXME: insert <addr>/<mask> into the tree here */ |
| 1143 | node = calloc(1, sizeof(*node) + 4); /* reserve 4 bytes for IPv4 address */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1144 | if (!node) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1145 | memprintf(err, "out of memory while loading IPv4 pattern"); |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1146 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1147 | } |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1148 | memcpy(node->key, &pattern->val.ipv4.addr, 4); /* network byte order */ |
| 1149 | node->node.pfx = mask; |
| 1150 | if (ebmb_insert_prefix(tree, node, 4) != node) |
| 1151 | free(node); /* was a duplicate */ |
| 1152 | pattern->flags |= ACL_PAT_F_TREE; |
| 1153 | return 1; |
| 1154 | } |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 1155 | return 1; |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1156 | } |
Willy Tarreau | ceb4ac9 | 2012-04-28 00:41:46 +0200 | [diff] [blame] | 1157 | else if (str62net(*text, &pattern->val.ipv6.addr, &pattern->val.ipv6.mask)) { |
| 1158 | /* no tree support right now */ |
| 1159 | pattern->type = SMP_T_IPV6; |
| 1160 | return 1; |
| 1161 | } |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1162 | else { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1163 | memprintf(err, "'%s' is not a valid IPv4 or IPv6 address", *text); |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 1164 | return 0; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1165 | } |
Willy Tarreau | a67fad9 | 2007-05-08 19:50:09 +0200 | [diff] [blame] | 1166 | } |
| 1167 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1168 | /* |
| 1169 | * Registers the ACL keyword list <kwl> as a list of valid keywords for next |
| 1170 | * parsing sessions. |
| 1171 | */ |
| 1172 | void acl_register_keywords(struct acl_kw_list *kwl) |
| 1173 | { |
| 1174 | LIST_ADDQ(&acl_keywords.list, &kwl->list); |
| 1175 | } |
| 1176 | |
| 1177 | /* |
| 1178 | * Unregisters the ACL keyword list <kwl> from the list of valid keywords. |
| 1179 | */ |
| 1180 | void acl_unregister_keywords(struct acl_kw_list *kwl) |
| 1181 | { |
| 1182 | LIST_DEL(&kwl->list); |
| 1183 | LIST_INIT(&kwl->list); |
| 1184 | } |
| 1185 | |
| 1186 | /* Return a pointer to the ACL <name> within the list starting at <head>, or |
| 1187 | * NULL if not found. |
| 1188 | */ |
| 1189 | struct acl *find_acl_by_name(const char *name, struct list *head) |
| 1190 | { |
| 1191 | struct acl *acl; |
| 1192 | list_for_each_entry(acl, head, list) { |
| 1193 | if (strcmp(acl->name, name) == 0) |
| 1194 | return acl; |
| 1195 | } |
| 1196 | return NULL; |
| 1197 | } |
| 1198 | |
| 1199 | /* Return a pointer to the ACL keyword <kw>, or NULL if not found. Note that if |
| 1200 | * <kw> contains an opening parenthesis, only the left part of it is checked. |
| 1201 | */ |
| 1202 | struct acl_keyword *find_acl_kw(const char *kw) |
| 1203 | { |
| 1204 | int index; |
| 1205 | const char *kwend; |
| 1206 | struct acl_kw_list *kwl; |
| 1207 | |
| 1208 | kwend = strchr(kw, '('); |
| 1209 | if (!kwend) |
| 1210 | kwend = kw + strlen(kw); |
| 1211 | |
| 1212 | list_for_each_entry(kwl, &acl_keywords.list, list) { |
| 1213 | for (index = 0; kwl->kw[index].kw != NULL; index++) { |
| 1214 | if ((strncmp(kwl->kw[index].kw, kw, kwend - kw) == 0) && |
| 1215 | kwl->kw[index].kw[kwend-kw] == 0) |
| 1216 | return &kwl->kw[index]; |
| 1217 | } |
| 1218 | } |
| 1219 | return NULL; |
| 1220 | } |
| 1221 | |
Willy Tarreau | dfd7fca | 2011-03-09 07:27:02 +0100 | [diff] [blame] | 1222 | /* NB: does nothing if <pat> is NULL */ |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1223 | static void free_pattern(struct acl_pattern *pat) |
| 1224 | { |
Willy Tarreau | dfd7fca | 2011-03-09 07:27:02 +0100 | [diff] [blame] | 1225 | if (!pat) |
| 1226 | return; |
Krzysztof Piotr Oledzki | 8001d61 | 2008-05-31 13:53:23 +0200 | [diff] [blame] | 1227 | |
| 1228 | if (pat->ptr.ptr) { |
| 1229 | if (pat->freeptrbuf) |
| 1230 | pat->freeptrbuf(pat->ptr.ptr); |
| 1231 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1232 | free(pat->ptr.ptr); |
Krzysztof Piotr Oledzki | 8001d61 | 2008-05-31 13:53:23 +0200 | [diff] [blame] | 1233 | } |
| 1234 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1235 | free(pat); |
| 1236 | } |
| 1237 | |
| 1238 | static void free_pattern_list(struct list *head) |
| 1239 | { |
| 1240 | struct acl_pattern *pat, *tmp; |
| 1241 | list_for_each_entry_safe(pat, tmp, head, list) |
| 1242 | free_pattern(pat); |
| 1243 | } |
| 1244 | |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1245 | static void free_pattern_tree(struct eb_root *root) |
| 1246 | { |
| 1247 | struct eb_node *node, *next; |
| 1248 | node = eb_first(root); |
| 1249 | while (node) { |
| 1250 | next = eb_next(node); |
| 1251 | free(node); |
| 1252 | node = next; |
| 1253 | } |
| 1254 | } |
| 1255 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1256 | static struct acl_expr *prune_acl_expr(struct acl_expr *expr) |
| 1257 | { |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1258 | struct arg *arg; |
| 1259 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1260 | free_pattern_list(&expr->patterns); |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1261 | free_pattern_tree(&expr->pattern_tree); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1262 | LIST_INIT(&expr->patterns); |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1263 | |
| 1264 | for (arg = expr->args; arg; arg++) { |
| 1265 | if (arg->type == ARGT_STOP) |
| 1266 | break; |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 1267 | if (arg->type == ARGT_STR || arg->unresolved) { |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1268 | free(arg->data.str.str); |
| 1269 | arg->data.str.str = NULL; |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 1270 | arg->unresolved = 0; |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1271 | } |
| 1272 | arg++; |
| 1273 | } |
| 1274 | |
Willy Tarreau | 2e845be | 2012-10-19 19:49:09 +0200 | [diff] [blame] | 1275 | if (expr->args != empty_arg_list) |
| 1276 | free(expr->args); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1277 | expr->kw->use_cnt--; |
| 1278 | return expr; |
| 1279 | } |
| 1280 | |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1281 | |
| 1282 | /* Reads patterns from a file. If <err_msg> is non-NULL, an error message will |
| 1283 | * be returned there on errors and the caller will have to free it. |
| 1284 | */ |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1285 | static int acl_read_patterns_from_file( struct acl_keyword *aclkw, |
| 1286 | struct acl_expr *expr, |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1287 | const char *filename, int patflags, |
| 1288 | char **err) |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1289 | { |
| 1290 | FILE *file; |
| 1291 | char *c; |
| 1292 | const char *args[2]; |
| 1293 | struct acl_pattern *pattern; |
| 1294 | int opaque; |
Willy Tarreau | 6a8097f | 2011-02-26 15:14:15 +0100 | [diff] [blame] | 1295 | int ret = 0; |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1296 | int line = 0; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1297 | |
| 1298 | file = fopen(filename, "r"); |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1299 | if (!file) { |
| 1300 | memprintf(err, "failed to open pattern file <%s>", filename); |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1301 | return 0; |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1302 | } |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1303 | |
| 1304 | /* now parse all patterns. The file may contain only one pattern per |
| 1305 | * line. If the line contains spaces, they will be part of the pattern. |
| 1306 | * The pattern stops at the first CR, LF or EOF encountered. |
| 1307 | */ |
| 1308 | opaque = 0; |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1309 | pattern = NULL; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1310 | args[1] = ""; |
David du Colombier | 7af4605 | 2012-05-16 14:16:48 +0200 | [diff] [blame] | 1311 | while (fgets(trash, trashlen, file) != NULL) { |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1312 | line++; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1313 | c = trash; |
Willy Tarreau | 58215a0 | 2010-05-13 22:07:43 +0200 | [diff] [blame] | 1314 | |
| 1315 | /* ignore lines beginning with a dash */ |
| 1316 | if (*c == '#') |
| 1317 | continue; |
| 1318 | |
| 1319 | /* strip leading spaces and tabs */ |
| 1320 | while (*c == ' ' || *c == '\t') |
| 1321 | c++; |
| 1322 | |
Willy Tarreau | 58215a0 | 2010-05-13 22:07:43 +0200 | [diff] [blame] | 1323 | |
| 1324 | args[0] = c; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1325 | while (*c && *c != '\n' && *c != '\r') |
| 1326 | c++; |
| 1327 | *c = 0; |
| 1328 | |
Willy Tarreau | 5109196 | 2011-01-03 21:04:10 +0100 | [diff] [blame] | 1329 | /* empty lines are ignored too */ |
| 1330 | if (c == args[0]) |
| 1331 | continue; |
| 1332 | |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1333 | /* we keep the previous pattern along iterations as long as it's not used */ |
| 1334 | if (!pattern) |
| 1335 | pattern = (struct acl_pattern *)malloc(sizeof(*pattern)); |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1336 | if (!pattern) { |
| 1337 | memprintf(err, "out of memory when loading patterns from file <%s>", filename); |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1338 | goto out_close; |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1339 | } |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1340 | |
| 1341 | memset(pattern, 0, sizeof(*pattern)); |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1342 | pattern->flags = patflags; |
| 1343 | |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1344 | if ((aclkw->requires & ACL_MAY_LOOKUP) && !(pattern->flags & ACL_PAT_F_IGNORE_CASE)) { |
| 1345 | /* we pre-set the data pointer to the tree's head so that functions |
| 1346 | * which are able to insert in a tree know where to do that. |
| 1347 | */ |
| 1348 | pattern->flags |= ACL_PAT_F_TREE_OK; |
| 1349 | pattern->val.tree = &expr->pattern_tree; |
| 1350 | } |
| 1351 | |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 1352 | pattern->type = SMP_TYPES; /* unspecified type by default */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1353 | if (!aclkw->parse(args, pattern, &opaque, err)) |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1354 | goto out_free_pattern; |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1355 | |
| 1356 | /* if the parser did not feed the tree, let's chain the pattern to the list */ |
| 1357 | if (!(pattern->flags & ACL_PAT_F_TREE)) { |
| 1358 | LIST_ADDQ(&expr->patterns, &pattern->list); |
| 1359 | pattern = NULL; /* get a new one */ |
| 1360 | } |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1361 | } |
Willy Tarreau | 6a8097f | 2011-02-26 15:14:15 +0100 | [diff] [blame] | 1362 | |
| 1363 | ret = 1; /* success */ |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1364 | |
| 1365 | out_free_pattern: |
| 1366 | free_pattern(pattern); |
| 1367 | out_close: |
| 1368 | fclose(file); |
Willy Tarreau | 6a8097f | 2011-02-26 15:14:15 +0100 | [diff] [blame] | 1369 | return ret; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1370 | } |
| 1371 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1372 | /* Parse an ACL expression starting at <args>[0], and return it. If <err> is |
| 1373 | * not NULL, it will be filled with a pointer to an error message in case of |
| 1374 | * error. This pointer must be freeable or NULL. |
| 1375 | * |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1376 | * Right now, the only accepted syntax is : |
| 1377 | * <subject> [<value>...] |
| 1378 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1379 | struct acl_expr *parse_acl_expr(const char **args, char **err) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1380 | { |
| 1381 | __label__ out_return, out_free_expr, out_free_pattern; |
| 1382 | struct acl_expr *expr; |
| 1383 | struct acl_keyword *aclkw; |
| 1384 | struct acl_pattern *pattern; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 1385 | int opaque, patflags; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1386 | const char *arg; |
| 1387 | |
| 1388 | aclkw = find_acl_kw(args[0]); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1389 | if (!aclkw || !aclkw->parse) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1390 | memprintf(err, "unknown ACL keyword '%s'", *args); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1391 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1392 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1393 | |
| 1394 | expr = (struct acl_expr *)calloc(1, sizeof(*expr)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1395 | if (!expr) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1396 | memprintf(err, "out of memory when parsing ACL expression"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1397 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1398 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1399 | |
| 1400 | expr->kw = aclkw; |
| 1401 | aclkw->use_cnt++; |
| 1402 | LIST_INIT(&expr->patterns); |
Willy Tarreau | e56cda9 | 2010-05-11 23:25:05 +0200 | [diff] [blame] | 1403 | expr->pattern_tree = EB_ROOT_UNIQUE; |
Willy Tarreau | 2e845be | 2012-10-19 19:49:09 +0200 | [diff] [blame] | 1404 | expr->args = empty_arg_list; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1405 | |
| 1406 | arg = strchr(args[0], '('); |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1407 | if (aclkw->arg_mask) { |
| 1408 | int nbargs = 0; |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1409 | char *end; |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1410 | |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1411 | if (arg != NULL) { |
| 1412 | /* there are 0 or more arguments in the form "subject(arg[,arg]*)" */ |
| 1413 | arg++; |
| 1414 | end = strchr(arg, ')'); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1415 | if (!end) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1416 | memprintf(err, "missing closing ')' after arguments to ACL keyword '%s'", aclkw->kw); |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1417 | goto out_free_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1418 | } |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 1419 | |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1420 | /* Parse the arguments. Note that currently we have no way to |
| 1421 | * report parsing errors, hence the NULL in the error pointers. |
| 1422 | * An error is also reported if some mandatory arguments are |
| 1423 | * missing. |
| 1424 | */ |
| 1425 | nbargs = make_arg_list(arg, end - arg, aclkw->arg_mask, &expr->args, |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1426 | err, NULL, NULL); |
| 1427 | if (nbargs < 0) { |
| 1428 | /* note that make_arg_list will have set <err> here */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1429 | memprintf(err, "in argument to '%s', %s", aclkw->kw, *err); |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1430 | goto out_free_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1431 | } |
Willy Tarreau | ae52f06 | 2012-04-26 12:13:35 +0200 | [diff] [blame] | 1432 | |
Willy Tarreau | 2e845be | 2012-10-19 19:49:09 +0200 | [diff] [blame] | 1433 | if (!expr->args) |
| 1434 | expr->args = empty_arg_list; |
| 1435 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1436 | if (aclkw->val_args && !aclkw->val_args(expr->args, err)) { |
| 1437 | /* invalid keyword argument, error must have been |
| 1438 | * set by val_args(). |
| 1439 | */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1440 | memprintf(err, "in argument to '%s', %s", aclkw->kw, *err); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1441 | goto out_free_expr; |
| 1442 | } |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1443 | } |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 1444 | else if (ARGM(aclkw->arg_mask) == 1) { |
| 1445 | int type = (aclkw->arg_mask >> 4) & 15; |
| 1446 | |
| 1447 | /* If a proxy is noted as a mandatory argument, we'll fake |
| 1448 | * an empty one so that acl_find_targets() resolves it as |
| 1449 | * the current one later. |
| 1450 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1451 | if (type != ARGT_FE && type != ARGT_BE && type != ARGT_TAB) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1452 | memprintf(err, "ACL keyword '%s' expects %d arguments", aclkw->kw, ARGM(aclkw->arg_mask)); |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 1453 | goto out_free_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1454 | } |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 1455 | |
| 1456 | /* Build an arg list containing the type as an empty string |
| 1457 | * and the usual STOP. |
| 1458 | */ |
| 1459 | expr->args = calloc(2, sizeof(*expr->args)); |
| 1460 | expr->args[0].type = type; |
Willy Tarreau | e3a4611 | 2012-06-15 08:02:34 +0200 | [diff] [blame] | 1461 | expr->args[0].unresolved = 1; |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 1462 | expr->args[0].data.str.str = strdup(""); |
| 1463 | expr->args[0].data.str.len = 1; |
| 1464 | expr->args[0].data.str.len = 0; |
| 1465 | expr->args[1].type = ARGT_STOP; |
| 1466 | } |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1467 | else if (ARGM(aclkw->arg_mask)) { |
| 1468 | /* there were some mandatory arguments */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1469 | memprintf(err, "ACL keyword '%s' expects %d arguments", aclkw->kw, ARGM(aclkw->arg_mask)); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1470 | goto out_free_expr; |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1471 | } |
| 1472 | } |
| 1473 | else { |
| 1474 | if (arg) { |
| 1475 | /* no argument expected */ |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1476 | memprintf(err, "ACL keyword '%s' takes no argument", aclkw->kw); |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 1477 | goto out_free_expr; |
| 1478 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1479 | } |
| 1480 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1481 | args++; |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 1482 | |
| 1483 | /* check for options before patterns. Supported options are : |
| 1484 | * -i : ignore case for all patterns by default |
| 1485 | * -f : read patterns from those files |
| 1486 | * -- : everything after this is not an option |
| 1487 | */ |
| 1488 | patflags = 0; |
| 1489 | while (**args == '-') { |
| 1490 | if ((*args)[1] == 'i') |
| 1491 | patflags |= ACL_PAT_F_IGNORE_CASE; |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1492 | else if ((*args)[1] == 'f') { |
Willy Tarreau | 08ad0b3 | 2012-04-27 17:25:24 +0200 | [diff] [blame] | 1493 | if (!acl_read_patterns_from_file(aclkw, expr, args[1], patflags | ACL_PAT_F_FROM_FILE, err)) |
Willy Tarreau | 2b5285d | 2010-05-09 23:45:24 +0200 | [diff] [blame] | 1494 | goto out_free_expr; |
| 1495 | args++; |
| 1496 | } |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 1497 | else if ((*args)[1] == '-') { |
| 1498 | args++; |
| 1499 | break; |
| 1500 | } |
| 1501 | else |
| 1502 | break; |
| 1503 | args++; |
| 1504 | } |
| 1505 | |
| 1506 | /* now parse all patterns */ |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 1507 | opaque = 0; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1508 | while (**args) { |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 1509 | int ret; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1510 | pattern = (struct acl_pattern *)calloc(1, sizeof(*pattern)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1511 | if (!pattern) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1512 | memprintf(err, "out of memory when parsing ACL pattern"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1513 | goto out_free_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1514 | } |
Willy Tarreau | c8d7c96 | 2007-06-17 08:20:33 +0200 | [diff] [blame] | 1515 | pattern->flags = patflags; |
| 1516 | |
Willy Tarreau | c92ddbc | 2012-04-27 22:10:57 +0200 | [diff] [blame] | 1517 | pattern->type = SMP_TYPES; /* unspecified type */ |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1518 | ret = aclkw->parse(args, pattern, &opaque, err); |
| 1519 | if (!ret) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1520 | goto out_free_pattern; |
Willy Tarreau | 7dcb648 | 2012-04-27 17:52:25 +0200 | [diff] [blame] | 1521 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1522 | LIST_ADDQ(&expr->patterns, &pattern->list); |
Willy Tarreau | ae8b796 | 2007-06-09 23:10:04 +0200 | [diff] [blame] | 1523 | args += ret; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1524 | } |
| 1525 | |
| 1526 | return expr; |
| 1527 | |
| 1528 | out_free_pattern: |
| 1529 | free_pattern(pattern); |
| 1530 | out_free_expr: |
| 1531 | prune_acl_expr(expr); |
| 1532 | free(expr); |
| 1533 | out_return: |
| 1534 | return NULL; |
| 1535 | } |
| 1536 | |
Krzysztof Piotr Oledzki | a643baf | 2008-05-29 23:53:44 +0200 | [diff] [blame] | 1537 | /* Purge everything in the acl <acl>, then return <acl>. */ |
| 1538 | struct acl *prune_acl(struct acl *acl) { |
| 1539 | |
| 1540 | struct acl_expr *expr, *exprb; |
| 1541 | |
| 1542 | free(acl->name); |
| 1543 | |
| 1544 | list_for_each_entry_safe(expr, exprb, &acl->expr, list) { |
| 1545 | LIST_DEL(&expr->list); |
| 1546 | prune_acl_expr(expr); |
| 1547 | free(expr); |
| 1548 | } |
| 1549 | |
| 1550 | return acl; |
| 1551 | } |
| 1552 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1553 | /* Parse an ACL with the name starting at <args>[0], and with a list of already |
| 1554 | * known ACLs in <acl>. If the ACL was not in the list, it will be added. |
Willy Tarreau | 2a56c5e | 2010-03-15 16:13:29 +0100 | [diff] [blame] | 1555 | * A pointer to that ACL is returned. If the ACL has an empty name, then it's |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1556 | * an anonymous one and it won't be merged with any other one. If <err> is not |
| 1557 | * NULL, it will be filled with an appropriate error. This pointer must be |
| 1558 | * freeable or NULL. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1559 | * |
| 1560 | * args syntax: <aclname> <acl_expr> |
| 1561 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1562 | struct acl *parse_acl(const char **args, struct list *known_acl, char **err) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1563 | { |
| 1564 | __label__ out_return, out_free_acl_expr, out_free_name; |
| 1565 | struct acl *cur_acl; |
| 1566 | struct acl_expr *acl_expr; |
| 1567 | char *name; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1568 | const char *pos; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1569 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1570 | if (**args && (pos = invalid_char(*args))) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1571 | memprintf(err, "invalid character in ACL name : '%c'", *pos); |
Willy Tarreau | 2e74c3f | 2007-12-02 18:45:09 +0100 | [diff] [blame] | 1572 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1573 | } |
Willy Tarreau | 2e74c3f | 2007-12-02 18:45:09 +0100 | [diff] [blame] | 1574 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1575 | acl_expr = parse_acl_expr(args + 1, err); |
| 1576 | if (!acl_expr) { |
| 1577 | /* parse_acl_expr will have filled <err> here */ |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1578 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1579 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1580 | |
Willy Tarreau | 404e8ab | 2009-07-26 19:40:40 +0200 | [diff] [blame] | 1581 | /* Check for args beginning with an opening parenthesis just after the |
| 1582 | * subject, as this is almost certainly a typo. Right now we can only |
| 1583 | * emit a warning, so let's do so. |
| 1584 | */ |
Krzysztof Piotr Oledzki | 4cdd831 | 2009-10-05 00:23:35 +0200 | [diff] [blame] | 1585 | if (!strchr(args[1], '(') && *args[2] == '(') |
Willy Tarreau | 404e8ab | 2009-07-26 19:40:40 +0200 | [diff] [blame] | 1586 | Warning("parsing acl '%s' :\n" |
| 1587 | " matching '%s' for pattern '%s' is likely a mistake and probably\n" |
| 1588 | " not what you want. Maybe you need to remove the extraneous space before '('.\n" |
| 1589 | " If you are really sure this is not an error, please insert '--' between the\n" |
| 1590 | " match and the pattern to make this warning message disappear.\n", |
| 1591 | args[0], args[1], args[2]); |
| 1592 | |
Willy Tarreau | 2a56c5e | 2010-03-15 16:13:29 +0100 | [diff] [blame] | 1593 | if (*args[0]) |
| 1594 | cur_acl = find_acl_by_name(args[0], known_acl); |
| 1595 | else |
| 1596 | cur_acl = NULL; |
| 1597 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1598 | if (!cur_acl) { |
| 1599 | name = strdup(args[0]); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1600 | if (!name) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1601 | memprintf(err, "out of memory when parsing ACL"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1602 | goto out_free_acl_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1603 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1604 | cur_acl = (struct acl *)calloc(1, sizeof(*cur_acl)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1605 | if (cur_acl == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1606 | memprintf(err, "out of memory when parsing ACL"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1607 | goto out_free_name; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1608 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1609 | |
| 1610 | LIST_INIT(&cur_acl->expr); |
| 1611 | LIST_ADDQ(known_acl, &cur_acl->list); |
| 1612 | cur_acl->name = name; |
| 1613 | } |
| 1614 | |
Willy Tarreau | a980263 | 2008-07-25 19:13:19 +0200 | [diff] [blame] | 1615 | cur_acl->requires |= acl_expr->kw->requires; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1616 | LIST_ADDQ(&cur_acl->expr, &acl_expr->list); |
| 1617 | return cur_acl; |
| 1618 | |
| 1619 | out_free_name: |
| 1620 | free(name); |
| 1621 | out_free_acl_expr: |
| 1622 | prune_acl_expr(acl_expr); |
| 1623 | free(acl_expr); |
| 1624 | out_return: |
| 1625 | return NULL; |
| 1626 | } |
| 1627 | |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1628 | /* Some useful ACLs provided by default. Only those used are allocated. */ |
| 1629 | |
| 1630 | const struct { |
| 1631 | const char *name; |
| 1632 | const char *expr[4]; /* put enough for longest expression */ |
| 1633 | } default_acl_list[] = { |
Willy Tarreau | 58393e1 | 2008-07-20 10:39:22 +0200 | [diff] [blame] | 1634 | { .name = "TRUE", .expr = {"always_true",""}}, |
| 1635 | { .name = "FALSE", .expr = {"always_false",""}}, |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1636 | { .name = "LOCALHOST", .expr = {"src","127.0.0.1/8",""}}, |
Willy Tarreau | 2492d5b | 2009-07-11 00:06:00 +0200 | [diff] [blame] | 1637 | { .name = "HTTP", .expr = {"req_proto_http",""}}, |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1638 | { .name = "HTTP_1.0", .expr = {"req_ver","1.0",""}}, |
| 1639 | { .name = "HTTP_1.1", .expr = {"req_ver","1.1",""}}, |
| 1640 | { .name = "METH_CONNECT", .expr = {"method","CONNECT",""}}, |
| 1641 | { .name = "METH_GET", .expr = {"method","GET","HEAD",""}}, |
| 1642 | { .name = "METH_HEAD", .expr = {"method","HEAD",""}}, |
| 1643 | { .name = "METH_OPTIONS", .expr = {"method","OPTIONS",""}}, |
| 1644 | { .name = "METH_POST", .expr = {"method","POST",""}}, |
| 1645 | { .name = "METH_TRACE", .expr = {"method","TRACE",""}}, |
| 1646 | { .name = "HTTP_URL_ABS", .expr = {"url_reg","^[^/:]*://",""}}, |
| 1647 | { .name = "HTTP_URL_SLASH", .expr = {"url_beg","/",""}}, |
| 1648 | { .name = "HTTP_URL_STAR", .expr = {"url","*",""}}, |
| 1649 | { .name = "HTTP_CONTENT", .expr = {"hdr_val(content-length)","gt","0",""}}, |
Emeric Brun | bede3d0 | 2009-06-30 17:54:00 +0200 | [diff] [blame] | 1650 | { .name = "RDP_COOKIE", .expr = {"req_rdp_cookie_cnt","gt","0",""}}, |
Willy Tarreau | c631770 | 2008-07-20 09:29:50 +0200 | [diff] [blame] | 1651 | { .name = "REQ_CONTENT", .expr = {"req_len","gt","0",""}}, |
Willy Tarreau | b6fb420 | 2008-07-20 11:18:28 +0200 | [diff] [blame] | 1652 | { .name = "WAIT_END", .expr = {"wait_end",""}}, |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1653 | { .name = NULL, .expr = {""}} |
| 1654 | }; |
| 1655 | |
| 1656 | /* Find a default ACL from the default_acl list, compile it and return it. |
| 1657 | * If the ACL is not found, NULL is returned. In theory, it cannot fail, |
| 1658 | * except when default ACLs are broken, in which case it will return NULL. |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1659 | * If <known_acl> is not NULL, the ACL will be queued at its tail. If <err> is |
| 1660 | * not NULL, it will be filled with an error message if an error occurs. This |
| 1661 | * pointer must be freeable or NULL. |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1662 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1663 | struct acl *find_acl_default(const char *acl_name, struct list *known_acl, char **err) |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1664 | { |
| 1665 | __label__ out_return, out_free_acl_expr, out_free_name; |
| 1666 | struct acl *cur_acl; |
| 1667 | struct acl_expr *acl_expr; |
| 1668 | char *name; |
| 1669 | int index; |
| 1670 | |
| 1671 | for (index = 0; default_acl_list[index].name != NULL; index++) { |
| 1672 | if (strcmp(acl_name, default_acl_list[index].name) == 0) |
| 1673 | break; |
| 1674 | } |
| 1675 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1676 | if (default_acl_list[index].name == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1677 | memprintf(err, "no such ACL : '%s'", acl_name); |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1678 | return NULL; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1679 | } |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1680 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1681 | acl_expr = parse_acl_expr((const char **)default_acl_list[index].expr, err); |
| 1682 | if (!acl_expr) { |
| 1683 | /* parse_acl_expr must have filled err here */ |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1684 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1685 | } |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1686 | |
| 1687 | name = strdup(acl_name); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1688 | if (!name) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1689 | memprintf(err, "out of memory when building default ACL '%s'", acl_name); |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1690 | goto out_free_acl_expr; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1691 | } |
| 1692 | |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1693 | cur_acl = (struct acl *)calloc(1, sizeof(*cur_acl)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1694 | if (cur_acl == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1695 | memprintf(err, "out of memory when building default ACL '%s'", acl_name); |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1696 | goto out_free_name; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1697 | } |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1698 | |
| 1699 | cur_acl->name = name; |
Willy Tarreau | a55b7dc | 2009-07-12 09:21:30 +0200 | [diff] [blame] | 1700 | cur_acl->requires |= acl_expr->kw->requires; |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1701 | LIST_INIT(&cur_acl->expr); |
| 1702 | LIST_ADDQ(&cur_acl->expr, &acl_expr->list); |
| 1703 | if (known_acl) |
| 1704 | LIST_ADDQ(known_acl, &cur_acl->list); |
| 1705 | |
| 1706 | return cur_acl; |
| 1707 | |
| 1708 | out_free_name: |
| 1709 | free(name); |
| 1710 | out_free_acl_expr: |
| 1711 | prune_acl_expr(acl_expr); |
| 1712 | free(acl_expr); |
| 1713 | out_return: |
| 1714 | return NULL; |
| 1715 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1716 | |
| 1717 | /* Purge everything in the acl_cond <cond>, then return <cond>. */ |
| 1718 | struct acl_cond *prune_acl_cond(struct acl_cond *cond) |
| 1719 | { |
| 1720 | struct acl_term_suite *suite, *tmp_suite; |
| 1721 | struct acl_term *term, *tmp_term; |
| 1722 | |
| 1723 | /* iterate through all term suites and free all terms and all suites */ |
| 1724 | list_for_each_entry_safe(suite, tmp_suite, &cond->suites, list) { |
| 1725 | list_for_each_entry_safe(term, tmp_term, &suite->terms, list) |
| 1726 | free(term); |
| 1727 | free(suite); |
| 1728 | } |
| 1729 | return cond; |
| 1730 | } |
| 1731 | |
| 1732 | /* Parse an ACL condition starting at <args>[0], relying on a list of already |
| 1733 | * known ACLs passed in <known_acl>. The new condition is returned (or NULL in |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1734 | * case of low memory). Supports multiple conditions separated by "or". If |
| 1735 | * <err> is not NULL, it will be filled with a pointer to an error message in |
| 1736 | * case of error, that the caller is responsible for freeing. The initial |
| 1737 | * location must either be freeable or NULL. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1738 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1739 | struct acl_cond *parse_acl_cond(const char **args, struct list *known_acl, int pol, char **err) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1740 | { |
| 1741 | __label__ out_return, out_free_suite, out_free_term; |
Willy Tarreau | 74b98a8 | 2007-06-16 19:35:18 +0200 | [diff] [blame] | 1742 | int arg, neg; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1743 | const char *word; |
| 1744 | struct acl *cur_acl; |
| 1745 | struct acl_term *cur_term; |
| 1746 | struct acl_term_suite *cur_suite; |
| 1747 | struct acl_cond *cond; |
| 1748 | |
| 1749 | cond = (struct acl_cond *)calloc(1, sizeof(*cond)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1750 | if (cond == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1751 | memprintf(err, "out of memory when parsing condition"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1752 | goto out_return; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1753 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1754 | |
| 1755 | LIST_INIT(&cond->list); |
| 1756 | LIST_INIT(&cond->suites); |
| 1757 | cond->pol = pol; |
| 1758 | |
| 1759 | cur_suite = NULL; |
Willy Tarreau | 74b98a8 | 2007-06-16 19:35:18 +0200 | [diff] [blame] | 1760 | neg = 0; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1761 | for (arg = 0; *args[arg]; arg++) { |
| 1762 | word = args[arg]; |
| 1763 | |
| 1764 | /* remove as many exclamation marks as we can */ |
| 1765 | while (*word == '!') { |
| 1766 | neg = !neg; |
| 1767 | word++; |
| 1768 | } |
| 1769 | |
| 1770 | /* an empty word is allowed because we cannot force the user to |
| 1771 | * always think about not leaving exclamation marks alone. |
| 1772 | */ |
| 1773 | if (!*word) |
| 1774 | continue; |
| 1775 | |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1776 | if (strcasecmp(word, "or") == 0 || strcmp(word, "||") == 0) { |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1777 | /* new term suite */ |
| 1778 | cur_suite = NULL; |
| 1779 | neg = 0; |
| 1780 | continue; |
| 1781 | } |
| 1782 | |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1783 | if (strcmp(word, "{") == 0) { |
| 1784 | /* we may have a complete ACL expression between two braces, |
| 1785 | * find the last one. |
| 1786 | */ |
| 1787 | int arg_end = arg + 1; |
| 1788 | const char **args_new; |
| 1789 | |
| 1790 | while (*args[arg_end] && strcmp(args[arg_end], "}") != 0) |
| 1791 | arg_end++; |
| 1792 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1793 | if (!*args[arg_end]) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1794 | memprintf(err, "missing closing '}' in condition"); |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1795 | goto out_free_suite; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1796 | } |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1797 | |
| 1798 | args_new = calloc(1, (arg_end - arg + 1) * sizeof(*args_new)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1799 | if (!args_new) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1800 | memprintf(err, "out of memory when parsing condition"); |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1801 | goto out_free_suite; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1802 | } |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1803 | |
Willy Tarreau | 2a56c5e | 2010-03-15 16:13:29 +0100 | [diff] [blame] | 1804 | args_new[0] = ""; |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1805 | memcpy(args_new + 1, args + arg + 1, (arg_end - arg) * sizeof(*args_new)); |
| 1806 | args_new[arg_end - arg] = ""; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1807 | cur_acl = parse_acl(args_new, known_acl, err); |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1808 | free(args_new); |
| 1809 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1810 | if (!cur_acl) { |
| 1811 | /* note that parse_acl() must have filled <err> here */ |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1812 | goto out_free_suite; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1813 | } |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1814 | arg = arg_end; |
| 1815 | } |
| 1816 | else { |
| 1817 | /* search for <word> in the known ACL names. If we do not find |
| 1818 | * it, let's look for it in the default ACLs, and if found, add |
| 1819 | * it to the list of ACLs of this proxy. This makes it possible |
| 1820 | * to override them. |
| 1821 | */ |
| 1822 | cur_acl = find_acl_by_name(word, known_acl); |
| 1823 | if (cur_acl == NULL) { |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1824 | cur_acl = find_acl_default(word, known_acl, err); |
| 1825 | if (cur_acl == NULL) { |
| 1826 | /* note that find_acl_default() must have filled <err> here */ |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1827 | goto out_free_suite; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1828 | } |
Willy Tarreau | 95fa469 | 2010-02-01 13:05:50 +0100 | [diff] [blame] | 1829 | } |
Willy Tarreau | 16fbe82 | 2007-06-17 11:54:31 +0200 | [diff] [blame] | 1830 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1831 | |
| 1832 | cur_term = (struct acl_term *)calloc(1, sizeof(*cur_term)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1833 | if (cur_term == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1834 | memprintf(err, "out of memory when parsing condition"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1835 | goto out_free_suite; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1836 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1837 | |
| 1838 | cur_term->acl = cur_acl; |
| 1839 | cur_term->neg = neg; |
Willy Tarreau | a980263 | 2008-07-25 19:13:19 +0200 | [diff] [blame] | 1840 | cond->requires |= cur_acl->requires; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1841 | |
| 1842 | if (!cur_suite) { |
| 1843 | cur_suite = (struct acl_term_suite *)calloc(1, sizeof(*cur_suite)); |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1844 | if (cur_term == NULL) { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1845 | memprintf(err, "out of memory when parsing condition"); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1846 | goto out_free_term; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1847 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1848 | LIST_INIT(&cur_suite->terms); |
| 1849 | LIST_ADDQ(&cond->suites, &cur_suite->list); |
| 1850 | } |
| 1851 | LIST_ADDQ(&cur_suite->terms, &cur_term->list); |
Willy Tarreau | 74b98a8 | 2007-06-16 19:35:18 +0200 | [diff] [blame] | 1852 | neg = 0; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1853 | } |
| 1854 | |
| 1855 | return cond; |
| 1856 | |
| 1857 | out_free_term: |
| 1858 | free(cur_term); |
| 1859 | out_free_suite: |
| 1860 | prune_acl_cond(cond); |
| 1861 | free(cond); |
| 1862 | out_return: |
| 1863 | return NULL; |
| 1864 | } |
| 1865 | |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1866 | /* Builds an ACL condition starting at the if/unless keyword. The complete |
| 1867 | * condition is returned. NULL is returned in case of error or if the first |
| 1868 | * word is neither "if" nor "unless". It automatically sets the file name and |
| 1869 | * the line number in the condition for better error reporting, and adds the |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1870 | * ACL requirements to the proxy's acl_requires. If <err> is not NULL, it will |
| 1871 | * be filled with a pointer to an error message in case of error, that the |
| 1872 | * caller is responsible for freeing. The initial location must either be |
| 1873 | * freeable or NULL. |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1874 | */ |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1875 | struct acl_cond *build_acl_cond(const char *file, int line, struct proxy *px, const char **args, char **err) |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1876 | { |
| 1877 | int pol = ACL_COND_NONE; |
| 1878 | struct acl_cond *cond = NULL; |
| 1879 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1880 | if (err) |
| 1881 | *err = NULL; |
| 1882 | |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1883 | if (!strcmp(*args, "if")) { |
| 1884 | pol = ACL_COND_IF; |
| 1885 | args++; |
| 1886 | } |
| 1887 | else if (!strcmp(*args, "unless")) { |
| 1888 | pol = ACL_COND_UNLESS; |
| 1889 | args++; |
| 1890 | } |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1891 | else { |
Willy Tarreau | eb6cead | 2012-09-20 19:43:14 +0200 | [diff] [blame] | 1892 | memprintf(err, "conditions must start with either 'if' or 'unless'"); |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1893 | return NULL; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1894 | } |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1895 | |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1896 | cond = parse_acl_cond(args, &px->acl, pol, err); |
| 1897 | if (!cond) { |
| 1898 | /* note that parse_acl_cond must have filled <err> here */ |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1899 | return NULL; |
Willy Tarreau | b7451bb | 2012-04-27 12:38:15 +0200 | [diff] [blame] | 1900 | } |
Willy Tarreau | 2bbba41 | 2010-01-28 16:48:33 +0100 | [diff] [blame] | 1901 | |
| 1902 | cond->file = file; |
| 1903 | cond->line = line; |
| 1904 | px->acl_requires |= cond->requires; |
| 1905 | |
| 1906 | return cond; |
| 1907 | } |
| 1908 | |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1909 | /* Execute condition <cond> and return either ACL_PAT_FAIL, ACL_PAT_MISS or |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1910 | * ACL_PAT_PASS depending on the test results. ACL_PAT_MISS may only be |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 1911 | * returned if <opt> does not contain SMP_OPT_FINAL, indicating that incomplete |
Willy Tarreau | 7a777ed | 2012-04-26 11:44:02 +0200 | [diff] [blame] | 1912 | * data is being examined. The function automatically sets SMP_OPT_ITERATE. |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1913 | * This function only computes the condition, it does not apply the polarity |
| 1914 | * required by IF/UNLESS, it's up to the caller to do this using something like |
| 1915 | * this : |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1916 | * |
| 1917 | * res = acl_pass(res); |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1918 | * if (res == ACL_PAT_MISS) |
| 1919 | * return 0; |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1920 | * if (cond->pol == ACL_COND_UNLESS) |
| 1921 | * res = !res; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1922 | */ |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 1923 | int acl_exec_cond(struct acl_cond *cond, struct proxy *px, struct session *l4, void *l7, unsigned int opt) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1924 | { |
| 1925 | __label__ fetch_next; |
| 1926 | struct acl_term_suite *suite; |
| 1927 | struct acl_term *term; |
| 1928 | struct acl_expr *expr; |
| 1929 | struct acl *acl; |
| 1930 | struct acl_pattern *pattern; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 1931 | struct sample smp; |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1932 | int acl_res, suite_res, cond_res; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1933 | |
Willy Tarreau | 7a777ed | 2012-04-26 11:44:02 +0200 | [diff] [blame] | 1934 | /* ACLs are iterated over all values, so let's always set the flag to |
| 1935 | * indicate this to the fetch functions. |
| 1936 | */ |
| 1937 | opt |= SMP_OPT_ITERATE; |
| 1938 | |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1939 | /* We're doing a logical OR between conditions so we initialize to FAIL. |
| 1940 | * The MISS status is propagated down from the suites. |
| 1941 | */ |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1942 | cond_res = ACL_PAT_FAIL; |
| 1943 | list_for_each_entry(suite, &cond->suites, list) { |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1944 | /* Evaluate condition suite <suite>. We stop at the first term |
| 1945 | * which returns ACL_PAT_FAIL. The MISS status is still propagated |
| 1946 | * in case of uncertainty in the result. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1947 | */ |
| 1948 | |
| 1949 | /* we're doing a logical AND between terms, so we must set the |
| 1950 | * initial value to PASS. |
| 1951 | */ |
| 1952 | suite_res = ACL_PAT_PASS; |
| 1953 | list_for_each_entry(term, &suite->terms, list) { |
| 1954 | acl = term->acl; |
| 1955 | |
| 1956 | /* FIXME: use cache ! |
| 1957 | * check acl->cache_idx for this. |
| 1958 | */ |
| 1959 | |
| 1960 | /* ACL result not cached. Let's scan all the expressions |
| 1961 | * and use the first one to match. |
| 1962 | */ |
| 1963 | acl_res = ACL_PAT_FAIL; |
| 1964 | list_for_each_entry(expr, &acl->expr, list) { |
Willy Tarreau | d41f8d8 | 2007-06-10 10:06:18 +0200 | [diff] [blame] | 1965 | /* we need to reset context and flags */ |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 1966 | memset(&smp, 0, sizeof(smp)); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1967 | fetch_next: |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 1968 | if (!expr->kw->fetch(px, l4, l7, opt, expr->args, &smp)) { |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1969 | /* maybe we could not fetch because of missing data */ |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 1970 | if (smp.flags & SMP_F_MAY_CHANGE && !(opt & SMP_OPT_FINAL)) |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1971 | acl_res |= ACL_PAT_MISS; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1972 | continue; |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 1973 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1974 | |
Willy Tarreau | 197e10a | 2012-04-23 19:18:42 +0200 | [diff] [blame] | 1975 | if (smp.type == SMP_T_BOOL) { |
| 1976 | if (smp.data.uint) |
Willy Tarreau | a79534f | 2008-07-20 10:13:37 +0200 | [diff] [blame] | 1977 | acl_res |= ACL_PAT_PASS; |
| 1978 | else |
| 1979 | acl_res |= ACL_PAT_FAIL; |
| 1980 | } |
| 1981 | else { |
Willy Tarreau | 020534d | 2010-05-16 21:45:45 +0200 | [diff] [blame] | 1982 | if (!eb_is_empty(&expr->pattern_tree)) { |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 1983 | /* a tree is present, let's check what type it is */ |
| 1984 | if (expr->kw->match == acl_match_str) |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 1985 | acl_res |= acl_lookup_str(&smp, expr) ? ACL_PAT_PASS : ACL_PAT_FAIL; |
Willy Tarreau | b337b53 | 2010-05-13 20:03:41 +0200 | [diff] [blame] | 1986 | else if (expr->kw->match == acl_match_ip) |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 1987 | acl_res |= acl_lookup_ip(&smp, expr) ? ACL_PAT_PASS : ACL_PAT_FAIL; |
Willy Tarreau | c426296 | 2010-05-10 23:42:40 +0200 | [diff] [blame] | 1988 | } |
| 1989 | |
Willy Tarreau | a79534f | 2008-07-20 10:13:37 +0200 | [diff] [blame] | 1990 | /* call the match() function for all tests on this value */ |
| 1991 | list_for_each_entry(pattern, &expr->patterns, list) { |
Willy Tarreau | a79534f | 2008-07-20 10:13:37 +0200 | [diff] [blame] | 1992 | if (acl_res == ACL_PAT_PASS) |
| 1993 | break; |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 1994 | acl_res |= expr->kw->match(&smp, pattern); |
Willy Tarreau | a79534f | 2008-07-20 10:13:37 +0200 | [diff] [blame] | 1995 | } |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 1996 | } |
| 1997 | /* |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 1998 | * OK now acl_res holds the result of this expression |
| 1999 | * as one of ACL_PAT_FAIL, ACL_PAT_MISS or ACL_PAT_PASS. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2000 | * |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2001 | * Then if (!MISS) we can cache the result, and put |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 2002 | * (smp.flags & SMP_F_VOLATILE) in the cache flags. |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2003 | * |
| 2004 | * FIXME: implement cache. |
| 2005 | * |
| 2006 | */ |
| 2007 | |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2008 | /* we're ORing these terms, so a single PASS is enough */ |
| 2009 | if (acl_res == ACL_PAT_PASS) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2010 | break; |
| 2011 | |
Willy Tarreau | 3740635 | 2012-04-23 16:16:37 +0200 | [diff] [blame] | 2012 | if (smp.flags & SMP_F_NOT_LAST) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2013 | goto fetch_next; |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 2014 | |
| 2015 | /* sometimes we know the fetched data is subject to change |
| 2016 | * later and give another chance for a new match (eg: request |
| 2017 | * size, time, ...) |
| 2018 | */ |
Willy Tarreau | 32a6f2e | 2012-04-25 10:13:36 +0200 | [diff] [blame] | 2019 | if (smp.flags & SMP_F_MAY_CHANGE && !(opt & SMP_OPT_FINAL)) |
Willy Tarreau | b686644 | 2008-07-14 23:54:42 +0200 | [diff] [blame] | 2020 | acl_res |= ACL_PAT_MISS; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2021 | } |
| 2022 | /* |
| 2023 | * Here we have the result of an ACL (cached or not). |
| 2024 | * ACLs are combined, negated or not, to form conditions. |
| 2025 | */ |
| 2026 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2027 | if (term->neg) |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2028 | acl_res = acl_neg(acl_res); |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2029 | |
| 2030 | suite_res &= acl_res; |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2031 | |
| 2032 | /* we're ANDing these terms, so a single FAIL is enough */ |
| 2033 | if (suite_res == ACL_PAT_FAIL) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2034 | break; |
| 2035 | } |
| 2036 | cond_res |= suite_res; |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2037 | |
| 2038 | /* we're ORing these terms, so a single PASS is enough */ |
| 2039 | if (cond_res == ACL_PAT_PASS) |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2040 | break; |
| 2041 | } |
Willy Tarreau | 1138281 | 2008-07-09 16:18:21 +0200 | [diff] [blame] | 2042 | return cond_res; |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2043 | } |
| 2044 | |
| 2045 | |
Willy Tarreau | dd64f8d | 2008-07-27 22:02:32 +0200 | [diff] [blame] | 2046 | /* Reports a pointer to the first ACL used in condition <cond> which requires |
| 2047 | * at least one of the USE_FLAGS in <require>. Returns NULL if none matches. |
| 2048 | * The construct is almost the same as for acl_exec_cond() since we're walking |
| 2049 | * down the ACL tree as well. It is important that the tree is really walked |
| 2050 | * through and never cached, because that way, this function can be used as a |
| 2051 | * late check. |
| 2052 | */ |
Willy Tarreau | f1e98b8 | 2010-01-28 17:59:39 +0100 | [diff] [blame] | 2053 | struct acl *cond_find_require(const struct acl_cond *cond, unsigned int require) |
Willy Tarreau | dd64f8d | 2008-07-27 22:02:32 +0200 | [diff] [blame] | 2054 | { |
| 2055 | struct acl_term_suite *suite; |
| 2056 | struct acl_term *term; |
| 2057 | struct acl *acl; |
| 2058 | |
| 2059 | list_for_each_entry(suite, &cond->suites, list) { |
| 2060 | list_for_each_entry(term, &suite->terms, list) { |
| 2061 | acl = term->acl; |
| 2062 | if (acl->requires & require) |
| 2063 | return acl; |
| 2064 | } |
| 2065 | } |
| 2066 | return NULL; |
| 2067 | } |
| 2068 | |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2069 | /* |
| 2070 | * Find targets for userlist and groups in acl. Function returns the number |
| 2071 | * of errors or OK if everything is fine. |
| 2072 | */ |
| 2073 | int |
| 2074 | acl_find_targets(struct proxy *p) |
| 2075 | { |
| 2076 | |
| 2077 | struct acl *acl; |
| 2078 | struct acl_expr *expr; |
| 2079 | struct acl_pattern *pattern; |
| 2080 | struct userlist *ul; |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2081 | struct arg *arg; |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2082 | int cfgerr = 0; |
| 2083 | |
| 2084 | list_for_each_entry(acl, &p->acl, list) { |
| 2085 | list_for_each_entry(expr, &acl->expr, list) { |
Willy Tarreau | 2e845be | 2012-10-19 19:49:09 +0200 | [diff] [blame] | 2086 | for (arg = expr->args; arg && arg->type != ARGT_STOP; arg++) { |
| 2087 | if (!arg->unresolved) |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2088 | continue; |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2089 | else if (arg->type == ARGT_SRV) { |
| 2090 | struct proxy *px; |
| 2091 | struct server *srv; |
| 2092 | char *pname, *sname; |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2093 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2094 | if (!expr->args->data.str.len) { |
| 2095 | Alert("proxy %s: acl '%s' %s(): missing server name.\n", |
| 2096 | p->id, acl->name, expr->kw->kw); |
| 2097 | cfgerr++; |
| 2098 | continue; |
| 2099 | } |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2100 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2101 | pname = expr->args->data.str.str; |
| 2102 | sname = strrchr(pname, '/'); |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2103 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2104 | if (sname) |
| 2105 | *sname++ = '\0'; |
| 2106 | else { |
| 2107 | sname = pname; |
| 2108 | pname = NULL; |
| 2109 | } |
| 2110 | |
| 2111 | px = p; |
| 2112 | if (pname) { |
| 2113 | px = findproxy(pname, PR_CAP_BE); |
| 2114 | if (!px) { |
| 2115 | Alert("proxy %s: acl '%s' %s(): unable to find proxy '%s'.\n", |
| 2116 | p->id, acl->name, expr->kw->kw, pname); |
| 2117 | cfgerr++; |
| 2118 | continue; |
| 2119 | } |
| 2120 | } |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2121 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2122 | srv = findserver(px, sname); |
| 2123 | if (!srv) { |
| 2124 | Alert("proxy %s: acl '%s' %s(): unable to find server '%s'.\n", |
| 2125 | p->id, acl->name, expr->kw->kw, sname); |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2126 | cfgerr++; |
| 2127 | continue; |
| 2128 | } |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2129 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2130 | free(expr->args->data.str.str); |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2131 | expr->args->data.str.str = NULL; |
| 2132 | arg->unresolved = 0; |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2133 | expr->args->data.srv = srv; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2134 | } |
| 2135 | else if (arg->type == ARGT_FE) { |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2136 | struct proxy *prx = p; |
| 2137 | char *pname = p->id; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2138 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2139 | if (expr->args->data.str.len) { |
| 2140 | pname = expr->args->data.str.str; |
| 2141 | prx = findproxy(pname, PR_CAP_FE); |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2142 | } |
| 2143 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2144 | if (!prx) { |
| 2145 | Alert("proxy %s: acl '%s' %s(): unable to find frontend '%s'.\n", |
| 2146 | p->id, acl->name, expr->kw->kw, pname); |
| 2147 | cfgerr++; |
| 2148 | continue; |
| 2149 | } |
| 2150 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2151 | if (!(prx->cap & PR_CAP_FE)) { |
| 2152 | Alert("proxy %s: acl '%s' %s(): proxy '%s' has no frontend capability.\n", |
| 2153 | p->id, acl->name, expr->kw->kw, pname); |
| 2154 | cfgerr++; |
| 2155 | continue; |
| 2156 | } |
| 2157 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2158 | free(expr->args->data.str.str); |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2159 | expr->args->data.str.str = NULL; |
| 2160 | arg->unresolved = 0; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2161 | expr->args->data.prx = prx; |
| 2162 | } |
| 2163 | else if (arg->type == ARGT_BE) { |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2164 | struct proxy *prx = p; |
| 2165 | char *pname = p->id; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2166 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2167 | if (expr->args->data.str.len) { |
| 2168 | pname = expr->args->data.str.str; |
| 2169 | prx = findproxy(pname, PR_CAP_BE); |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2170 | } |
| 2171 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2172 | if (!prx) { |
| 2173 | Alert("proxy %s: acl '%s' %s(): unable to find backend '%s'.\n", |
| 2174 | p->id, acl->name, expr->kw->kw, pname); |
| 2175 | cfgerr++; |
| 2176 | continue; |
| 2177 | } |
| 2178 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2179 | if (!(prx->cap & PR_CAP_BE)) { |
| 2180 | Alert("proxy %s: acl '%s' %s(): proxy '%s' has no backend capability.\n", |
| 2181 | p->id, acl->name, expr->kw->kw, pname); |
| 2182 | cfgerr++; |
| 2183 | continue; |
| 2184 | } |
| 2185 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2186 | free(expr->args->data.str.str); |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2187 | expr->args->data.str.str = NULL; |
| 2188 | arg->unresolved = 0; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2189 | expr->args->data.prx = prx; |
| 2190 | } |
| 2191 | else if (arg->type == ARGT_TAB) { |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2192 | struct proxy *prx = p; |
| 2193 | char *pname = p->id; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2194 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2195 | if (expr->args->data.str.len) { |
| 2196 | pname = expr->args->data.str.str; |
| 2197 | prx = find_stktable(pname); |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2198 | } |
| 2199 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2200 | if (!prx) { |
| 2201 | Alert("proxy %s: acl '%s' %s(): unable to find table '%s'.\n", |
| 2202 | p->id, acl->name, expr->kw->kw, pname); |
| 2203 | cfgerr++; |
| 2204 | continue; |
| 2205 | } |
| 2206 | |
Willy Tarreau | fc2c1fd | 2012-04-19 23:35:54 +0200 | [diff] [blame] | 2207 | |
| 2208 | if (!prx->table.size) { |
| 2209 | Alert("proxy %s: acl '%s' %s(): no table in proxy '%s'.\n", |
| 2210 | p->id, acl->name, expr->kw->kw, pname); |
| 2211 | cfgerr++; |
| 2212 | continue; |
| 2213 | } |
| 2214 | |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2215 | free(expr->args->data.str.str); |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2216 | expr->args->data.str.str = NULL; |
| 2217 | arg->unresolved = 0; |
Willy Tarreau | d28c353 | 2012-04-19 19:28:33 +0200 | [diff] [blame] | 2218 | expr->args->data.prx = prx; |
Willy Tarreau | 0b1cd94 | 2010-05-16 22:18:27 +0200 | [diff] [blame] | 2219 | } |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2220 | else if (arg->type == ARGT_USR) { |
| 2221 | if (!expr->args->data.str.len) { |
| 2222 | Alert("proxy %s: acl '%s' %s(): missing userlist name.\n", |
| 2223 | p->id, acl->name, expr->kw->kw); |
| 2224 | cfgerr++; |
| 2225 | continue; |
| 2226 | } |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2227 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2228 | if (p->uri_auth && p->uri_auth->userlist && |
| 2229 | !strcmp(p->uri_auth->userlist->name, expr->args->data.str.str)) |
| 2230 | ul = p->uri_auth->userlist; |
| 2231 | else |
| 2232 | ul = auth_find_userlist(expr->args->data.str.str); |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2233 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2234 | if (!ul) { |
| 2235 | Alert("proxy %s: acl '%s' %s(%s): unable to find userlist.\n", |
| 2236 | p->id, acl->name, expr->kw->kw, expr->args->data.str.str); |
| 2237 | cfgerr++; |
| 2238 | continue; |
| 2239 | } |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2240 | |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2241 | free(expr->args->data.str.str); |
Willy Tarreau | 496aa01 | 2012-06-01 10:38:29 +0200 | [diff] [blame] | 2242 | expr->args->data.str.str = NULL; |
| 2243 | arg->unresolved = 0; |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2244 | expr->args->data.usr = ul; |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2245 | } |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2246 | } /* end of args processing */ |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2247 | |
Willy Tarreau | 46b39d0 | 2012-05-10 23:40:14 +0200 | [diff] [blame] | 2248 | /* don't try to resolve groups if we're not certain of having |
| 2249 | * resolved userlists first. |
| 2250 | */ |
| 2251 | if (cfgerr) |
| 2252 | break; |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2253 | |
| 2254 | if (!strcmp(expr->kw->kw, "http_auth_group")) { |
Willy Tarreau | 63364ee | 2012-04-19 19:11:13 +0200 | [diff] [blame] | 2255 | /* note: argument resolved above thanks to ARGT_USR */ |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2256 | |
| 2257 | if (LIST_ISEMPTY(&expr->patterns)) { |
| 2258 | Alert("proxy %s: acl %s %s(): no groups specified.\n", |
| 2259 | p->id, acl->name, expr->kw->kw); |
| 2260 | cfgerr++; |
| 2261 | continue; |
| 2262 | } |
| 2263 | |
| 2264 | list_for_each_entry(pattern, &expr->patterns, list) { |
Willy Tarreau | 34db108 | 2012-04-19 17:16:54 +0200 | [diff] [blame] | 2265 | pattern->val.group_mask = auth_resolve_groups(expr->args->data.usr, pattern->ptr.str); |
Krzysztof Piotr Oledzki | f9423ae | 2010-01-29 19:26:18 +0100 | [diff] [blame] | 2266 | |
| 2267 | free(pattern->ptr.str); |
| 2268 | pattern->ptr.str = NULL; |
| 2269 | pattern->len = 0; |
| 2270 | |
| 2271 | if (!pattern->val.group_mask) { |
| 2272 | Alert("proxy %s: acl %s %s(): invalid group(s).\n", |
| 2273 | p->id, acl->name, expr->kw->kw); |
| 2274 | cfgerr++; |
| 2275 | continue; |
| 2276 | } |
| 2277 | } |
| 2278 | } |
| 2279 | } |
| 2280 | } |
| 2281 | |
| 2282 | return cfgerr; |
| 2283 | } |
Willy Tarreau | dd64f8d | 2008-07-27 22:02:32 +0200 | [diff] [blame] | 2284 | |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2285 | /************************************************************************/ |
| 2286 | /* All supported keywords must be declared here. */ |
| 2287 | /************************************************************************/ |
| 2288 | |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 2289 | /* Note: must not be declared <const> as its list will be overwritten. |
| 2290 | * Please take care of keeping this list alphabetically sorted. |
| 2291 | */ |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2292 | static struct acl_kw_list acl_kws = {{ },{ |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 2293 | { "always_false", acl_parse_nothing, acl_fetch_false, acl_match_nothing, ACL_USE_NOTHING, 0 }, |
| 2294 | { "always_true", acl_parse_nothing, acl_fetch_true, acl_match_nothing, ACL_USE_NOTHING, 0 }, |
| 2295 | { "rep_ssl_hello_type", acl_parse_int, acl_fetch_ssl_hello_type, acl_match_int, ACL_USE_L6RTR_VOLATILE, 0 }, |
| 2296 | { "req_len", acl_parse_int, acl_fetch_req_len, acl_match_int, ACL_USE_L6REQ_VOLATILE, 0 }, |
Willy Tarreau | 61612d4 | 2012-04-19 18:42:05 +0200 | [diff] [blame] | 2297 | { "req_ssl_hello_type", acl_parse_int, acl_fetch_ssl_hello_type, acl_match_int, ACL_USE_L6REQ_VOLATILE, 0 }, |
| 2298 | { "req_ssl_sni", acl_parse_str, acl_fetch_ssl_hello_sni, acl_match_str, ACL_USE_L6REQ_VOLATILE|ACL_MAY_LOOKUP, 0 }, |
| 2299 | { "req_ssl_ver", acl_parse_dotted_ver, acl_fetch_req_ssl_ver, acl_match_int, ACL_USE_L6REQ_VOLATILE, 0 }, |
| 2300 | { "wait_end", acl_parse_nothing, acl_fetch_wait_end, acl_match_nothing, ACL_USE_NOTHING, 0 }, |
Willy Tarreau | a84d374 | 2007-05-07 00:36:48 +0200 | [diff] [blame] | 2301 | { NULL, NULL, NULL, NULL } |
| 2302 | }}; |
| 2303 | |
| 2304 | |
| 2305 | __attribute__((constructor)) |
| 2306 | static void __acl_init(void) |
| 2307 | { |
| 2308 | acl_register_keywords(&acl_kws); |
| 2309 | } |
| 2310 | |
| 2311 | |
| 2312 | /* |
| 2313 | * Local variables: |
| 2314 | * c-indent-level: 8 |
| 2315 | * c-basic-offset: 8 |
| 2316 | * End: |
| 2317 | */ |