source: nginx/src/http/modules/ngx_http_memcached_module.c

tip
Last change on this file was 5832:d09b689911ac, checked in by Roman Arutyunyan <arut@…>, 7 weeks ago

Upstream: limited next_upstream time and tries (ticket #544).

The new directives {proxy,fastcgi,scgi,uwsgi,memcached}_next_upstream_tries
and {proxy,fastcgi,scgi,uwsgi,memcached}_next_upstream_timeout limit
the number of upstreams tried and the maximum time spent for these tries
when searching for a valid upstream.

File size: 20.2 KB
Line 
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) Nginx, Inc.
5 */
6
7
8#include <ngx_config.h>
9#include <ngx_core.h>
10#include <ngx_http.h>
11
12
13typedef struct {
14    ngx_http_upstream_conf_t   upstream;
15    ngx_int_t                  index;
16    ngx_uint_t                 gzip_flag;
17} ngx_http_memcached_loc_conf_t;
18
19
20typedef struct {
21    size_t                     rest;
22    ngx_http_request_t        *request;
23    ngx_str_t                  key;
24} ngx_http_memcached_ctx_t;
25
26
27static ngx_int_t ngx_http_memcached_create_request(ngx_http_request_t *r);
28static ngx_int_t ngx_http_memcached_reinit_request(ngx_http_request_t *r);
29static ngx_int_t ngx_http_memcached_process_header(ngx_http_request_t *r);
30static ngx_int_t ngx_http_memcached_filter_init(void *data);
31static ngx_int_t ngx_http_memcached_filter(void *data, ssize_t bytes);
32static void ngx_http_memcached_abort_request(ngx_http_request_t *r);
33static void ngx_http_memcached_finalize_request(ngx_http_request_t *r,
34    ngx_int_t rc);
35
36static void *ngx_http_memcached_create_loc_conf(ngx_conf_t *cf);
37static char *ngx_http_memcached_merge_loc_conf(ngx_conf_t *cf,
38    void *parent, void *child);
39
40static char *ngx_http_memcached_pass(ngx_conf_t *cf, ngx_command_t *cmd,
41    void *conf);
42
43
44static ngx_conf_bitmask_t  ngx_http_memcached_next_upstream_masks[] = {
45    { ngx_string("error"), NGX_HTTP_UPSTREAM_FT_ERROR },
46    { ngx_string("timeout"), NGX_HTTP_UPSTREAM_FT_TIMEOUT },
47    { ngx_string("invalid_response"), NGX_HTTP_UPSTREAM_FT_INVALID_HEADER },
48    { ngx_string("not_found"), NGX_HTTP_UPSTREAM_FT_HTTP_404 },
49    { ngx_string("off"), NGX_HTTP_UPSTREAM_FT_OFF },
50    { ngx_null_string, 0 }
51};
52
53
54static ngx_command_t  ngx_http_memcached_commands[] = {
55
56    { ngx_string("memcached_pass"),
57      NGX_HTTP_LOC_CONF|NGX_HTTP_LIF_CONF|NGX_CONF_TAKE1,
58      ngx_http_memcached_pass,
59      NGX_HTTP_LOC_CONF_OFFSET,
60      0,
61      NULL },
62
63    { ngx_string("memcached_bind"),
64      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
65      ngx_http_upstream_bind_set_slot,
66      NGX_HTTP_LOC_CONF_OFFSET,
67      offsetof(ngx_http_memcached_loc_conf_t, upstream.local),
68      NULL },
69
70    { ngx_string("memcached_connect_timeout"),
71      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
72      ngx_conf_set_msec_slot,
73      NGX_HTTP_LOC_CONF_OFFSET,
74      offsetof(ngx_http_memcached_loc_conf_t, upstream.connect_timeout),
75      NULL },
76
77    { ngx_string("memcached_send_timeout"),
78      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
79      ngx_conf_set_msec_slot,
80      NGX_HTTP_LOC_CONF_OFFSET,
81      offsetof(ngx_http_memcached_loc_conf_t, upstream.send_timeout),
82      NULL },
83
84    { ngx_string("memcached_buffer_size"),
85      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
86      ngx_conf_set_size_slot,
87      NGX_HTTP_LOC_CONF_OFFSET,
88      offsetof(ngx_http_memcached_loc_conf_t, upstream.buffer_size),
89      NULL },
90
91    { ngx_string("memcached_read_timeout"),
92      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
93      ngx_conf_set_msec_slot,
94      NGX_HTTP_LOC_CONF_OFFSET,
95      offsetof(ngx_http_memcached_loc_conf_t, upstream.read_timeout),
96      NULL },
97
98    { ngx_string("memcached_next_upstream"),
99      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_1MORE,
100      ngx_conf_set_bitmask_slot,
101      NGX_HTTP_LOC_CONF_OFFSET,
102      offsetof(ngx_http_memcached_loc_conf_t, upstream.next_upstream),
103      &ngx_http_memcached_next_upstream_masks },
104
105    { ngx_string("memcached_next_upstream_tries"),
106      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
107      ngx_conf_set_num_slot,
108      NGX_HTTP_LOC_CONF_OFFSET,
109      offsetof(ngx_http_memcached_loc_conf_t, upstream.next_upstream_tries),
110      NULL },
111
112    { ngx_string("memcached_next_upstream_timeout"),
113      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
114      ngx_conf_set_msec_slot,
115      NGX_HTTP_LOC_CONF_OFFSET,
116      offsetof(ngx_http_memcached_loc_conf_t, upstream.next_upstream_timeout),
117      NULL },
118
119    { ngx_string("memcached_gzip_flag"),
120      NGX_HTTP_MAIN_CONF|NGX_HTTP_SRV_CONF|NGX_HTTP_LOC_CONF|NGX_CONF_TAKE1,
121      ngx_conf_set_num_slot,
122      NGX_HTTP_LOC_CONF_OFFSET,
123      offsetof(ngx_http_memcached_loc_conf_t, gzip_flag),
124      NULL },
125
126      ngx_null_command
127};
128
129
130static ngx_http_module_t  ngx_http_memcached_module_ctx = {
131    NULL,                                  /* preconfiguration */
132    NULL,                                  /* postconfiguration */
133
134    NULL,                                  /* create main configuration */
135    NULL,                                  /* init main configuration */
136
137    NULL,                                  /* create server configuration */
138    NULL,                                  /* merge server configuration */
139
140    ngx_http_memcached_create_loc_conf,    /* create location configuration */
141    ngx_http_memcached_merge_loc_conf      /* merge location configuration */
142};
143
144
145ngx_module_t  ngx_http_memcached_module = {
146    NGX_MODULE_V1,
147    &ngx_http_memcached_module_ctx,        /* module context */
148    ngx_http_memcached_commands,           /* module directives */
149    NGX_HTTP_MODULE,                       /* module type */
150    NULL,                                  /* init master */
151    NULL,                                  /* init module */
152    NULL,                                  /* init process */
153    NULL,                                  /* init thread */
154    NULL,                                  /* exit thread */
155    NULL,                                  /* exit process */
156    NULL,                                  /* exit master */
157    NGX_MODULE_V1_PADDING
158};
159
160
161static ngx_str_t  ngx_http_memcached_key = ngx_string("memcached_key");
162
163
164#define NGX_HTTP_MEMCACHED_END   (sizeof(ngx_http_memcached_end) - 1)
165static u_char  ngx_http_memcached_end[] = CRLF "END" CRLF;
166
167
168static ngx_int_t
169ngx_http_memcached_handler(ngx_http_request_t *r)
170{
171    ngx_int_t                       rc;
172    ngx_http_upstream_t            *u;
173    ngx_http_memcached_ctx_t       *ctx;
174    ngx_http_memcached_loc_conf_t  *mlcf;
175
176    if (!(r->method & (NGX_HTTP_GET|NGX_HTTP_HEAD))) {
177        return NGX_HTTP_NOT_ALLOWED;
178    }
179
180    rc = ngx_http_discard_request_body(r);
181
182    if (rc != NGX_OK) {
183        return rc;
184    }
185
186    if (ngx_http_set_content_type(r) != NGX_OK) {
187        return NGX_HTTP_INTERNAL_SERVER_ERROR;
188    }
189
190    if (ngx_http_upstream_create(r) != NGX_OK) {
191        return NGX_HTTP_INTERNAL_SERVER_ERROR;
192    }
193
194    u = r->upstream;
195
196    ngx_str_set(&u->schema, "memcached://");
197    u->output.tag = (ngx_buf_tag_t) &ngx_http_memcached_module;
198
199    mlcf = ngx_http_get_module_loc_conf(r, ngx_http_memcached_module);
200
201    u->conf = &mlcf->upstream;
202
203    u->create_request = ngx_http_memcached_create_request;
204    u->reinit_request = ngx_http_memcached_reinit_request;
205    u->process_header = ngx_http_memcached_process_header;
206    u->abort_request = ngx_http_memcached_abort_request;
207    u->finalize_request = ngx_http_memcached_finalize_request;
208
209    ctx = ngx_palloc(r->pool, sizeof(ngx_http_memcached_ctx_t));
210    if (ctx == NULL) {
211        return NGX_HTTP_INTERNAL_SERVER_ERROR;
212    }
213
214    ctx->request = r;
215
216    ngx_http_set_ctx(r, ctx, ngx_http_memcached_module);
217
218    u->input_filter_init = ngx_http_memcached_filter_init;
219    u->input_filter = ngx_http_memcached_filter;
220    u->input_filter_ctx = ctx;
221
222    r->main->count++;
223
224    ngx_http_upstream_init(r);
225
226    return NGX_DONE;
227}
228
229
230static ngx_int_t
231ngx_http_memcached_create_request(ngx_http_request_t *r)
232{
233    size_t                          len;
234    uintptr_t                       escape;
235    ngx_buf_t                      *b;
236    ngx_chain_t                    *cl;
237    ngx_http_memcached_ctx_t       *ctx;
238    ngx_http_variable_value_t      *vv;
239    ngx_http_memcached_loc_conf_t  *mlcf;
240
241    mlcf = ngx_http_get_module_loc_conf(r, ngx_http_memcached_module);
242
243    vv = ngx_http_get_indexed_variable(r, mlcf->index);
244
245    if (vv == NULL || vv->not_found || vv->len == 0) {
246        ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
247                      "the \"$memcached_key\" variable is not set");
248        return NGX_ERROR;
249    }
250
251    escape = 2 * ngx_escape_uri(NULL, vv->data, vv->len, NGX_ESCAPE_MEMCACHED);
252
253    len = sizeof("get ") - 1 + vv->len + escape + sizeof(CRLF) - 1;
254
255    b = ngx_create_temp_buf(r->pool, len);
256    if (b == NULL) {
257        return NGX_ERROR;
258    }
259
260    cl = ngx_alloc_chain_link(r->pool);
261    if (cl == NULL) {
262        return NGX_ERROR;
263    }
264
265    cl->buf = b;
266    cl->next = NULL;
267
268    r->upstream->request_bufs = cl;
269
270    *b->last++ = 'g'; *b->last++ = 'e'; *b->last++ = 't'; *b->last++ = ' ';
271
272    ctx = ngx_http_get_module_ctx(r, ngx_http_memcached_module);
273
274    ctx->key.data = b->last;
275
276    if (escape == 0) {
277        b->last = ngx_copy(b->last, vv->data, vv->len);
278
279    } else {
280        b->last = (u_char *) ngx_escape_uri(b->last, vv->data, vv->len,
281                                            NGX_ESCAPE_MEMCACHED);
282    }
283
284    ctx->key.len = b->last - ctx->key.data;
285
286    ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
287                   "http memcached request: \"%V\"", &ctx->key);
288
289    *b->last++ = CR; *b->last++ = LF;
290
291    return NGX_OK;
292}
293
294
295static ngx_int_t
296ngx_http_memcached_reinit_request(ngx_http_request_t *r)
297{
298    return NGX_OK;
299}
300
301
302static ngx_int_t
303ngx_http_memcached_process_header(ngx_http_request_t *r)
304{
305    u_char                         *p, *start;
306    ngx_str_t                       line;
307    ngx_uint_t                      flags;
308    ngx_table_elt_t                *h;
309    ngx_http_upstream_t            *u;
310    ngx_http_memcached_ctx_t       *ctx;
311    ngx_http_memcached_loc_conf_t  *mlcf;
312
313    u = r->upstream;
314
315    for (p = u->buffer.pos; p < u->buffer.last; p++) {
316        if (*p == LF) {
317            goto found;
318        }
319    }
320
321    return NGX_AGAIN;
322
323found:
324
325    line.data = u->buffer.pos;
326    line.len = p - u->buffer.pos;
327
328    if (line.len == 0 || *(p - 1) != CR) {
329        goto no_valid;
330    }
331
332    *p = '\0';
333    line.len--;
334
335    ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
336                   "memcached: \"%V\"", &line);
337
338    p = u->buffer.pos;
339
340    ctx = ngx_http_get_module_ctx(r, ngx_http_memcached_module);
341    mlcf = ngx_http_get_module_loc_conf(r, ngx_http_memcached_module);
342
343    if (ngx_strncmp(p, "VALUE ", sizeof("VALUE ") - 1) == 0) {
344
345        p += sizeof("VALUE ") - 1;
346
347        if (ngx_strncmp(p, ctx->key.data, ctx->key.len) != 0) {
348            ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
349                          "memcached sent invalid key in response \"%V\" "
350                          "for key \"%V\"",
351                          &line, &ctx->key);
352
353            return NGX_HTTP_UPSTREAM_INVALID_HEADER;
354        }
355
356        p += ctx->key.len;
357
358        if (*p++ != ' ') {
359            goto no_valid;
360        }
361
362        /* flags */
363
364        start = p;
365
366        while (*p) {
367            if (*p++ == ' ') {
368                if (mlcf->gzip_flag) {
369                    goto flags;
370                } else {
371                    goto length;
372                }
373            }
374        }
375
376        goto no_valid;
377
378    flags:
379
380        flags = ngx_atoi(start, p - start - 1);
381
382        if (flags == (ngx_uint_t) NGX_ERROR) {
383            ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
384                          "memcached sent invalid flags in response \"%V\" "
385                          "for key \"%V\"",
386                          &line, &ctx->key);
387            return NGX_HTTP_UPSTREAM_INVALID_HEADER;
388        }
389
390        if (flags & mlcf->gzip_flag) {
391            h = ngx_list_push(&r->headers_out.headers);
392            if (h == NULL) {
393                return NGX_ERROR;
394            }
395
396            h->hash = 1;
397            ngx_str_set(&h->key, "Content-Encoding");
398            ngx_str_set(&h->value, "gzip");
399            r->headers_out.content_encoding = h;
400        }
401
402    length:
403
404        start = p;
405        p = line.data + line.len;
406
407        u->headers_in.content_length_n = ngx_atoof(start, p - start);
408        if (u->headers_in.content_length_n == NGX_ERROR) {
409            ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
410                          "memcached sent invalid length in response \"%V\" "
411                          "for key \"%V\"",
412                          &line, &ctx->key);
413            return NGX_HTTP_UPSTREAM_INVALID_HEADER;
414        }
415
416        u->headers_in.status_n = 200;
417        u->state->status = 200;
418        u->buffer.pos = p + sizeof(CRLF) - 1;
419
420        return NGX_OK;
421    }
422
423    if (ngx_strcmp(p, "END\x0d") == 0) {
424        ngx_log_error(NGX_LOG_INFO, r->connection->log, 0,
425                      "key: \"%V\" was not found by memcached", &ctx->key);
426
427        u->headers_in.content_length_n = 0;
428        u->headers_in.status_n = 404;
429        u->state->status = 404;
430        u->buffer.pos = p + sizeof("END" CRLF) - 1;
431        u->keepalive = 1;
432
433        return NGX_OK;
434    }
435
436no_valid:
437
438    ngx_log_error(NGX_LOG_ERR, r->connection->log, 0,
439                  "memcached sent invalid response: \"%V\"", &line);
440
441    return NGX_HTTP_UPSTREAM_INVALID_HEADER;
442}
443
444
445static ngx_int_t
446ngx_http_memcached_filter_init(void *data)
447{
448    ngx_http_memcached_ctx_t  *ctx = data;
449
450    ngx_http_upstream_t  *u;
451
452    u = ctx->request->upstream;
453
454    if (u->headers_in.status_n != 404) {
455        u->length = u->headers_in.content_length_n + NGX_HTTP_MEMCACHED_END;
456        ctx->rest = NGX_HTTP_MEMCACHED_END;
457
458    } else {
459        u->length = 0;
460    }
461
462    return NGX_OK;
463}
464
465
466static ngx_int_t
467ngx_http_memcached_filter(void *data, ssize_t bytes)
468{
469    ngx_http_memcached_ctx_t  *ctx = data;
470
471    u_char               *last;
472    ngx_buf_t            *b;
473    ngx_chain_t          *cl, **ll;
474    ngx_http_upstream_t  *u;
475
476    u = ctx->request->upstream;
477    b = &u->buffer;
478
479    if (u->length == (ssize_t) ctx->rest) {
480
481        if (ngx_strncmp(b->last,
482                   ngx_http_memcached_end + NGX_HTTP_MEMCACHED_END - ctx->rest,
483                   bytes)
484            != 0)
485        {
486            ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0,
487                          "memcached sent invalid trailer");
488
489            u->length = 0;
490            ctx->rest = 0;
491
492            return NGX_OK;
493        }
494
495        u->length -= bytes;
496        ctx->rest -= bytes;
497
498        if (u->length == 0) {
499            u->keepalive = 1;
500        }
501
502        return NGX_OK;
503    }
504
505    for (cl = u->out_bufs, ll = &u->out_bufs; cl; cl = cl->next) {
506        ll = &cl->next;
507    }
508
509    cl = ngx_chain_get_free_buf(ctx->request->pool, &u->free_bufs);
510    if (cl == NULL) {
511        return NGX_ERROR;
512    }
513
514    cl->buf->flush = 1;
515    cl->buf->memory = 1;
516
517    *ll = cl;
518
519    last = b->last;
520    cl->buf->pos = last;
521    b->last += bytes;
522    cl->buf->last = b->last;
523    cl->buf->tag = u->output.tag;
524
525    ngx_log_debug4(NGX_LOG_DEBUG_HTTP, ctx->request->connection->log, 0,
526                   "memcached filter bytes:%z size:%z length:%z rest:%z",
527                   bytes, b->last - b->pos, u->length, ctx->rest);
528
529    if (bytes <= (ssize_t) (u->length - NGX_HTTP_MEMCACHED_END)) {
530        u->length -= bytes;
531        return NGX_OK;
532    }
533
534    last += (size_t) (u->length - NGX_HTTP_MEMCACHED_END);
535
536    if (ngx_strncmp(last, ngx_http_memcached_end, b->last - last) != 0) {
537        ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0,
538                      "memcached sent invalid trailer");
539
540        b->last = last;
541        cl->buf->last = last;
542        u->length = 0;
543        ctx->rest = 0;
544
545        return NGX_OK;
546    }
547
548    ctx->rest -= b->last - last;
549    b->last = last;
550    cl->buf->last = last;
551    u->length = ctx->rest;
552
553    if (u->length == 0) {
554        u->keepalive = 1;
555    }
556
557    return NGX_OK;
558}
559
560
561static void
562ngx_http_memcached_abort_request(ngx_http_request_t *r)
563{
564    ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
565                   "abort http memcached request");
566    return;
567}
568
569
570static void
571ngx_http_memcached_finalize_request(ngx_http_request_t *r, ngx_int_t rc)
572{
573    ngx_log_debug0(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
574                   "finalize http memcached request");
575    return;
576}
577
578
579static void *
580ngx_http_memcached_create_loc_conf(ngx_conf_t *cf)
581{
582    ngx_http_memcached_loc_conf_t  *conf;
583
584    conf = ngx_pcalloc(cf->pool, sizeof(ngx_http_memcached_loc_conf_t));
585    if (conf == NULL) {
586        return NULL;
587    }
588
589    /*
590     * set by ngx_pcalloc():
591     *
592     *     conf->upstream.bufs.num = 0;
593     *     conf->upstream.next_upstream = 0;
594     *     conf->upstream.temp_path = NULL;
595     *     conf->upstream.uri = { 0, NULL };
596     *     conf->upstream.location = NULL;
597     */
598
599    conf->upstream.local = NGX_CONF_UNSET_PTR;
600    conf->upstream.next_upstream_tries = NGX_CONF_UNSET_UINT;
601    conf->upstream.connect_timeout = NGX_CONF_UNSET_MSEC;
602    conf->upstream.send_timeout = NGX_CONF_UNSET_MSEC;
603    conf->upstream.read_timeout = NGX_CONF_UNSET_MSEC;
604    conf->upstream.next_upstream_timeout = NGX_CONF_UNSET_MSEC;
605
606    conf->upstream.buffer_size = NGX_CONF_UNSET_SIZE;
607
608    /* the hardcoded values */
609    conf->upstream.cyclic_temp_file = 0;
610    conf->upstream.buffering = 0;
611    conf->upstream.ignore_client_abort = 0;
612    conf->upstream.send_lowat = 0;
613    conf->upstream.bufs.num = 0;
614    conf->upstream.busy_buffers_size = 0;
615    conf->upstream.max_temp_file_size = 0;
616    conf->upstream.temp_file_write_size = 0;
617    conf->upstream.intercept_errors = 1;
618    conf->upstream.intercept_404 = 1;
619    conf->upstream.pass_request_headers = 0;
620    conf->upstream.pass_request_body = 0;
621
622    conf->index = NGX_CONF_UNSET;
623    conf->gzip_flag = NGX_CONF_UNSET_UINT;
624
625    return conf;
626}
627
628
629static char *
630ngx_http_memcached_merge_loc_conf(ngx_conf_t *cf, void *parent, void *child)
631{
632    ngx_http_memcached_loc_conf_t *prev = parent;
633    ngx_http_memcached_loc_conf_t *conf = child;
634
635    ngx_conf_merge_ptr_value(conf->upstream.local,
636                              prev->upstream.local, NULL);
637
638    ngx_conf_merge_uint_value(conf->upstream.next_upstream_tries,
639                              prev->upstream.next_upstream_tries, 0);
640
641    ngx_conf_merge_msec_value(conf->upstream.connect_timeout,
642                              prev->upstream.connect_timeout, 60000);
643
644    ngx_conf_merge_msec_value(conf->upstream.send_timeout,
645                              prev->upstream.send_timeout, 60000);
646
647    ngx_conf_merge_msec_value(conf->upstream.read_timeout,
648                              prev->upstream.read_timeout, 60000);
649
650    ngx_conf_merge_msec_value(conf->upstream.next_upstream_timeout,
651                              prev->upstream.next_upstream_timeout, 0);
652
653    ngx_conf_merge_size_value(conf->upstream.buffer_size,
654                              prev->upstream.buffer_size,
655                              (size_t) ngx_pagesize);
656
657    ngx_conf_merge_bitmask_value(conf->upstream.next_upstream,
658                              prev->upstream.next_upstream,
659                              (NGX_CONF_BITMASK_SET
660                               |NGX_HTTP_UPSTREAM_FT_ERROR
661                               |NGX_HTTP_UPSTREAM_FT_TIMEOUT));
662
663    if (conf->upstream.next_upstream & NGX_HTTP_UPSTREAM_FT_OFF) {
664        conf->upstream.next_upstream = NGX_CONF_BITMASK_SET
665                                       |NGX_HTTP_UPSTREAM_FT_OFF;
666    }
667
668    if (conf->upstream.upstream == NULL) {
669        conf->upstream.upstream = prev->upstream.upstream;
670    }
671
672    if (conf->index == NGX_CONF_UNSET) {
673        conf->index = prev->index;
674    }
675
676    ngx_conf_merge_uint_value(conf->gzip_flag, prev->gzip_flag, 0);
677
678    return NGX_CONF_OK;
679}
680
681
682static char *
683ngx_http_memcached_pass(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
684{
685    ngx_http_memcached_loc_conf_t *mlcf = conf;
686
687    ngx_str_t                 *value;
688    ngx_url_t                  u;
689    ngx_http_core_loc_conf_t  *clcf;
690
691    if (mlcf->upstream.upstream) {
692        return "is duplicate";
693    }
694
695    value = cf->args->elts;
696
697    ngx_memzero(&u, sizeof(ngx_url_t));
698
699    u.url = value[1];
700    u.no_resolve = 1;
701
702    mlcf->upstream.upstream = ngx_http_upstream_add(cf, &u, 0);
703    if (mlcf->upstream.upstream == NULL) {
704        return NGX_CONF_ERROR;
705    }
706
707    clcf = ngx_http_conf_get_module_loc_conf(cf, ngx_http_core_module);
708
709    clcf->handler = ngx_http_memcached_handler;
710
711    if (clcf->name.data[clcf->name.len - 1] == '/') {
712        clcf->auto_redirect = 1;
713    }
714
715    mlcf->index = ngx_http_get_variable_index(cf, &ngx_http_memcached_key);
716
717    if (mlcf->index == NGX_ERROR) {
718        return NGX_CONF_ERROR;
719    }
720
721    return NGX_CONF_OK;
722}
Note: See TracBrowser for help on using the repository browser.