details: http://hg.nginx.org/nginx/rev/954867a2f0a6
branches:
changeset: 5812:954867a2f0a6
user: Ruslan Ermilov <ru@nginx.com>
date: Tue Aug 19 15:43:26 2014 +0400
description:
Resolver: notify all waiting requests on timeout.

If a "resolver_timeout" occurs, only the first waiting request
was notified. Other requests may hang forever.

diffstat:

src/core/ngx_resolver.c | 30 +++++++++++++++++++-----------
1 files changed, 19 insertions(+), 11 deletions(-)

diffs (68 lines):

diff -r f5b612019042 -r 954867a2f0a6 src/core/ngx_resolver.c
--- a/src/core/ngx_resolver.c Tue Aug 26 17:35:23 2014 +0400
+++ b/src/core/ngx_resolver.c Tue Aug 19 15:43:26 2014 +0400
@@ -417,7 +417,7 @@ ngx_resolve_name_done(ngx_resolver_ctx_t

/* lock name mutex */

- if (ctx->state == NGX_AGAIN || ctx->state == NGX_RESOLVE_TIMEDOUT) {
+ if (ctx->state == NGX_AGAIN) {

hash = ngx_crc32_short(ctx->name.data, ctx->name.len);

@@ -664,7 +664,7 @@ ngx_resolve_name_locked(ngx_resolver_t *
}

ctx->event->handler = ngx_resolver_timeout_handler;
- ctx->event->data = ctx;
+ ctx->event->data = rn;
ctx->event->log = r->log;
ctx->ident = -1;

@@ -857,7 +857,7 @@ ngx_resolve_addr(ngx_resolver_ctx_t *ctx
}

ctx->event->handler = ngx_resolver_timeout_handler;
- ctx->event->data = ctx;
+ ctx->event->data = rn;
ctx->event->log = r->log;
ctx->ident = -1;

@@ -949,7 +949,7 @@ ngx_resolve_addr_done(ngx_resolver_ctx_t

/* lock addr mutex */

- if (ctx->state == NGX_AGAIN || ctx->state == NGX_RESOLVE_TIMEDOUT) {
+ if (ctx->state == NGX_AGAIN) {

switch (ctx->addr.sockaddr->sa_family) {

@@ -2790,13 +2790,21 @@ done:
static void
ngx_resolver_timeout_handler(ngx_event_t *ev)
{
- ngx_resolver_ctx_t *ctx;
-
- ctx = ev->data;
-
- ctx->state = NGX_RESOLVE_TIMEDOUT;
-
- ctx->handler(ctx);
+ ngx_resolver_ctx_t *ctx, *next;
+ ngx_resolver_node_t *rn;
+
+ rn = ev->data;
+ ctx = rn->waiting;
+ rn->waiting = NULL;
+
+ do {
+ ctx->state = NGX_RESOLVE_TIMEDOUT;
+ next = ctx->next;
+
+ ctx->handler(ctx);
+
+ ctx = next;
+ } while (ctx);
}



_______________________________________________
nginx-devel mailing list
nginx-devel@nginx.org
http://mailman.nginx.org/mailman/listinfo/nginx-devel