aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2003-10-17 16:53:26 +0000
committerIgor Sysoev <igor@sysoev.ru>2003-10-17 16:53:26 +0000
commit091f7d6e83b2ee38b44b15ff583f76e705baa43d (patch)
tree7e07f5d44cb800c953ae62befa7f8a5a798d4f38
parentd404c9716322cfe8778e7494e55efb924f35ecaa (diff)
downloadnginx-091f7d6e83b2ee38b44b15ff583f76e705baa43d.tar.gz
nginx-091f7d6e83b2ee38b44b15ff583f76e705baa43d.zip
nginx-0.0.1-2003-10-17-20:53:26 import
-rw-r--r--src/event/ngx_event_proxy.c4
-rw-r--r--src/http/ngx_http_request.c3
2 files changed, 6 insertions, 1 deletions
diff --git a/src/event/ngx_event_proxy.c b/src/event/ngx_event_proxy.c
index c6bd8a373..a683be3c9 100644
--- a/src/event/ngx_event_proxy.c
+++ b/src/event/ngx_event_proxy.c
@@ -246,7 +246,9 @@ int ngx_event_proxy_write_to_downstream(ngx_event_proxy_t *p)
} else if (!p->cachable && p->in) {
out = p->in;
- if (p->busy_len + ngx_hunk_size(out->hunk) > p->max_busy_len) {
+ if (!(p->upstream_eof || p->upstream_error || p->upstream_done)
+ && (p->busy_len + ngx_hunk_size(out->hunk) > p->max_busy_len))
+ {
break;
}
diff --git a/src/http/ngx_http_request.c b/src/http/ngx_http_request.c
index 71b1c21cf..f972402b7 100644
--- a/src/http/ngx_http_request.c
+++ b/src/http/ngx_http_request.c
@@ -721,7 +721,10 @@ static ssize_t ngx_http_read_request_header(ngx_http_request_t *r)
n = r->header_in->last - r->header_in->pos;
if (n > 0) {
+#if 0
+ /* TODO: THINK - AIO ??? */
rev->ready = 0;
+#endif
return n;
}