aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMaxim Dounin <mdounin@mdounin.ru>2013-07-25 15:00:41 +0400
committerMaxim Dounin <mdounin@mdounin.ru>2013-07-25 15:00:41 +0400
commit5274f023a243e4163bcdb1b93e00445e769a8ff9 (patch)
treeeba84a5bcf52540362682265f9198ebc6a4962b3 /src
parent78aacc838bac5c92fe92f8533526515766cfce15 (diff)
downloadnginx-5274f023a243e4163bcdb1b93e00445e769a8ff9.tar.gz
nginx-5274f023a243e4163bcdb1b93e00445e769a8ff9.zip
Upstream: no last buffer on errors.
Previously, after sending a header we always sent a last buffer and finalized a request with code 0, even in case of errors. In some cases this resulted in a loss of ability to detect the response wasn't complete (e.g. if Content-Length was removed from a response by gzip filter). This change tries to propogate to a client information that a response isn't complete in such cases. In particular, with this change we no longer pretend a returned response is complete if we wasn't able to create a temporary file. If an error code suggests the error wasn't fatal, we flush buffered data and disable keepalive, then finalize request normally. This allows to to propogate information about a problem to a client, while still sending all the data we've got from an upstream.
Diffstat (limited to 'src')
-rw-r--r--src/http/ngx_http_upstream.c12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/http/ngx_http_upstream.c b/src/http/ngx_http_upstream.c
index 1f6000ea4..cd946340a 100644
--- a/src/http/ngx_http_upstream.c
+++ b/src/http/ngx_http_upstream.c
@@ -3297,6 +3297,7 @@ static void
ngx_http_upstream_finalize_request(ngx_http_request_t *r,
ngx_http_upstream_t *u, ngx_int_t rc)
{
+ ngx_uint_t flush;
ngx_time_t *tp;
ngx_log_debug1(NGX_LOG_DEBUG_HTTP, r->connection->log, 0,
@@ -3417,8 +3418,11 @@ ngx_http_upstream_finalize_request(ngx_http_request_t *r,
return;
}
- if (rc == NGX_ERROR || rc >= NGX_HTTP_SPECIAL_RESPONSE) {
- rc = 0;
+ flush = 0;
+
+ if (rc >= NGX_HTTP_SPECIAL_RESPONSE) {
+ rc = NGX_ERROR;
+ flush = 1;
}
if (r->header_only) {
@@ -3428,6 +3432,10 @@ ngx_http_upstream_finalize_request(ngx_http_request_t *r,
if (rc == 0) {
rc = ngx_http_send_special(r, NGX_HTTP_LAST);
+
+ } else if (flush) {
+ r->keepalive = 0;
+ rc = ngx_http_send_special(r, NGX_HTTP_FLUSH);
}
ngx_http_finalize_request(r, rc);