* Move handling of backends that broke after the headers have been sent

  into the proxy handler of mod_proxy.

  This patch still sets r->connection->aborted to 1 which is currently
  vetoed by Roy. Moving it from the scheme handler to the proxy handler
  should ease the reimplementation of this, as the scheme handlers only
  needs to return PROXY_BACKEND_BROKEN to signal the above situation to
  the proxy handler.

  mod_proxy.h: Add define for PROXY_BACKEND_BROKEN
  mod_proxy.c: Handle PROXY_BACKEND_BROKEN in proxy handler
  mod_proxy_http.c: Sent back PROXY_BACKEND_BROKEN if backend broke
  after we sent the headers.

git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@355823 13f79535-47bb-0310-9956-ffa450edef68

diff --git a/modules/proxy/mod_proxy.c b/modules/proxy/mod_proxy.c
index 4eab150829ee410490b78e7fff89ee5fb2f699b5..0101c5ff14d7f21b5ca973c90ed11a82990fff1d 100644 (file)
--- a/modules/proxy/mod_proxy.c
+++ b/modules/proxy/mod_proxy.c
@@ -758,6 +758,20 @@ static int proxy_handler(request_rec *r)
                 worker->s->status |= PROXY_WORKER_IN_ERROR;
             }
         }
+        else if (access_status == PROXY_BACKEND_BROKEN) {
+            /*
+             * If the backend broke after the headers had been sent do not
+             * try another worker, but leave. Do not mark the worker as
+             * unsuable as this problem may not reoccur on the next request.
+             *
+             * TODO: Currently we abort the connection and notify all parties
+             * on the upstream that something went wrong by setting c->aborted
+             * to 1. This idea is currently vetoed and should be replaced with
+             * other methods
+             */
+            r->connection->aborted = 1;
+            break;
+        }
         else {
             /* Unrecoverable error.
              * Return the origin status code to the client.

diff --git a/modules/proxy/mod_proxy.h b/modules/proxy/mod_proxy.h
index 63ed1afe2cfcf0435169720146ac70d6d96f483d..f84cc254f5d7a259ca4b6892320fff6a4cfad806 100644 (file)
--- a/modules/proxy/mod_proxy.h
+++ b/modules/proxy/mod_proxy.h
@@ -238,6 +238,12 @@ struct proxy_conn_pool {
     proxy_conn_rec *conn;   /* Single connection for prefork mpm's */
 };
 
+/*
+ * Return code that scheme handlers should return if the backend connection
+ * broke after they have sent the headers
+ */
+#define PROXY_BACKEND_BROKEN -10
+
 /* woker status flags */
 #define PROXY_WORKER_INITIALIZED    0x0001
 #define PROXY_WORKER_IGNORE_ERRORS  0x0002

diff --git a/modules/proxy/mod_proxy_http.c b/modules/proxy/mod_proxy_http.c
index 250b7601d02823afab839403951d2620929a63b0..b751efadc4a77fd94574e488926f0a210bf89a2f 100644 (file)
--- a/modules/proxy/mod_proxy_http.c
+++ b/modules/proxy/mod_proxy_http.c
@@ -1199,6 +1199,7 @@ apr_status_t ap_proxy_http_process_response(apr_pool_t * p, request_rec *r,
                            * are being read. */
     int pread_len = 0;
     apr_table_t *save_table;
+    int backend_broken = 0;
 
     bb = apr_brigade_create(p, c->bucket_alloc);
 
@@ -1486,7 +1487,7 @@ apr_status_t ap_proxy_http_process_response(apr_pool_t * p, request_rec *r,
                          */
                         ap_log_cerror(APLOG_MARK, APLOG_ERR, rv, c,
                                       "proxy: error reading response");
-                        c->aborted = 1;
+                        backend_broken = 1;
                         break;
                     }
                     /* next time try a non-blocking read */
@@ -1552,9 +1553,9 @@ apr_status_t ap_proxy_http_process_response(apr_pool_t * p, request_rec *r,
         }
     } while (interim_response);
 
-    /* If our connection with the client is to be aborted, return DONE. */
-    if (c->aborted) {
-        return DONE;
+    /* Signal back that the backend broke after we sent the headers. */
+    if (backend_broken) {
+        return PROXY_BACKEND_BROKEN;
     }
 
     if (conf->error_override) {