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