mirror/nginx
1
0
Fork 0
mirror of https://github.com/nginx/nginx.git synced 2024-12-05 06:19:01 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Keepalive support in memcached.

Browse Source
This commit is contained in:
Maxim Dounin 2011-09-15 19:04:25 +00:00
parent 2d6be3fe93
commit 05552a23a2
1 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/http/modules/ngx_http_memcached_module.c
View File

@ -366,6 +366,7 @@ found:
u->headers_in.status_n = 404; u->headers_in.status_n = 404;
u->state->status = 404; u->state->status = 404;
u->keepalive = 1;
return NGX_OK; return NGX_OK;
} }
@ -426,6 +427,10 @@ ngx_http_memcached_filter(void *data, ssize_t bytes)
u->length -= bytes; u->length -= bytes;
ctx->rest -= bytes; ctx->rest -= bytes;
if (u->length == 0) {
u->keepalive = 1;
}
return NGX_OK; return NGX_OK;
} }
@ -463,6 +468,13 @@ ngx_http_memcached_filter(void *data, ssize_t bytes)
if (ngx_strncmp(last, ngx_http_memcached_end, b->last - last) != 0) { if (ngx_strncmp(last, ngx_http_memcached_end, b->last - last) != 0) {
ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0, ngx_log_error(NGX_LOG_ERR, ctx->request->connection->log, 0,
"memcached sent invalid trailer"); "memcached sent invalid trailer");
b->last = last;
cl->buf->last = last;
u->length = 0;
ctx->rest = 0;
return NGX_OK;
} }
ctx->rest -= b->last - last; ctx->rest -= b->last - last;
@ -470,6 +482,10 @@ ngx_http_memcached_filter(void *data, ssize_t bytes)
cl->buf->last = last; cl->buf->last = last;
u->length = ctx->rest; u->length = ctx->rest;
if (u->length == 0) {
u->keepalive = 1;
}
return NGX_OK; return NGX_OK;
} }