aboutsummaryrefslogtreecommitdiff
path: root/src/http/ngx_http_request.c
diff options
context:
space:
mode:
authorIgor Sysoev <igor@sysoev.ru>2003-11-18 16:49:00 +0000
committerIgor Sysoev <igor@sysoev.ru>2003-11-18 16:49:00 +0000
commit222a2adf40eb25ff613c251f15032f1e39d7f609 (patch)
tree703e825cbfacdac4e1fdc73889371755bf5f68bb /src/http/ngx_http_request.c
parent0b2b4ccd2c8a31caea0ef760b55a63c2fc169838 (diff)
downloadnginx-222a2adf40eb25ff613c251f15032f1e39d7f609.tar.gz
nginx-222a2adf40eb25ff613c251f15032f1e39d7f609.zip
nginx-0.0.1-2003-11-18-19:49:00 import
Diffstat (limited to 'src/http/ngx_http_request.c')
-rw-r--r--src/http/ngx_http_request.c7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/http/ngx_http_request.c b/src/http/ngx_http_request.c
index 9dd040e43..a59b12aa1 100644
--- a/src/http/ngx_http_request.c
+++ b/src/http/ngx_http_request.c
@@ -664,6 +664,10 @@ static ssize_t ngx_http_read_request_header(ngx_http_request_t *r)
return n;
}
+ if (!rev->ready) {
+ return NGX_AGAIN;
+ }
+
n = ngx_recv(r->connection, r->header_in->last,
r->header_in->end - r->header_in->last);
@@ -853,7 +857,8 @@ static void ngx_http_set_write_handler(ngx_http_request_t *r)
ngx_http_core_module);
ngx_add_timer(wev, clcf->send_timeout);
- if (ngx_handle_write_event(wev, clcf->send_lowat) == NGX_ERROR) {
+ wev->available = clcf->send_lowat;
+ if (ngx_handle_write_event(wev, NGX_LOWAT_EVENT) == NGX_ERROR) {
ngx_http_close_request(r, 0);
ngx_http_close_connection(r->connection);
}