blob: 3bdc5bf612fb47be8bdac5d1550611e5185a8dca [file] [log] [blame]
Dragan Dosen93b38d92015-06-29 16:43:25 +02001#include <stdio.h>
2
Willy Tarreau4c7e4b72020-05-27 12:58:42 +02003#include <haproxy/api.h>
Dragan Dosen93b38d92015-06-29 16:43:25 +02004#include <common/cfgparse.h>
Willy Tarreauc13ed532020-06-02 10:22:45 +02005#include <haproxy/chunk.h>
Willy Tarreau2741c8c2020-06-02 11:28:02 +02006#include <haproxy/buf-t.h>
Willy Tarreau8d366972020-05-27 16:10:29 +02007#include <haproxy/errors.h>
Willy Tarreau126ba3a2020-06-04 18:26:43 +02008#include <haproxy/http_fetch.h>
Willy Tarreau87735332020-06-04 09:08:41 +02009#include <haproxy/http_htx.h>
Willy Tarreau3f567e42020-05-28 15:29:19 +020010#include <haproxy/thread.h>
Willy Tarreauf268ee82020-06-04 17:05:57 +020011#include <haproxy/global.h>
Willy Tarreauaa74c4e2020-06-04 10:19:23 +020012#include <haproxy/arg.h>
Dragan Dosen93b38d92015-06-29 16:43:25 +020013#include <proto/log.h>
Christopher Fauletfc9cfe42019-07-16 14:54:53 +020014#include <proto/http_ana.h>
Willy Tarreaue6ce10b2020-06-04 15:33:47 +020015#include <haproxy/sample.h>
Dragan Dosen93b38d92015-06-29 16:43:25 +020016#include <import/xxhash.h>
Dragan Dosen105c8e62015-06-29 16:43:26 +020017#include <import/lru.h>
Willy Tarreaub7a67142016-12-21 21:18:44 +010018#include <51Degrees.h>
Dragan Dosen93b38d92015-06-29 16:43:25 +020019
20struct _51d_property_names {
21 struct list list;
22 char *name;
23};
24
James Rosewella28bbd52015-09-18 18:28:52 +010025#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Dragan Dosen105c8e62015-06-29 16:43:26 +020026static struct lru64_head *_51d_lru_tree = NULL;
27static unsigned long long _51d_lru_seed;
Ben51Degrees4ddf59d2019-02-05 13:24:00 +000028
29__decl_spinlock(_51d_lru_lock);
James Rosewella28bbd52015-09-18 18:28:52 +010030#endif
Dragan Dosen105c8e62015-06-29 16:43:26 +020031
Willy Tarreaub7a67142016-12-21 21:18:44 +010032static struct {
33 char property_separator; /* the separator to use in the response for the values. this is taken from 51degrees-property-separator from config. */
34 struct list property_names; /* list of properties to load into the data set. this is taken from 51degrees-property-name-list from config. */
35 char *data_file_path;
36 int header_count; /* number of HTTP headers related to device detection. */
Willy Tarreau83061a82018-07-13 11:56:34 +020037 struct buffer *header_names; /* array of HTTP header names. */
Willy Tarreaub7a67142016-12-21 21:18:44 +010038 fiftyoneDegreesDataSet data_set; /* data set used with the pattern and trie detection methods. */
39#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
40 fiftyoneDegreesWorksetPool *pool; /* pool of worksets to avoid creating a new one for each request. */
41#endif
42#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
43 int32_t *header_offsets; /* offsets to the HTTP header name string. */
Ben51Degrees4ddf59d2019-02-05 13:24:00 +000044#ifdef FIFTYONEDEGREES_NO_THREADING
Willy Tarreaub7a67142016-12-21 21:18:44 +010045 fiftyoneDegreesDeviceOffsets device_offsets; /* Memory used for device offsets. */
46#endif
Ben51Degrees4ddf59d2019-02-05 13:24:00 +000047#endif
Willy Tarreaub7a67142016-12-21 21:18:44 +010048 int cache_size;
49} global_51degrees = {
50 .property_separator = ',',
51 .property_names = LIST_HEAD_INIT(global_51degrees.property_names),
52 .data_file_path = NULL,
53#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
54 .data_set = { },
55#endif
56 .cache_size = 0,
57};
58
Dragan Dosen93b38d92015-06-29 16:43:25 +020059static int _51d_data_file(char **args, int section_type, struct proxy *curpx,
60 struct proxy *defpx, const char *file, int line,
61 char **err)
62{
63 if (*(args[1]) == 0) {
64 memprintf(err,
65 "'%s' expects a filepath to a 51Degrees trie or pattern data file.",
66 args[0]);
67 return -1;
68 }
69
Willy Tarreaub7a67142016-12-21 21:18:44 +010070 if (global_51degrees.data_file_path)
71 free(global_51degrees.data_file_path);
72 global_51degrees.data_file_path = strdup(args[1]);
Dragan Dosen93b38d92015-06-29 16:43:25 +020073
74 return 0;
75}
76
77static int _51d_property_name_list(char **args, int section_type, struct proxy *curpx,
James Rosewella28bbd52015-09-18 18:28:52 +010078 struct proxy *defpx, const char *file, int line,
79 char **err)
Dragan Dosen93b38d92015-06-29 16:43:25 +020080{
81 int cur_arg = 1;
82 struct _51d_property_names *name;
83
84 if (*(args[cur_arg]) == 0) {
85 memprintf(err,
86 "'%s' expects at least one 51Degrees property name.",
87 args[0]);
88 return -1;
89 }
90
91 while (*(args[cur_arg])) {
Vincent Bernat02779b62016-04-03 13:48:43 +020092 name = calloc(1, sizeof(*name));
Dragan Dosen93b38d92015-06-29 16:43:25 +020093 name->name = strdup(args[cur_arg]);
Willy Tarreaub7a67142016-12-21 21:18:44 +010094 LIST_ADDQ(&global_51degrees.property_names, &name->list);
Dragan Dosen93b38d92015-06-29 16:43:25 +020095 ++cur_arg;
96 }
97
98 return 0;
99}
100
101static int _51d_property_separator(char **args, int section_type, struct proxy *curpx,
102 struct proxy *defpx, const char *file, int line,
103 char **err)
104{
105 if (*(args[1]) == 0) {
106 memprintf(err,
107 "'%s' expects a single character.",
108 args[0]);
109 return -1;
110 }
111 if (strlen(args[1]) > 1) {
112 memprintf(err,
113 "'%s' expects a single character, got '%s'.",
114 args[0], args[1]);
115 return -1;
116 }
117
Willy Tarreaub7a67142016-12-21 21:18:44 +0100118 global_51degrees.property_separator = *args[1];
Dragan Dosen93b38d92015-06-29 16:43:25 +0200119
120 return 0;
121}
122
Dragan Dosen105c8e62015-06-29 16:43:26 +0200123static int _51d_cache_size(char **args, int section_type, struct proxy *curpx,
124 struct proxy *defpx, const char *file, int line,
125 char **err)
126{
127 if (*(args[1]) == 0) {
128 memprintf(err,
129 "'%s' expects a positive numeric value.",
130 args[0]);
131 return -1;
132 }
133
Willy Tarreaub7a67142016-12-21 21:18:44 +0100134 global_51degrees.cache_size = atoi(args[1]);
135 if (global_51degrees.cache_size < 0) {
Dragan Dosen105c8e62015-06-29 16:43:26 +0200136 memprintf(err,
137 "'%s' expects a positive numeric value, got '%s'.",
138 args[0], args[1]);
139 return -1;
140 }
141
James Rosewella28bbd52015-09-18 18:28:52 +0100142 return 0;
143}
144
145static int _51d_fetch_check(struct arg *arg, char **err_msg)
146{
Willy Tarreaub7a67142016-12-21 21:18:44 +0100147 if (global_51degrees.data_file_path)
James Rosewella28bbd52015-09-18 18:28:52 +0100148 return 1;
149
150 memprintf(err_msg, "51Degrees data file is not specified (parameter '51degrees-data-file')");
Dragan Dosen105c8e62015-06-29 16:43:26 +0200151 return 0;
152}
153
Dragan Dosen9373fc52015-08-07 16:41:23 +0200154static int _51d_conv_check(struct arg *arg, struct sample_conv *conv,
James Rosewella28bbd52015-09-18 18:28:52 +0100155 const char *file, int line, char **err_msg)
Dragan Dosen9373fc52015-08-07 16:41:23 +0200156{
Willy Tarreaub7a67142016-12-21 21:18:44 +0100157 if (global_51degrees.data_file_path)
Dragan Dosen9373fc52015-08-07 16:41:23 +0200158 return 1;
159
James Rosewella28bbd52015-09-18 18:28:52 +0100160 memprintf(err_msg, "51Degrees data file is not specified (parameter '51degrees-data-file')");
Dragan Dosen9373fc52015-08-07 16:41:23 +0200161 return 0;
162}
163
James Rosewella28bbd52015-09-18 18:28:52 +0100164#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000165static void _51d_lru_free(void *cache_entry)
166{
Willy Tarreau83061a82018-07-13 11:56:34 +0200167 struct buffer *ptr = cache_entry;
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000168
169 if (!ptr)
170 return;
171
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200172 free(ptr->area);
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000173 free(ptr);
174}
175
176/* Allocates memory freeing space in the cache if necessary.
177*/
178static void *_51d_malloc(int size)
179{
180 void *ptr = malloc(size);
181
182 if (!ptr) {
183 /* free the oldest 10 entries from lru to free up some memory
184 * then try allocating memory again */
185 lru64_kill_oldest(_51d_lru_tree, 10);
186 ptr = malloc(size);
187 }
188
189 return ptr;
190}
191
James Rosewell63426cb2015-09-18 19:53:05 +0100192/* Insert the data associated with the sample into the cache as a fresh item.
193 */
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000194static void _51d_insert_cache_entry(struct sample *smp, struct lru64 *lru, void* domain)
James Rosewell63426cb2015-09-18 19:53:05 +0100195{
Willy Tarreau83061a82018-07-13 11:56:34 +0200196 struct buffer *cache_entry = _51d_malloc(sizeof(*cache_entry));
James Rosewell63426cb2015-09-18 19:53:05 +0100197
198 if (!cache_entry)
199 return;
200
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200201 cache_entry->area = _51d_malloc(smp->data.u.str.data + 1);
202 if (!cache_entry->area) {
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000203 free(cache_entry);
James Rosewell63426cb2015-09-18 19:53:05 +0100204 return;
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000205 }
James Rosewell63426cb2015-09-18 19:53:05 +0100206
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200207 memcpy(cache_entry->area, smp->data.u.str.area, smp->data.u.str.data);
208 cache_entry->area[smp->data.u.str.data] = 0;
209 cache_entry->data = smp->data.u.str.data;
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000210 HA_SPIN_LOCK(OTHER_LOCK, &_51d_lru_lock);
ben@51degrees.comc9dfa242016-01-08 13:47:46 +0000211 lru64_commit(lru, cache_entry, domain, 0, _51d_lru_free);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000212 HA_SPIN_UNLOCK(OTHER_LOCK, &_51d_lru_lock);
James Rosewell63426cb2015-09-18 19:53:05 +0100213}
214
215/* Retrieves the data from the cache and sets the sample data to this string.
216 */
217static void _51d_retrieve_cache_entry(struct sample *smp, struct lru64 *lru)
218{
Willy Tarreau83061a82018-07-13 11:56:34 +0200219 struct buffer *cache_entry = lru->data;
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200220 smp->data.u.str.area = cache_entry->area;
221 smp->data.u.str.data = cache_entry->data;
James Rosewell63426cb2015-09-18 19:53:05 +0100222}
223#endif
224
225#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
James Rosewella28bbd52015-09-18 18:28:52 +0100226/* Sets the important HTTP headers ahead of the detection
227 */
228static void _51d_set_headers(struct sample *smp, fiftyoneDegreesWorkset *ws)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200229{
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200230 struct channel *chn;
231 struct htx *htx;
232 struct http_hdr_ctx ctx;
233 struct ist name;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200234 int i;
James Rosewella28bbd52015-09-18 18:28:52 +0100235
James Rosewella28bbd52015-09-18 18:28:52 +0100236 ws->importantHeadersCount = 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200237 chn = (smp->strm ? &smp->strm->req : NULL);
Ben51Degrees31a51f22019-06-12 15:19:12 +0100238
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200239 // No need to null check as this has already been carried out in the
240 // calling method
Christopher Fauletf11b1fb2020-05-05 11:53:43 +0200241 htx = smp_prefetch_htx(smp, chn, NULL, 1);
Ben51Degrees31a51f22019-06-12 15:19:12 +0100242
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200243 for (i = 0; i < global_51degrees.header_count; i++) {
244 name.ptr = (global_51degrees.header_names + i)->area;
245 name.len = (global_51degrees.header_names + i)->data;
246 ctx.blk = NULL;
Ben51Degrees31a51f22019-06-12 15:19:12 +0100247
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200248 if (http_find_header(htx, name, &ctx, 1)) {
249 ws->importantHeaders[ws->importantHeadersCount].header = ws->dataSet->httpHeaders + i;
250 ws->importantHeaders[ws->importantHeadersCount].headerValue = ctx.value.ptr;
251 ws->importantHeaders[ws->importantHeadersCount].headerValueLength = ctx.value.len;
252 ws->importantHeadersCount++;
James Rosewella28bbd52015-09-18 18:28:52 +0100253 }
254 }
255}
Dragan Dosen93b38d92015-06-29 16:43:25 +0200256#endif
James Rosewella28bbd52015-09-18 18:28:52 +0100257
Dragan Dosen93b38d92015-06-29 16:43:25 +0200258#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000259static void _51d_init_device_offsets(fiftyoneDegreesDeviceOffsets *offsets) {
260 int i;
261 for (i = 0; i < global_51degrees.data_set.uniqueHttpHeaders.count; i++) {
262 offsets->firstOffset[i].userAgent = NULL;
263 }
264}
265
266static void _51d_set_device_offsets(struct sample *smp, fiftyoneDegreesDeviceOffsets *offsets)
James Rosewella28bbd52015-09-18 18:28:52 +0100267{
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200268 struct channel *chn;
269 struct htx *htx;
270 struct http_hdr_ctx ctx;
271 struct ist name;
Ben51Degrees31a51f22019-06-12 15:19:12 +0100272 int i;
Dragan Dosen105c8e62015-06-29 16:43:26 +0200273
James Rosewella28bbd52015-09-18 18:28:52 +0100274 offsets->size = 0;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200275 chn = (smp->strm ? &smp->strm->req : NULL);
Ben51Degrees31a51f22019-06-12 15:19:12 +0100276
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200277 // No need to null check as this has already been carried out in the
278 // calling method
Christopher Fauletf11b1fb2020-05-05 11:53:43 +0200279 htx = smp_prefetch_htx(smp, chn, NULL, 1);
Ben51Degrees31a51f22019-06-12 15:19:12 +0100280
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200281 for (i = 0; i < global_51degrees.header_count; i++) {
282 name.ptr = (global_51degrees.header_names + i)->area;
283 name.len = (global_51degrees.header_names + i)->data;
284 ctx.blk = NULL;
Ben51Degrees31a51f22019-06-12 15:19:12 +0100285
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200286 if (http_find_header(htx, name, &ctx, 1)) {
287 (offsets->firstOffset + offsets->size)->httpHeaderOffset = *(global_51degrees.header_offsets + i);
288 (offsets->firstOffset + offsets->size)->deviceOffset = fiftyoneDegreesGetDeviceOffset(&global_51degrees.data_set, ctx.value.ptr);
289 offsets->size++;
Ben51Degrees31a51f22019-06-12 15:19:12 +0100290 }
Ben51Degrees31a51f22019-06-12 15:19:12 +0100291 }
Ben51Degrees31a51f22019-06-12 15:19:12 +0100292
James Rosewella28bbd52015-09-18 18:28:52 +0100293}
294#endif
Dragan Dosen93b38d92015-06-29 16:43:25 +0200295
296#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
James Rosewella28bbd52015-09-18 18:28:52 +0100297/* Provides a hash code for the important HTTP headers.
298 */
299unsigned long long _51d_req_hash(const struct arg *args, fiftyoneDegreesWorkset* ws)
300{
301 unsigned long long seed = _51d_lru_seed ^ (long)args;
302 unsigned long long hash = 0;
303 int i;
304 for(i = 0; i < ws->importantHeadersCount; i++) {
305 hash ^= ws->importantHeaders[i].header->headerNameOffset;
306 hash ^= XXH64(ws->importantHeaders[i].headerValue,
307 ws->importantHeaders[i].headerValueLength,
308 seed);
309 }
310 return hash;
311}
Dragan Dosen93b38d92015-06-29 16:43:25 +0200312#endif
313
Dragan Dosen93b38d92015-06-29 16:43:25 +0200314#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
James Rosewella28bbd52015-09-18 18:28:52 +0100315static void _51d_process_match(const struct arg *args, struct sample *smp, fiftyoneDegreesWorkset* ws)
316{
317 char *methodName;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200318#endif
319#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000320static void _51d_process_match(const struct arg *args, struct sample *smp, fiftyoneDegreesDeviceOffsets *offsets)
James Rosewella28bbd52015-09-18 18:28:52 +0100321{
322 char valuesBuffer[1024];
Willy Tarreaub7a67142016-12-21 21:18:44 +0100323 const char **requiredProperties = fiftyoneDegreesGetRequiredPropertiesNames(&global_51degrees.data_set);
324 int requiredPropertiesCount = fiftyoneDegreesGetRequiredPropertiesCount(&global_51degrees.data_set);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200325#endif
326
James Rosewella28bbd52015-09-18 18:28:52 +0100327 char no_data[] = "NoData"; /* response when no data could be found */
Willy Tarreau83061a82018-07-13 11:56:34 +0200328 struct buffer *temp = get_trash_chunk();
James Rosewella28bbd52015-09-18 18:28:52 +0100329 int j, i = 0, found;
330 const char* property_name;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200331
332 /* Loop through property names passed to the filter and fetch them from the dataset. */
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200333 while (args[i].data.str.area) {
Dragan Dosen93b38d92015-06-29 16:43:25 +0200334 /* Try to find request property in dataset. */
Dragan Dosen93b38d92015-06-29 16:43:25 +0200335 found = 0;
James Rosewella28bbd52015-09-18 18:28:52 +0100336#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200337 if (strcmp("Method", args[i].data.str.area) == 0) {
James Rosewella28bbd52015-09-18 18:28:52 +0100338 switch(ws->method) {
339 case EXACT: methodName = "Exact"; break;
340 case NUMERIC: methodName = "Numeric"; break;
341 case NEAREST: methodName = "Nearest"; break;
342 case CLOSEST: methodName = "Closest"; break;
343 default:
344 case NONE: methodName = "None"; break;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200345 }
James Rosewella28bbd52015-09-18 18:28:52 +0100346 chunk_appendf(temp, "%s", methodName);
347 found = 1;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200348 }
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200349 else if (strcmp("Difference", args[i].data.str.area) == 0) {
James Rosewella28bbd52015-09-18 18:28:52 +0100350 chunk_appendf(temp, "%d", ws->difference);
351 found = 1;
352 }
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200353 else if (strcmp("Rank", args[i].data.str.area) == 0) {
James Rosewella28bbd52015-09-18 18:28:52 +0100354 chunk_appendf(temp, "%d", fiftyoneDegreesGetSignatureRank(ws));
355 found = 1;
356 }
357 else {
358 for (j = 0; j < ws->dataSet->requiredPropertyCount; j++) {
359 property_name = fiftyoneDegreesGetPropertyName(ws->dataSet, ws->dataSet->requiredProperties[j]);
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200360 if (strcmp(property_name, args[i].data.str.area) == 0) {
James Rosewella28bbd52015-09-18 18:28:52 +0100361 found = 1;
362 fiftyoneDegreesSetValues(ws, j);
363 chunk_appendf(temp, "%s", fiftyoneDegreesGetValueName(ws->dataSet, *ws->values));
364 break;
365 }
366 }
Dragan Dosen93b38d92015-06-29 16:43:25 +0200367 }
368#endif
369#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
James Rosewella28bbd52015-09-18 18:28:52 +0100370 found = 0;
371 for (j = 0; j < requiredPropertiesCount; j++) {
372 property_name = requiredProperties[j];
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200373 if (strcmp(property_name, args[i].data.str.area) == 0 &&
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000374 fiftyoneDegreesGetValueFromOffsets(&global_51degrees.data_set, offsets, j, valuesBuffer, 1024) > 0) {
James Rosewella28bbd52015-09-18 18:28:52 +0100375 found = 1;
376 chunk_appendf(temp, "%s", valuesBuffer);
377 break;
378 }
Dragan Dosen93b38d92015-06-29 16:43:25 +0200379 }
James Rosewella28bbd52015-09-18 18:28:52 +0100380#endif
ben@51degrees.comd3842522016-01-08 13:52:32 +0000381 if (!found)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200382 chunk_appendf(temp, "%s", no_data);
ben@51degrees.comd3842522016-01-08 13:52:32 +0000383
Dragan Dosen93b38d92015-06-29 16:43:25 +0200384 /* Add separator. */
Willy Tarreaub7a67142016-12-21 21:18:44 +0100385 chunk_appendf(temp, "%c", global_51degrees.property_separator);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200386 ++i;
387 }
388
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200389 if (temp->data) {
390 --temp->data;
391 temp->area[temp->data] = '\0';
Dragan Dosen93b38d92015-06-29 16:43:25 +0200392 }
393
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200394 smp->data.u.str.area = temp->area;
395 smp->data.u.str.data = temp->data;
James Rosewella28bbd52015-09-18 18:28:52 +0100396}
397
Ben51Degrees6bf06722020-01-20 11:25:11 +0000398/* Sets the sample data as a constant string. This ensures that the
399 * string will be processed correctly.
400 */
401static void _51d_set_smp(struct sample *smp)
402{
403 /*
404 * Data type has to be set to ensure the string output is processed
405 * correctly.
406 */
407 smp->data.type = SMP_T_STR;
408
409 /* Flags the sample to show it uses constant memory. */
410 smp->flags |= SMP_F_CONST;
411}
412
James Rosewella28bbd52015-09-18 18:28:52 +0100413static int _51d_fetch(const struct arg *args, struct sample *smp, const char *kw, void *private)
414{
415#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
416 fiftyoneDegreesWorkset* ws; /* workset for detection */
417 struct lru64 *lru = NULL;
418#endif
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000419#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
420 fiftyoneDegreesDeviceOffsets *offsets; /* Offsets for detection */
Ben51Degrees31a51f22019-06-12 15:19:12 +0100421
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000422#endif
Ben51Degrees31a51f22019-06-12 15:19:12 +0100423 struct channel *chn;
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200424 struct htx *htx;
425
Ben51Degrees31a51f22019-06-12 15:19:12 +0100426 chn = (smp->strm ? &smp->strm->req : NULL);
Christopher Fauletf11b1fb2020-05-05 11:53:43 +0200427 htx = smp_prefetch_htx(smp, chn, NULL, 1);
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200428 if (!htx)
429 return 0;
James Rosewella28bbd52015-09-18 18:28:52 +0100430
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000431
James Rosewella28bbd52015-09-18 18:28:52 +0100432#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
433
434 /* Get only the headers needed for device detection so they can be used
435 * with the cache to return previous results. Pattern is slower than
436 * Trie so caching will help improve performance.
437 */
438
439 /* Get a workset from the pool which will later contain detection results. */
Willy Tarreaub7a67142016-12-21 21:18:44 +0100440 ws = fiftyoneDegreesWorksetPoolGet(global_51degrees.pool);
James Rosewella28bbd52015-09-18 18:28:52 +0100441 if (!ws)
442 return 0;
443
444 /* Set the important HTTP headers for this request in the workset. */
445 _51d_set_headers(smp, ws);
446
447 /* Check the cache to see if there's results for these headers already. */
448 if (_51d_lru_tree) {
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000449 HA_SPIN_LOCK(OTHER_LOCK, &_51d_lru_lock);
450
James Rosewella28bbd52015-09-18 18:28:52 +0100451 lru = lru64_get(_51d_req_hash(args, ws),
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000452 _51d_lru_tree, (void*)args, 0);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000453
James Rosewella28bbd52015-09-18 18:28:52 +0100454 if (lru && lru->domain) {
Willy Tarreaub7a67142016-12-21 21:18:44 +0100455 fiftyoneDegreesWorksetPoolRelease(global_51degrees.pool, ws);
James Rosewell63426cb2015-09-18 19:53:05 +0100456 _51d_retrieve_cache_entry(smp, lru);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000457 HA_SPIN_UNLOCK(OTHER_LOCK, &_51d_lru_lock);
Ben51Degrees6bf06722020-01-20 11:25:11 +0000458
459 _51d_set_smp(smp);
James Rosewella28bbd52015-09-18 18:28:52 +0100460 return 1;
461 }
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000462 HA_SPIN_UNLOCK(OTHER_LOCK, &_51d_lru_lock);
James Rosewella28bbd52015-09-18 18:28:52 +0100463 }
464
465 fiftyoneDegreesMatchForHttpHeaders(ws);
466
467 _51d_process_match(args, smp, ws);
468
469#endif
470
471#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000472#ifndef FIFTYONEDEGREES_NO_THREADING
473 offsets = fiftyoneDegreesCreateDeviceOffsets(&global_51degrees.data_set);
474 _51d_init_device_offsets(offsets);
475#else
476 offsets = &global_51degrees.device_offsets;
477#endif
James Rosewella28bbd52015-09-18 18:28:52 +0100478
479 /* Trie is very fast so all the headers can be passed in and the result
480 * returned faster than the hashing algorithm process.
481 */
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000482 _51d_set_device_offsets(smp, offsets);
483 _51d_process_match(args, smp, offsets);
James Rosewella28bbd52015-09-18 18:28:52 +0100484
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000485#ifndef FIFTYONEDEGREES_NO_THREADING
486 fiftyoneDegreesFreeDeviceOffsets(offsets);
James Rosewella28bbd52015-09-18 18:28:52 +0100487#endif
488
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000489#endif
490
James Rosewella28bbd52015-09-18 18:28:52 +0100491#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Willy Tarreaub7a67142016-12-21 21:18:44 +0100492 fiftyoneDegreesWorksetPoolRelease(global_51degrees.pool, ws);
ben@51degrees.comd3842522016-01-08 13:52:32 +0000493 if (lru)
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000494 _51d_insert_cache_entry(smp, lru, (void*)args);
James Rosewella28bbd52015-09-18 18:28:52 +0100495#endif
496
Ben51Degrees6bf06722020-01-20 11:25:11 +0000497 _51d_set_smp(smp);
James Rosewella28bbd52015-09-18 18:28:52 +0100498 return 1;
499}
Dragan Dosen93b38d92015-06-29 16:43:25 +0200500
James Rosewella28bbd52015-09-18 18:28:52 +0100501static int _51d_conv(const struct arg *args, struct sample *smp, void *private)
502{
Dragan Dosen93b38d92015-06-29 16:43:25 +0200503#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
James Rosewella28bbd52015-09-18 18:28:52 +0100504 fiftyoneDegreesWorkset* ws; /* workset for detection */
505 struct lru64 *lru = NULL;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200506#endif
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000507#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
508 fiftyoneDegreesDeviceOffsets *offsets; /* Offsets for detection */
509#endif
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000510
James Rosewella28bbd52015-09-18 18:28:52 +0100511#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
512
513 /* Look in the list. */
514 if (_51d_lru_tree) {
515 unsigned long long seed = _51d_lru_seed ^ (long)args;
516
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000517 HA_SPIN_LOCK(OTHER_LOCK, &_51d_lru_lock);
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200518 lru = lru64_get(XXH64(smp->data.u.str.area, smp->data.u.str.data, seed),
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000519 _51d_lru_tree, (void*)args, 0);
James Rosewella28bbd52015-09-18 18:28:52 +0100520 if (lru && lru->domain) {
James Rosewell63426cb2015-09-18 19:53:05 +0100521 _51d_retrieve_cache_entry(smp, lru);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000522 HA_SPIN_UNLOCK(OTHER_LOCK, &_51d_lru_lock);
James Rosewella28bbd52015-09-18 18:28:52 +0100523 return 1;
524 }
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000525 HA_SPIN_UNLOCK(OTHER_LOCK, &_51d_lru_lock);
James Rosewella28bbd52015-09-18 18:28:52 +0100526 }
527
528 /* Create workset. This will later contain detection results. */
Willy Tarreaub7a67142016-12-21 21:18:44 +0100529 ws = fiftyoneDegreesWorksetPoolGet(global_51degrees.pool);
James Rosewella28bbd52015-09-18 18:28:52 +0100530 if (!ws)
531 return 0;
532#endif
533
534 /* Duplicate the data and remove the "const" flag before device detection. */
535 if (!smp_dup(smp))
536 return 0;
537
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200538 smp->data.u.str.area[smp->data.u.str.data] = '\0';
James Rosewella28bbd52015-09-18 18:28:52 +0100539
540 /* Perform detection. */
541#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200542 fiftyoneDegreesMatch(ws, smp->data.u.str.area);
James Rosewella28bbd52015-09-18 18:28:52 +0100543 _51d_process_match(args, smp, ws);
544#endif
545#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000546#ifndef FIFTYONEDEGREES_NO_THREADING
547 offsets = fiftyoneDegreesCreateDeviceOffsets(&global_51degrees.data_set);
548 _51d_init_device_offsets(offsets);
549#else
550 offsets = &global_51degrees.device_offsets;
551#endif
552
553 offsets->firstOffset->deviceOffset = fiftyoneDegreesGetDeviceOffset(&global_51degrees.data_set,
554 smp->data.u.str.area);
555 offsets->size = 1;
556 _51d_process_match(args, smp, offsets);
James Rosewella28bbd52015-09-18 18:28:52 +0100557#endif
558
559#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Willy Tarreaub7a67142016-12-21 21:18:44 +0100560 fiftyoneDegreesWorksetPoolRelease(global_51degrees.pool, ws);
ben@51degrees.comd3842522016-01-08 13:52:32 +0000561 if (lru)
ben@51degrees.com82a9d762016-01-08 13:42:41 +0000562 _51d_insert_cache_entry(smp, lru, (void*)args);
James Rosewella28bbd52015-09-18 18:28:52 +0100563#endif
Dragan Dosen105c8e62015-06-29 16:43:26 +0200564
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000565#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
566#ifndef FIFTYONEDEGREES_NO_THREADING
567 fiftyoneDegreesFreeDeviceOffsets(offsets);
568#endif
569#endif
570
Ben51Degrees6bf06722020-01-20 11:25:11 +0000571 _51d_set_smp(smp);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200572 return 1;
573}
574
James Rosewella28bbd52015-09-18 18:28:52 +0100575#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
576void _51d_init_http_headers()
577{
578 int index = 0;
579 const fiftyoneDegreesAsciiString *headerName;
Willy Tarreaub7a67142016-12-21 21:18:44 +0100580 fiftyoneDegreesDataSet *ds = &global_51degrees.data_set;
581 global_51degrees.header_count = ds->httpHeadersCount;
Willy Tarreau83061a82018-07-13 11:56:34 +0200582 global_51degrees.header_names = malloc(global_51degrees.header_count * sizeof(struct buffer));
Willy Tarreaub7a67142016-12-21 21:18:44 +0100583 for (index = 0; index < global_51degrees.header_count; index++) {
James Rosewella28bbd52015-09-18 18:28:52 +0100584 headerName = fiftyoneDegreesGetString(ds, ds->httpHeaders[index].headerNameOffset);
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200585 (global_51degrees.header_names + index)->area = (char*)&headerName->firstByte;
586 (global_51degrees.header_names + index)->data = headerName->length - 1;
587 (global_51degrees.header_names + index)->size = (global_51degrees.header_names + index)->data;
James Rosewella28bbd52015-09-18 18:28:52 +0100588 }
589}
590#endif
591
592#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
593void _51d_init_http_headers()
594{
595 int index = 0;
Willy Tarreaub7a67142016-12-21 21:18:44 +0100596 fiftyoneDegreesDataSet *ds = &global_51degrees.data_set;
597 global_51degrees.header_count = fiftyoneDegreesGetHttpHeaderCount(ds);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000598#ifdef FIFTYONEDEGREES_NO_THREADING
Willy Tarreaub7a67142016-12-21 21:18:44 +0100599 global_51degrees.device_offsets.firstOffset = malloc(
600 global_51degrees.header_count * sizeof(fiftyoneDegreesDeviceOffset));
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000601 _51d_init_device_offsets(&global_51degrees.device_offsets);
602#endif
Willy Tarreau83061a82018-07-13 11:56:34 +0200603 global_51degrees.header_names = malloc(global_51degrees.header_count * sizeof(struct buffer));
Willy Tarreaub7a67142016-12-21 21:18:44 +0100604 global_51degrees.header_offsets = malloc(global_51degrees.header_count * sizeof(int32_t));
605 for (index = 0; index < global_51degrees.header_count; index++) {
606 global_51degrees.header_offsets[index] = fiftyoneDegreesGetHttpHeaderNameOffset(ds, index);
Ben51Degreese0f6a2a2019-02-05 13:23:06 +0000607 global_51degrees.header_names[index].area = (char*)fiftyoneDegreesGetHttpHeaderNamePointer(ds, index);
608 global_51degrees.header_names[index].data = strlen(global_51degrees.header_names[index].area);
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200609 global_51degrees.header_names[index].size = global_51degrees.header_names->data;
James Rosewella28bbd52015-09-18 18:28:52 +0100610 }
611}
612#endif
613
Willy Tarreau9f3f2542016-12-21 20:30:05 +0100614/*
615 * module init / deinit functions. Returns 0 if OK, or a combination of ERR_*.
616 */
617static int init_51degrees(void)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200618{
619 int i = 0;
Willy Tarreau83061a82018-07-13 11:56:34 +0200620 struct buffer *temp;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200621 struct _51d_property_names *name;
622 char **_51d_property_list = NULL;
623 fiftyoneDegreesDataSetInitStatus _51d_dataset_status = DATA_SET_INIT_STATUS_NOT_SET;
624
Willy Tarreaub7a67142016-12-21 21:18:44 +0100625 if (!global_51degrees.data_file_path)
Willy Tarreau9f3f2542016-12-21 20:30:05 +0100626 return 0;
Dragan Dosen9373fc52015-08-07 16:41:23 +0200627
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000628 if (global.nbthread < 1) {
629 ha_alert("51Degrees: The thread count cannot be zero or negative.\n");
Christopher Faulete8ca4342017-10-25 17:23:02 +0200630 return (ERR_FATAL | ERR_ALERT);
631 }
632
Willy Tarreaub7a67142016-12-21 21:18:44 +0100633 if (!LIST_ISEMPTY(&global_51degrees.property_names)) {
Dragan Dosen93b38d92015-06-29 16:43:25 +0200634 i = 0;
Willy Tarreaub7a67142016-12-21 21:18:44 +0100635 list_for_each_entry(name, &global_51degrees.property_names, list)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200636 ++i;
637 _51d_property_list = calloc(i, sizeof(char *));
638
639 i = 0;
Willy Tarreaub7a67142016-12-21 21:18:44 +0100640 list_for_each_entry(name, &global_51degrees.property_names, list)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200641 _51d_property_list[i++] = name->name;
642 }
643
Willy Tarreaub7a67142016-12-21 21:18:44 +0100644 _51d_dataset_status = fiftyoneDegreesInitWithPropertyArray(global_51degrees.data_file_path, &global_51degrees.data_set, (const char**)_51d_property_list, i);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200645
646 temp = get_trash_chunk();
647 chunk_reset(temp);
648
649 switch (_51d_dataset_status) {
650 case DATA_SET_INIT_STATUS_SUCCESS:
James Rosewella28bbd52015-09-18 18:28:52 +0100651#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000652 global_51degrees.pool = fiftyoneDegreesWorksetPoolCreate(&global_51degrees.data_set, NULL, global.nbthread);
James Rosewella28bbd52015-09-18 18:28:52 +0100653#endif
654 _51d_init_http_headers();
Dragan Dosen93b38d92015-06-29 16:43:25 +0200655 break;
656 case DATA_SET_INIT_STATUS_INSUFFICIENT_MEMORY:
657 chunk_printf(temp, "Insufficient memory.");
658 break;
659 case DATA_SET_INIT_STATUS_CORRUPT_DATA:
660#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
661 chunk_printf(temp, "Corrupt data file. Check that the data file provided is uncompressed and Pattern data format.");
662#endif
663#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
664 chunk_printf(temp, "Corrupt data file. Check that the data file provided is uncompressed and Trie data format.");
665#endif
666 break;
667 case DATA_SET_INIT_STATUS_INCORRECT_VERSION:
668#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
669 chunk_printf(temp, "Incorrect version. Check that the data file provided is uncompressed and Pattern data format.");
670#endif
671#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
672 chunk_printf(temp, "Incorrect version. Check that the data file provided is uncompressed and Trie data format.");
673#endif
674 break;
675 case DATA_SET_INIT_STATUS_FILE_NOT_FOUND:
676 chunk_printf(temp, "File not found.");
677 break;
ben51degrees1f077eb2016-07-06 12:07:21 +0100678 case DATA_SET_INIT_STATUS_NULL_POINTER:
679 chunk_printf(temp, "Null pointer to the existing dataset or memory location.");
680 break;
681 case DATA_SET_INIT_STATUS_POINTER_OUT_OF_BOUNDS:
682 chunk_printf(temp, "Allocated continuous memory containing 51Degrees data file appears to be smaller than expected. Most likely"
683 " because the data file was not fully loaded into the allocated memory.");
684 break;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200685 case DATA_SET_INIT_STATUS_NOT_SET:
686 chunk_printf(temp, "Data set not initialised.");
687 break;
Dragan Dosen483b93c2017-09-27 12:46:44 +0200688 default:
689 chunk_printf(temp, "Other error.");
690 break;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200691 }
692 if (_51d_dataset_status != DATA_SET_INIT_STATUS_SUCCESS) {
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200693 if (temp->data)
694 ha_alert("51Degrees Setup - Error reading 51Degrees data file. %s\n",
695 temp->area);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200696 else
Christopher Faulet767a84b2017-11-24 16:50:31 +0100697 ha_alert("51Degrees Setup - Error reading 51Degrees data file.\n");
Willy Tarreau9f3f2542016-12-21 20:30:05 +0100698 return ERR_ALERT | ERR_FATAL;
Dragan Dosen93b38d92015-06-29 16:43:25 +0200699 }
700 free(_51d_property_list);
701
James Rosewella28bbd52015-09-18 18:28:52 +0100702#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Willy Tarreau52bf8392020-03-08 00:42:37 +0100703 _51d_lru_seed = ha_random();
Willy Tarreaub7a67142016-12-21 21:18:44 +0100704 if (global_51degrees.cache_size) {
705 _51d_lru_tree = lru64_new(global_51degrees.cache_size);
James Rosewella28bbd52015-09-18 18:28:52 +0100706 }
707#endif
Dragan Dosen105c8e62015-06-29 16:43:26 +0200708
Dragan Dosen93b38d92015-06-29 16:43:25 +0200709 return 0;
710}
711
Willy Tarreau7ac4c202016-12-21 20:59:01 +0100712static void deinit_51degrees(void)
Dragan Dosen93b38d92015-06-29 16:43:25 +0200713{
714 struct _51d_property_names *_51d_prop_name, *_51d_prop_nameb;
715
Willy Tarreaub7a67142016-12-21 21:18:44 +0100716 free(global_51degrees.header_names);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200717#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Dragan Dosenbc6218e2019-03-07 15:24:23 +0100718 if (global_51degrees.pool)
719 fiftyoneDegreesWorksetPoolFree(global_51degrees.pool);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200720#endif
721#ifdef FIFTYONEDEGREES_H_TRIE_INCLUDED
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000722#ifdef FIFTYONEDEGREES_NO_THREADING
Willy Tarreaub7a67142016-12-21 21:18:44 +0100723 free(global_51degrees.device_offsets.firstOffset);
Ben51Degrees4ddf59d2019-02-05 13:24:00 +0000724#endif
Willy Tarreaub7a67142016-12-21 21:18:44 +0100725 free(global_51degrees.header_offsets);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200726#endif
Willy Tarreaub7a67142016-12-21 21:18:44 +0100727 fiftyoneDegreesDataSetFree(&global_51degrees.data_set);
Dragan Dosen93b38d92015-06-29 16:43:25 +0200728
Willy Tarreaub7a67142016-12-21 21:18:44 +0100729 free(global_51degrees.data_file_path); global_51degrees.data_file_path = NULL;
730 list_for_each_entry_safe(_51d_prop_name, _51d_prop_nameb, &global_51degrees.property_names, list) {
Dragan Dosen93b38d92015-06-29 16:43:25 +0200731 LIST_DEL(&_51d_prop_name->list);
732 free(_51d_prop_name);
733 }
Dragan Dosen105c8e62015-06-29 16:43:26 +0200734
James Rosewella28bbd52015-09-18 18:28:52 +0100735#ifdef FIFTYONEDEGREES_H_PATTERN_INCLUDED
Dragan Dosen105c8e62015-06-29 16:43:26 +0200736 while (lru64_destroy(_51d_lru_tree));
James Rosewella28bbd52015-09-18 18:28:52 +0100737#endif
Dragan Dosen93b38d92015-06-29 16:43:25 +0200738}
739
740static struct cfg_kw_list _51dcfg_kws = {{ }, {
741 { CFG_GLOBAL, "51degrees-data-file", _51d_data_file },
742 { CFG_GLOBAL, "51degrees-property-name-list", _51d_property_name_list },
743 { CFG_GLOBAL, "51degrees-property-separator", _51d_property_separator },
Dragan Dosen105c8e62015-06-29 16:43:26 +0200744 { CFG_GLOBAL, "51degrees-cache-size", _51d_cache_size },
Dragan Dosen93b38d92015-06-29 16:43:25 +0200745 { 0, NULL, NULL },
746}};
747
Willy Tarreau0108d902018-11-25 19:14:37 +0100748INITCALL1(STG_REGISTER, cfg_register_keywords, &_51dcfg_kws);
749
Dragan Dosen93b38d92015-06-29 16:43:25 +0200750/* Note: must not be declared <const> as its list will be overwritten */
James Rosewella28bbd52015-09-18 18:28:52 +0100751static struct sample_fetch_kw_list sample_fetch_keywords = {ILH, {
752 { "51d.all", _51d_fetch, ARG5(1,STR,STR,STR,STR,STR), _51d_fetch_check, SMP_T_STR, SMP_USE_HRQHV },
753 { NULL, NULL, 0, 0, 0 },
754}};
755
Willy Tarreau0108d902018-11-25 19:14:37 +0100756INITCALL1(STG_REGISTER, sample_register_fetches, &sample_fetch_keywords);
757
James Rosewella28bbd52015-09-18 18:28:52 +0100758/* Note: must not be declared <const> as its list will be overwritten */
Dragan Dosen93b38d92015-06-29 16:43:25 +0200759static struct sample_conv_kw_list conv_kws = {ILH, {
James Rosewella28bbd52015-09-18 18:28:52 +0100760 { "51d.single", _51d_conv, ARG5(1,STR,STR,STR,STR,STR), _51d_conv_check, SMP_T_STR, SMP_T_STR },
Dragan Dosen93b38d92015-06-29 16:43:25 +0200761 { NULL, NULL, 0, 0, 0 },
762}};
763
Willy Tarreau0108d902018-11-25 19:14:37 +0100764INITCALL1(STG_REGISTER, sample_register_convs, &conv_kws);
765
Willy Tarreau172f5ce2018-11-26 11:21:50 +0100766REGISTER_POST_CHECK(init_51degrees);
767REGISTER_POST_DEINIT(deinit_51degrees);
Ben51Degreesf4a82fb2019-06-13 16:51:59 +0100768
769#if defined(FIFTYONEDEGREES_H_PATTERN_INCLUDED)
770#ifndef FIFTYONEDEGREES_DUMMY_LIB
771 REGISTER_BUILD_OPTS("Built with 51Degrees Pattern support.");
772#else
773 REGISTER_BUILD_OPTS("Built with 51Degrees Pattern support (dummy library).");
774#endif
775#elif defined(FIFTYONEDEGREES_H_TRIE_INCLUDED)
776#ifndef FIFTYONEDEGREES_DUMMY_LIB
777 REGISTER_BUILD_OPTS("Built with 51Degrees Trie support.");
778#else
779 REGISTER_BUILD_OPTS("Built with 51Degrees Trie support (dummy library).");
780#endif
Christopher Faulet6d1dd462019-07-15 14:36:03 +0200781#endif