modules/proxy/mod_proxy_ajp.c

	mod_proxy_ajp.c revision db9143eba1badc5e5ddf5fac58d705d332f1873d
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara/* Licensed to the Apache Software Foundation (ASF) under one or more
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * contributor license agreements.  See the NOTICE file distributed with
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * this work for additional information regarding copyright ownership.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * The ASF licenses this file to You under the Apache License, Version 2.0
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * (the "License"); you may not use this file except in compliance with
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * the License.  You may obtain a copy of the License at
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara *
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara *     http://www.apache.org/licenses/LICENSE-2.0
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara *
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * Unless required by applicable law or agreed to in writing, software
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * distributed under the License is distributed on an "AS IS" BASIS,
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * See the License for the specific language governing permissions and
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * limitations under the License.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara/* AJP routines for Apache proxy */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara#include "mod_proxy.h"
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara#include "ajp.h"
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergaramodule AP_MODULE_DECLARE_DATA proxy_ajp_module;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara/*
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * Canonicalise http-like URLs.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * scheme is the scheme for the URL
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * url is the URL starting with the first '/'
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara * def_port is the default port for this scheme.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergarastatic int proxy_ajp_canon(request_rec *r, char *url)
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara{
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    char *host, *path, sport[7];
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    char *search = NULL;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    const char *err;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    apr_port_t port = AJP13_DEF_PORT;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    /* ap_port_of_scheme() */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (strncasecmp(url, "ajp:", 4) == 0) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        url += 4;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    else {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        return DECLINED;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara             "proxy: AJP: canonicalising URL %s", url);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    /*
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * do syntactic check.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * We break the URL into host, port, path, search
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    err = ap_proxy_canon_netloc(r->pool, &url, NULL, NULL, &host, &port);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (err) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                      "error parsing URL %s: %s",
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                      url, err);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        return HTTP_BAD_REQUEST;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    /*
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * now parse path/search args, according to rfc1738:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * process the path. With proxy-nocanon set (by
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * mod_proxy) we use the raw, unparsed uri
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (apr_table_get(r->notes, "proxy-nocanon")) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        path = url;   /* this is the raw path */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    else {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        path = ap_proxy_canonenc(r->pool, url, strlen(url), enc_path, 0,
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                                 r->proxyreq);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        search = r->args;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (path == NULL)
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        return HTTP_BAD_REQUEST;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    apr_snprintf(sport, sizeof(sport), ":%d", port);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (ap_strchr_c(host, ':')) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        /* if literal IPv6 address */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        host = apr_pstrcat(r->pool, "[", host, "]", NULL);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    r->filename = apr_pstrcat(r->pool, "proxy:ajp://", host, sport,
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                              "/", path, (search) ? "?" : "",
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                              (search) ? search : "", NULL);
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    return OK;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara}
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara#define METHOD_NON_IDEMPOTENT       0
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara#define METHOD_IDEMPOTENT           1
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara#define METHOD_IDEMPOTENT_WITH_ARGS 2
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergarastatic int is_idempotent(request_rec *r)
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara{
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    /*
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * RFC2616 (9.1.2): GET, HEAD, PUT, DELETE, OPTIONS, TRACE are considered
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     * idempotent. Hint: HEAD requests use M_GET as method number as well.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara     */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    switch (r->method_number) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        case M_GET:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        case M_DELETE:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        case M_PUT:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        case M_OPTIONS:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        case M_TRACE:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            /*
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara             * If the request has arguments it might have side-effects and thus
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara             * it might be undesirable to resent it to a backend again
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara             * automatically.
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara             */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            if (r->args) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                return METHOD_IDEMPOTENT_WITH_ARGS;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            return METHOD_IDEMPOTENT;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        /* Everything else is not considered idempotent. */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        default:
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            return METHOD_NON_IDEMPOTENT;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara}
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergarastatic apr_off_t get_content_length(request_rec * r)
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara{
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    apr_off_t len = 0;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    if (r->clength > 0) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        return r->clength;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    else if (r->main == NULL) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        const char *clp = apr_table_get(r->headers_in, "Content-Length");
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        if (clp) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            char *errp;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            if (apr_strtoff(&len, clp, &errp, 10) || *errp || len < 0) {
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara                len = 0; /* parse error */
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara            }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara        }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    }
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara    return len;
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara}
11178d20048abeee671d0cdb2aab6dfbaa36293bjvergara
/*
 * XXX: AJP Auto Flushing
 *
 * When processing CMD_AJP13_SEND_BODY_CHUNK AJP messages we will do a poll
 * with FLUSH_WAIT miliseconds timeout to determine if more data is currently
 * available at the backend. If there is no more data available, we flush
 * the data to the client by adding a flush bucket to the brigade we pass
 * up the filter chain.
 * This is only a bandaid to fix the AJP/1.3 protocol shortcoming of not
 * sending (actually not having defined) a flush message, when the data
 * should be flushed to the client. As soon as this protocol shortcoming is
 * fixed this code should be removed.
 *
 * For further discussion see PR37100.
 * http://issues.apache.org/bugzilla/show_bug.cgi?id=37100
 */

/*
 * process the request and write the response.
 */
static int ap_proxy_ajp_request(apr_pool_t *p, request_rec *r,
                                proxy_conn_rec *conn,
                                conn_rec *origin,
                                proxy_dir_conf *conf,
                                apr_uri_t *uri,
                                char *url, char *server_portstr)
{
    apr_status_t status;
    int result;
    apr_bucket *e;
    apr_bucket_brigade *input_brigade;
    apr_bucket_brigade *output_brigade;
    ajp_msg_t *msg;
    apr_size_t bufsiz = 0;
    char *buff;
    char *send_body_chunk_buff;
    apr_uint16_t size;
    const char *tenc;
    int havebody = 1;
    int output_failed = 0;
    int backend_failed = 0;
    apr_off_t bb_len;
    int data_sent = 0;
    int request_ended = 0;
    int headers_sent = 0;
    int rv = 0;
    apr_int32_t conn_poll_fd;
    apr_pollfd_t *conn_poll;
    proxy_server_conf *psf =
    ap_get_module_config(r->server->module_config, &proxy_module);
    apr_size_t maxsize = AJP_MSG_BUFFER_SZ;
    int send_body = 0;
    apr_off_t content_length = 0;

    if (psf->io_buffer_size_set)
       maxsize = psf->io_buffer_size;
    if (maxsize > AJP_MAX_BUFFER_SZ)
       maxsize = AJP_MAX_BUFFER_SZ;
    else if (maxsize < AJP_MSG_BUFFER_SZ)
       maxsize = AJP_MSG_BUFFER_SZ;
    maxsize = APR_ALIGN(maxsize, 1024);

    /*
     * Send the AJP request to the remote server
     */

    /* send request headers */
    status = ajp_send_header(conn->sock, r, maxsize, uri);
    if (status != APR_SUCCESS) {
        conn->close++;
        ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                     "proxy: AJP: request failed to %pI (%s)",
                     conn->worker->cp->addr,
                     conn->worker->hostname);
        if (status == AJP_EOVERFLOW)
            return HTTP_BAD_REQUEST;
        else {
            /*
             * This is only non fatal when the method is idempotent. In this
             * case we can dare to retry it with a different worker if we are
             * a balancer member.
             */
            if (is_idempotent(r) == METHOD_IDEMPOTENT) {
                return HTTP_SERVICE_UNAVAILABLE;
            }
            return HTTP_INTERNAL_SERVER_ERROR;
        }
    }

    /* allocate an AJP message to store the data of the buckets */
    bufsiz = maxsize;
    status = ajp_alloc_data_msg(r->pool, &buff, &bufsiz, &msg);
    if (status != APR_SUCCESS) {
        /* We had a failure: Close connection to backend */
        conn->close++;
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: ajp_alloc_data_msg failed");
        return HTTP_INTERNAL_SERVER_ERROR;
    }

    /* read the first bloc of data */
    input_brigade = apr_brigade_create(p, r->connection->bucket_alloc);
    tenc = apr_table_get(r->headers_in, "Transfer-Encoding");
    if (tenc && (strcasecmp(tenc, "chunked") == 0)) {
        /* The AJP protocol does not want body data yet */
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: request is chunked");
    } else {
        /* Get client provided Content-Length header */
        content_length = get_content_length(r);
        status = ap_get_brigade(r->input_filters, input_brigade,
                                AP_MODE_READBYTES, APR_BLOCK_READ,
                                maxsize - AJP_HEADER_SZ);

        if (status != APR_SUCCESS) {
            /* We had a failure: Close connection to backend */
            conn->close++;
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                         "proxy: ap_get_brigade failed");
            apr_brigade_destroy(input_brigade);
            return HTTP_BAD_REQUEST;
        }

        /* have something */
        if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                         "proxy: APR_BUCKET_IS_EOS");
        }

        /* Try to send something */
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: data to read (max %" APR_SIZE_T_FMT
                     " at %" APR_SIZE_T_FMT ")", bufsiz, msg->pos);

        status = apr_brigade_flatten(input_brigade, buff, &bufsiz);
        if (status != APR_SUCCESS) {
            /* We had a failure: Close connection to backend */
            conn->close++;
            apr_brigade_destroy(input_brigade);
            ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                         "proxy: apr_brigade_flatten");
            return HTTP_INTERNAL_SERVER_ERROR;
        }
        apr_brigade_cleanup(input_brigade);

        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: got %" APR_SIZE_T_FMT " bytes of data", bufsiz);
        if (bufsiz > 0) {
            status = ajp_send_data_msg(conn->sock, msg, bufsiz);
            if (status != APR_SUCCESS) {
                /* We had a failure: Close connection to backend */
                conn->close++;
                apr_brigade_destroy(input_brigade);
                ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                             "proxy: send failed to %pI (%s)",
                             conn->worker->cp->addr,
                             conn->worker->hostname);
                /*
                 * It is fatal when we failed to send a (part) of the request
                 * body.
                 */
                return HTTP_INTERNAL_SERVER_ERROR;
            }
            conn->worker->s->transferred += bufsiz;
            send_body = 1;
        }
        else if (content_length > 0) {
            ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                         "proxy: read zero bytes, expecting"
                         " %" APR_OFF_T_FMT " bytes",
                         content_length);
            /*
             * We can only get here if the client closed the connection
             * to us without sending the body.
             * Now the connection is in the wrong state on the backend.
             * Sending an empty data msg doesn't help either as it does
             * not move this connection to the correct state on the backend
             * for later resusage by the next request again.
             * Close it to clean things up.
             */
            conn->close++;
            return HTTP_BAD_REQUEST;
        }
    }

    /* read the response */
    conn->data = NULL;
    status = ajp_read_header(conn->sock, r, maxsize,
                             (ajp_msg_t **)&(conn->data));
    if (status != APR_SUCCESS) {
        /* We had a failure: Close connection to backend */
        conn->close++;
        apr_brigade_destroy(input_brigade);
        ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                     "proxy: read response failed from %pI (%s)",
                     conn->worker->cp->addr,
                     conn->worker->hostname);
        /*
         * This is only non fatal when we have not sent (parts) of a possible
         * request body so far (we do not store it and thus cannot sent it
         * again) and the method is idempotent. In this case we can dare to
         * retry it with a different worker if we are a balancer member.
         */
        if (!send_body && (is_idempotent(r) == METHOD_IDEMPOTENT)) {
            return HTTP_SERVICE_UNAVAILABLE;
        }
        return HTTP_INTERNAL_SERVER_ERROR;
    }
    /* parse the reponse */
    result = ajp_parse_type(r, conn->data);
    output_brigade = apr_brigade_create(p, r->connection->bucket_alloc);

    /*
     * Prepare apr_pollfd_t struct for possible later check if there is currently
     * data available from the backend (do not flush response to client)
     * or not (flush response to client)
     */
    conn_poll = apr_pcalloc(p, sizeof(apr_pollfd_t));
    conn_poll->reqevents = APR_POLLIN;
    conn_poll->desc_type = APR_POLL_SOCKET;
    conn_poll->desc.s = conn->sock;

    bufsiz = maxsize;
    for (;;) {
        switch (result) {
            case CMD_AJP13_GET_BODY_CHUNK:
                if (havebody) {
                    if (APR_BUCKET_IS_EOS(APR_BRIGADE_LAST(input_brigade))) {
                        /* This is the end */
                        bufsiz = 0;
                        havebody = 0;
                        ap_log_error(APLOG_MARK, APLOG_DEBUG, status, r->server,
                                     "proxy: APR_BUCKET_IS_EOS");
                    } else {
                        status = ap_get_brigade(r->input_filters, input_brigade,
                                                AP_MODE_READBYTES,
                                                APR_BLOCK_READ,
                                                maxsize - AJP_HEADER_SZ);
                        if (status != APR_SUCCESS) {
                            ap_log_error(APLOG_MARK, APLOG_DEBUG, status,
                                         r->server,
                                         "ap_get_brigade failed");
                            output_failed = 1;
                            break;
                        }
                        bufsiz = maxsize;
                        status = apr_brigade_flatten(input_brigade, buff,
                                                     &bufsiz);
                        apr_brigade_cleanup(input_brigade);
                        if (status != APR_SUCCESS) {
                            ap_log_error(APLOG_MARK, APLOG_DEBUG, status,
                                         r->server,
                                         "apr_brigade_flatten failed");
                            output_failed = 1;
                            break;
                        }
                    }

                    ajp_msg_reset(msg);
                    /* will go in ajp_send_data_msg */
                    status = ajp_send_data_msg(conn->sock, msg, bufsiz);
                    if (status != APR_SUCCESS) {
                        ap_log_error(APLOG_MARK, APLOG_DEBUG, status, r->server,
                                     "ajp_send_data_msg failed");
                        backend_failed = 1;
                        break;
                    }
                    conn->worker->s->transferred += bufsiz;
                } else {
                    /*
                     * something is wrong TC asks for more body but we are
                     * already at the end of the body data
                     */
                    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                                 "ap_proxy_ajp_request error read after end");
                    backend_failed = 1;
                }
                break;
            case CMD_AJP13_SEND_HEADERS:
                if (headers_sent) {
                    /* Do not send anything to the client.
                     * Backend already send us the headers.
                     */
                    backend_failed = 1;
                    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                                 "proxy: Backend sent headers twice.");
                    break;
                }
                /* AJP13_SEND_HEADERS: process them */
                status = ajp_parse_header(r, conf, conn->data);
                if (status != APR_SUCCESS) {
                    backend_failed = 1;
                }
                headers_sent = 1;
                break;
            case CMD_AJP13_SEND_BODY_CHUNK:
                /* AJP13_SEND_BODY_CHUNK: piece of data */
                status = ajp_parse_data(r, conn->data, &size, &send_body_chunk_buff);
                if (status == APR_SUCCESS) {
                    /* AJP13_SEND_BODY_CHUNK with zero length
                     * is explicit flush message
                     */
                    if (size == 0) {
                        if (headers_sent) {
                            e = apr_bucket_flush_create(r->connection->bucket_alloc);
                            APR_BRIGADE_INSERT_TAIL(output_brigade, e);
                        }
                        else {
                            ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                                 "Ignoring flush message received before headers");
                        }
                    }
                    else {
                        e = apr_bucket_transient_create(send_body_chunk_buff, size,
                                                    r->connection->bucket_alloc);
                        APR_BRIGADE_INSERT_TAIL(output_brigade, e);

                        if ((conn->worker->flush_packets == flush_on) ||
                            ((conn->worker->flush_packets == flush_auto) &&
                            (apr_poll(conn_poll, 1, &conn_poll_fd,
                                      conn->worker->flush_wait)
                                        == APR_TIMEUP) ) ) {
                            e = apr_bucket_flush_create(r->connection->bucket_alloc);
                            APR_BRIGADE_INSERT_TAIL(output_brigade, e);
                        }
                        apr_brigade_length(output_brigade, 0, &bb_len);
                        if (bb_len != -1)
                            conn->worker->s->read += bb_len;
                    }
                    if (ap_pass_brigade(r->output_filters,
                                        output_brigade) != APR_SUCCESS) {
                        ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,
                                      "proxy: error processing body.%s",
                                      r->connection->aborted ?
                                      " Client aborted connection." : "");
                        output_failed = 1;
                    }
                    data_sent = 1;
                    apr_brigade_cleanup(output_brigade);
                }
                else {
                    backend_failed = 1;
                }
                break;
            case CMD_AJP13_END_RESPONSE:
                e = apr_bucket_eos_create(r->connection->bucket_alloc);
                APR_BRIGADE_INSERT_TAIL(output_brigade, e);
                if (ap_pass_brigade(r->output_filters,
                                    output_brigade) != APR_SUCCESS) {
                    ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, r,
                                  "proxy: error processing end");
                    output_failed = 1;
                }
                /* XXX: what about flush here? See mod_jk */
                data_sent = 1;
                request_ended = 1;
                break;
            default:
                backend_failed = 1;
                break;
        }

        /*
         * If connection has been aborted by client: Stop working.
         * Nevertheless, we regard our operation so far as a success:
         * So reset output_failed to 0 and set result to CMD_AJP13_END_RESPONSE
         * But: Close this connection to the backend.
         */
        if (r->connection->aborted) {
            conn->close++;
            output_failed = 0;
            result = CMD_AJP13_END_RESPONSE;
            request_ended = 1;
        }

        /*
         * We either have finished successfully or we failed.
         * So bail out
         */
        if ((result == CMD_AJP13_END_RESPONSE) || backend_failed
            || output_failed)
            break;

        /* read the response */
        status = ajp_read_header(conn->sock, r, maxsize,
                                 (ajp_msg_t **)&(conn->data));
        if (status != APR_SUCCESS) {
            backend_failed = 1;
            ap_log_error(APLOG_MARK, APLOG_DEBUG, status, r->server,
                         "ajp_read_header failed");
            break;
        }
        result = ajp_parse_type(r, conn->data);
    }
    apr_brigade_destroy(input_brigade);

    /*
     * Clear output_brigade to remove possible buckets that remained there
     * after an error.
     */
    apr_brigade_cleanup(output_brigade);

    if (backend_failed || output_failed) {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: Processing of request failed backend: %i, "
                     "output: %i", backend_failed, output_failed);
        /* We had a failure: Close connection to backend */
        conn->close++;
        /* Return DONE to avoid error messages being added to the stream */
        if (data_sent) {
            rv = DONE;
        }
    }
    else if (!request_ended) {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: Processing of request didn't terminate cleanly");
        /* We had a failure: Close connection to backend */
        conn->close++;
        backend_failed = 1;
        /* Return DONE to avoid error messages being added to the stream */
        if (data_sent) {
            rv = DONE;
        }
    }
    else {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: got response from %pI (%s)",
                     conn->worker->cp->addr,
                     conn->worker->hostname);
        rv = OK;
    }

    if (backend_failed) {
        ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                     "proxy: dialog to %pI (%s) failed",
                     conn->worker->cp->addr,
                     conn->worker->hostname);
        /*
         * If we already send data, signal a broken backend connection
         * upwards in the chain.
         */
        if (data_sent) {
            ap_proxy_backend_broke(r, output_brigade);
        } else
            rv = HTTP_SERVICE_UNAVAILABLE;
    }

    /*
     * Ensure that we sent an EOS bucket thru the filter chain, if we already
     * have sent some data. Maybe ap_proxy_backend_broke was called and added
     * one to the brigade already (no longer making it empty). So we should
     * not do this in this case.
     */
    if (data_sent && !r->eos_sent && APR_BRIGADE_EMPTY(output_brigade)) {
        e = apr_bucket_eos_create(r->connection->bucket_alloc);
        APR_BRIGADE_INSERT_TAIL(output_brigade, e);
    }

    /* If we have added something to the brigade above, sent it */
    if (!APR_BRIGADE_EMPTY(output_brigade))
        ap_pass_brigade(r->output_filters, output_brigade);

    apr_brigade_destroy(output_brigade);

    if (apr_table_get(r->subprocess_env, "proxy-nokeepalive")) {
        conn->close++;
    }

    return rv;
}

/*
 * This handles ajp:// URLs
 */
static int proxy_ajp_handler(request_rec *r, proxy_worker *worker,
                             proxy_server_conf *conf,
                             char *url, const char *proxyname,
                             apr_port_t proxyport)
{
    int status;
    char server_portstr[32];
    conn_rec *origin = NULL;
    proxy_conn_rec *backend = NULL;
    const char *scheme = "AJP";
    int retry;
    proxy_dir_conf *dconf = ap_get_module_config(r->per_dir_config,
                                                 &proxy_module);

    /*
     * Note: Memory pool allocation.
     * A downstream keepalive connection is always connected to the existence
     * (or not) of an upstream keepalive connection. If this is not done then
     * load balancing against multiple backend servers breaks (one backend
     * server ends up taking 100% of the load), and the risk is run of
     * downstream keepalive connections being kept open unnecessarily. This
     * keeps webservers busy and ties up resources.
     *
     * As a result, we allocate all sockets out of the upstream connection
     * pool, and when we want to reuse a socket, we check first whether the
     * connection ID of the current upstream connection is the same as that
     * of the connection when the socket was opened.
     */
    apr_pool_t *p = r->connection->pool;
    apr_uri_t *uri = apr_palloc(r->connection->pool, sizeof(*uri));


    if (strncasecmp(url, "ajp:", 4) != 0) {
        ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                     "proxy: AJP: declining URL %s", url);
        return DECLINED;
    }
    ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server,
                 "proxy: AJP: serving URL %s", url);

    /* create space for state information */
    status = ap_proxy_acquire_connection(scheme, &backend, worker,
                                         r->server);
    if (status != OK) {
        if (backend) {
            backend->close = 1;
            ap_proxy_release_connection(scheme, backend, r->server);
        }
        return status;
    }

    backend->is_ssl = 0;
    backend->close = 0;

    retry = 0;
    while (retry < 2) {
        char *locurl = url;
        /* Step One: Determine Who To Connect To */
        status = ap_proxy_determine_connection(p, r, conf, worker, backend,
                                               uri, &locurl, proxyname, proxyport,
                                               server_portstr,
                                               sizeof(server_portstr));

        if (status != OK)
            break;

        /* Step Two: Make the Connection */
        if (ap_proxy_connect_backend(scheme, backend, worker, r->server)) {
            ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server,
                         "proxy: AJP: failed to make connection to backend: %s",
                         backend->hostname);
            status = HTTP_SERVICE_UNAVAILABLE;
            break;
        }

        /* Handle CPING/CPONG */
        if (worker->ping_timeout_set) {
            status = ajp_handle_cping_cpong(backend->sock, r,
                                            worker->ping_timeout);
            /*
             * In case the CPING / CPONG failed for the first time we might be
             * just out of luck and got a faulty backend connection, but the
             * backend might be healthy nevertheless. So ensure that the backend
             * TCP connection gets closed and try it once again.
             */
            if (status != APR_SUCCESS) {
                backend->close++;
                ap_log_error(APLOG_MARK, APLOG_ERR, status, r->server,
                             "proxy: AJP: cping/cpong failed to %pI (%s)",
                             worker->cp->addr,
                             worker->hostname);
                status = HTTP_SERVICE_UNAVAILABLE;
                retry++;
                continue;
            }
        }
        /* Step Three: Process the Request */
        status = ap_proxy_ajp_request(p, r, backend, origin, dconf, uri, locurl,
                                      server_portstr);
        break;
    }

    /* Do not close the socket */
    ap_proxy_release_connection(scheme, backend, r->server);
    return status;
}

static void ap_proxy_http_register_hook(apr_pool_t *p)
{
    proxy_hook_scheme_handler(proxy_ajp_handler, NULL, NULL, APR_HOOK_FIRST);
    proxy_hook_canon_handler(proxy_ajp_canon, NULL, NULL, APR_HOOK_FIRST);
}

module AP_MODULE_DECLARE_DATA proxy_ajp_module = {
    STANDARD20_MODULE_STUFF,
    NULL,                       /* create per-directory config structure */
    NULL,                       /* merge per-directory config structures */
    NULL,                       /* create per-server config structure */
    NULL,                       /* merge per-server config structures */
    NULL,                       /* command apr_table_t */
    ap_proxy_http_register_hook /* register hooks */
};