1 files changed, 19 insertions, 9 deletions
diff --git a/src/http/ngx_http_special_response.c b/src/http/ngx_http_special_response.c
index 4e5e3b251..0e7ccbad5 100644
--- a/src/http/ngx_http_special_response.c
+++ b/src/http/ngx_http_special_response.c
@@ -5,6 +5,8 @@
 #include <ngx_core.h>
 #include <ngx_string.h>
 #include <ngx_http.h>
+#include <ngx_http_output_filter.h>
+
 
 static char error_tail[] =
 "<hr><center>" NGINX_VER "</center>" CRLF
@@ -12,6 +14,7 @@ static char error_tail[] =
 "</html>" CRLF
 ;
 
+
 static char error_400_page[] =
 "<html>" CRLF
 "<head><title>400 Bad Request</title></head>" CRLF
@@ -19,6 +22,7 @@ static char error_400_page[] =
 "<center><h1>400 Bad Request</h1></center>" CRLF
 ;
 
+
 static char error_403_page[] =
 "<html>" CRLF
 "<head><title>403 Forbidden</title></head>" CRLF
@@ -26,6 +30,7 @@ static char error_403_page[] =
 "<center><h1>403 Forbidden</h1></center>" CRLF
 ;
 
+
 static char error_404_page[] =
 "<html>" CRLF
 "<head><title>404 Not Found</title></head>" CRLF
@@ -33,6 +38,7 @@ static char error_404_page[] =
 "<center><h1>404 Not Found</h1></center>" CRLF
 ;
 
+
 static char error_500_page[] =
 "<html>" CRLF
 "<head><title>500 Internal Server Error</title></head>" CRLF
@@ -56,9 +62,10 @@ static ngx_str_t error_pages[] = {
     { sizeof(error_500_page) - 1, error_500_page }
 };
 
+
 int ngx_http_special_response(ngx_http_request_t *r, int error)
 {
-    int  rc, err, len;
+    int          err, len;
     ngx_hunk_t  *message, *tail;
 
     len = 0;
@@ -80,26 +87,29 @@ int ngx_http_special_response(ngx_http_request_t *r, int error)
         r->headers_out.content_length = error_pages[err].len
                                         + len + sizeof(error_tail);
 
-    ngx_http_send_header(r);
+    if (ngx_http_send_header(r) == NGX_ERROR) {
+        return NGX_ERROR;
+    }
 
-    if (error_pages[err].len == 0)
+    if (error_pages[err].len == 0) {
         return NGX_OK;
+    }
 
-    ngx_test_null(message, ngx_pcalloc(r->pool, sizeof(ngx_hunk_t)),
-                  NGX_HTTP_INTERNAL_SERVER_ERROR);
+    ngx_test_null(message, ngx_pcalloc(r->pool, sizeof(ngx_hunk_t)), NGX_ERROR);
 
     message->type = NGX_HUNK_MEMORY;
     message->pos.mem = error_pages[err].data;
     message->last.mem = error_pages[err].data + error_pages[err].len;
 
-    rc = ngx_http_output_filter(r, message);
+    if (ngx_http_output_filter(r, message) == NGX_ERROR) {
+        return NGX_ERROR;
+    }
 
-    ngx_test_null(tail, ngx_pcalloc(r->pool, sizeof(ngx_hunk_t)),
-                  NGX_HTTP_INTERNAL_SERVER_ERROR);
+    ngx_test_null(tail, ngx_pcalloc(r->pool, sizeof(ngx_hunk_t)), NGX_ERROR);
 
     tail->type = NGX_HUNK_MEMORY|NGX_HUNK_LAST;
     tail->pos.mem = error_tail;
     tail->last.mem = error_tail + sizeof(error_tail);
 
-    rc = ngx_http_output_filter(r, tail);
+    return ngx_http_output_filter(r, tail);
 }