modules/filters/mod_ext_filter.c

	mod_ext_filter.c revision 33bdcae1f7a1a65e351dda2a766a0cf28b1e695d
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick/* ====================================================================
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * The Apache Software License, Version 1.1
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
33bdcae1f7a1a65e351dda2a766a0cf28b1e695dnd * Copyright (c) 2000-2003 The Apache Software Foundation.  All rights
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * reserved.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * Redistribution and use in source and binary forms, with or without
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * modification, are permitted provided that the following conditions
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * are met:
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * 1. Redistributions of source code must retain the above copyright
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    notice, this list of conditions and the following disclaimer.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * 2. Redistributions in binary form must reproduce the above copyright
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    notice, this list of conditions and the following disclaimer in
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    the documentation and/or other materials provided with the
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    distribution.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * 3. The end-user documentation included with the redistribution,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    if any, must include the following acknowledgment:
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *       "This product includes software developed by the
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *        Apache Software Foundation (http://www.apache.org/)."
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    Alternately, this acknowledgment may appear in the software itself,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    if and wherever such third-party acknowledgments normally appear.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * 4. The names "Apache" and "Apache Software Foundation" must
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    not be used to endorse or promote products derived from this
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    software without prior written permission. For written
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    permission, please contact apache@apache.org.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * 5. Products derived from this software may not be called "Apache",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    nor may "Apache" appear in their name, without prior written
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *    permission of the Apache Software Foundation.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * SUCH DAMAGE.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * ====================================================================
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * This software consists of voluntary contributions made by many
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * individuals on behalf of the Apache Software Foundation.  For more
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * information on the Apache Software Foundation, please see
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * <http://www.apache.org/>.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * Portions of this software are based upon public domain software
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * originally written at the National Center for Supercomputing Applications,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * University of Illinois, Urbana-Champaign.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick/*
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * mod_ext_filter allows Unix-style filters to filter http content.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "httpd.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "http_config.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "http_log.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "http_protocol.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define CORE_PRIVATE
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "http_core.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_buckets.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "util_filter.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "util_script.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_strings.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_hash.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_lib.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_poll.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define APR_WANT_STRFUNC
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#include "apr_want.h"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawicktypedef struct ef_server_t {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_pool_t *p;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_hash_t *h;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick} ef_server_t;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawicktypedef struct ef_filter_t {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *name;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    enum {INPUT_FILTER=1, OUTPUT_FILTER} mode;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_filter_type ftype;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *command;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *enable_env;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *disable_env;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    char **args;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *intype;             /* list of IMTs we process (well, just one for now) */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define INTYPE_ALL (char *)1
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *outtype;            /* IMT of filtered output */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define OUTTYPE_UNCHANGED (char *)1
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    int preserves_content_length;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick} ef_filter_t;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawicktypedef struct ef_dir_t {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    int debug;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    int log_stderr;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick} ef_dir_t;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawicktypedef struct ef_ctx_t {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_pool_t *p;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_proc_t *proc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_procattr_t *procattr;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_filter_t *filter;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    int noop;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if APR_FILES_AS_SOCKETS
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_pollfd_t *pollset;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick} ef_ctx_t;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickmodule AP_MODULE_DECLARE_DATA ext_filter_module;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const server_rec *main_server;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t ef_output_filter(ap_filter_t *, apr_bucket_brigade *);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define DBGLVL_SHOWOPTIONS         1
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#define DBGLVL_GORY                9
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic void *create_ef_dir_conf(apr_pool_t *p, char *dummy)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc = (ef_dir_t *)apr_pcalloc(p, sizeof(ef_dir_t));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    dc->debug = -1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    dc->log_stderr = -1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic void *create_ef_server_conf(apr_pool_t *p, server_rec *s)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_server_t *conf;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    conf = (ef_server_t *)apr_pcalloc(p, sizeof(ef_server_t));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    conf->p = p;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    conf->h = apr_hash_make(conf->p);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return conf;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic void *merge_ef_dir_conf(apr_pool_t *p, void *basev, void *overridesv)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *a = (ef_dir_t *)apr_pcalloc (p, sizeof(ef_dir_t));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *base = (ef_dir_t *)basev, *over = (ef_dir_t *)overridesv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (over->debug != -1) {        /* if admin coded something... */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        a->debug = over->debug;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        a->debug = base->debug;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (over->log_stderr != -1) {   /* if admin coded something... */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        a->log_stderr = over->log_stderr;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        a->log_stderr = base->log_stderr;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return a;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const char *add_options(cmd_parms *cmd, void *in_dc,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                               const char *arg)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc = in_dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!strncasecmp(arg, "DebugLevel=", 11)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        dc->debug = atoi(arg + 11);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else if (!strcasecmp(arg, "LogStderr")) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        dc->log_stderr = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else if (!strcasecmp(arg, "NoLogStderr")) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        dc->log_stderr = 0;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return apr_pstrcat(cmd->temp_pool,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                           "Invalid ExtFilterOptions option: ",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                           arg,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                           NULL);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return NULL;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const char *parse_cmd(apr_pool_t *p, const char **args, ef_filter_t *filter)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (**args == '"') {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        const char *start = *args + 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        char *parms;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        int escaping = 0;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ++*args; /* move past leading " */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* find true end of args string (accounting for escaped quotes) */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        while (**args && (**args != '"' || (**args == '"' && escaping))) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (escaping) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                escaping = 0;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            else if (**args == '\\') {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                escaping = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ++*args;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (**args != '"') {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return "Expected cmd= delimiter";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* copy *just* the arg string for parsing, */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        parms = apr_pstrndup(p, start, *args - start);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ++*args; /* move past trailing " */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* parse and tokenize the args. */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_tokenize_to_argv(parms, &(filter->args), p);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return "cmd= parse error";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* simple path */
6e128d9c91437b22850d19fc166a6165e3c4831ctrawick        /* Allocate space for two argv pointers and parse the args. */
6e128d9c91437b22850d19fc166a6165e3c4831ctrawick        filter->args = (char **)apr_palloc(p, 2 * sizeof(char *));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        filter->args[0] = ap_getword_white(p, args);
6e128d9c91437b22850d19fc166a6165e3c4831ctrawick        filter->args[1] = NULL; /* end of args */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!filter->args[0]) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return "Invalid cmd= parameter";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    filter->command = filter->args[0];
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return NULL;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const char *define_filter(cmd_parms *cmd, void *dummy, const char *args)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_server_t *conf = ap_get_module_config(cmd->server->module_config,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                             &ext_filter_module);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *token;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *name;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_filter_t *filter;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    name = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!name) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return "Filter name not found";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (apr_hash_get(conf->h, name, APR_HASH_KEY_STRING)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return apr_psprintf(cmd->pool, "ExtFilter %s is already defined",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            name);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    filter = (ef_filter_t *)apr_pcalloc(conf->p, sizeof(ef_filter_t));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    filter->name = name;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    filter->mode = OUTPUT_FILTER;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    filter->ftype = AP_FTYPE_RESOURCE;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_hash_set(conf->h, name, APR_HASH_KEY_STRING, filter);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    while (*args) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        while (apr_isspace(*args)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ++args;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* Nasty parsing...  I wish I could simply use ap_getword_white()
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         * here and then look at the token, but ap_getword_white() doesn't
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         * do the right thing when we have cmd="word word word"
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "preservescontentlength", 22)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            token = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (!strcasecmp(token, "preservescontentlength")) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                filter->preserves_content_length = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return apr_psprintf(cmd->pool,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                    "mangled argument `%s'",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                    token);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "mode=", 5)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 5;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            token = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (!strcasecmp(token, "output")) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                filter->mode = OUTPUT_FILTER;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            else if (!strcasecmp(token, "input")) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                filter->mode = INPUT_FILTER;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return apr_psprintf(cmd->pool, "Invalid mode: `%s'",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                    token);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "ftype=", 6)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 6;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            token = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            filter->ftype = atoi(token);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "enableenv=", 10)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 10;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            token = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            filter->enable_env = token;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "disableenv=", 11)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 11;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            token = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            filter->disable_env = token;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "intype=", 7)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 7;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            filter->intype = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "outtype=", 8)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 8;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            filter->outtype = ap_getword_white(cmd->pool, &args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!strncasecmp(args, "cmd=", 4)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            args += 4;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if ((token = parse_cmd(cmd->pool, &args, filter))) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return token;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            continue;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return apr_psprintf(cmd->pool, "Unexpected parameter: `%s'",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* parsing is done...  register the filter
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (filter->mode == OUTPUT_FILTER) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* XXX need a way to ensure uniqueness among all filters */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_register_output_filter(filter->name, ef_output_filter, NULL, filter->ftype);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if 0              /* no input filters yet */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else if (filter->mode == INPUT_FILTER) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* XXX need a way to ensure uniqueness among all filters */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_register_input_filter(filter->name, ef_input_filter, NULL, AP_FTYPE_RESOURCE);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(1 != 1); /* we set the field wrong somehow */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return NULL;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const command_rec cmds[] =
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    AP_INIT_ITERATE("ExtFilterOptions",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    add_options,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    NULL,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    ACCESS_CONF, /* same as SetInputFilter/SetOutputFilter */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    "valid options: DebugLevel=n, LogStderr, NoLogStderr"),
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    AP_INIT_RAW_ARGS("ExtFilterDefine",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                     define_filter,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                     NULL,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                     RSRC_CONF,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                     "Define an external filter"),
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    {NULL}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick};
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic int ef_init(apr_pool_t *p, apr_pool_t *plog, apr_pool_t *ptemp, server_rec *main_s)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    main_server = main_s;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return OK;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic void register_hooks(apr_pool_t *p)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_hook_post_config(ef_init, NULL, NULL, APR_HOOK_MIDDLE);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t set_resource_limits(request_rec *r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                        apr_procattr_t *procattr)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if defined(RLIMIT_CPU)  || defined(RLIMIT_NPROC) || \
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    defined(RLIMIT_DATA) || defined(RLIMIT_VMEM) || defined (RLIMIT_AS)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    core_dir_config *conf =
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        (core_dir_config *)ap_get_module_config(r->per_dir_config,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                                &core_module);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#ifdef RLIMIT_CPU
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rv = apr_procattr_limit_set(procattr, APR_LIMIT_CPU, conf->limit_cpu);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rv == APR_SUCCESS); /* otherwise, we're out of sync with APR */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if defined(RLIMIT_DATA) || defined(RLIMIT_VMEM) || defined(RLIMIT_AS)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rv = apr_procattr_limit_set(procattr, APR_LIMIT_MEM, conf->limit_mem);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rv == APR_SUCCESS); /* otherwise, we're out of sync with APR */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#ifdef RLIMIT_NPROC
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rv = apr_procattr_limit_set(procattr, APR_LIMIT_NPROC, conf->limit_nproc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rv == APR_SUCCESS); /* otherwise, we're out of sync with APR */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif /* if at least one limit defined */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return APR_SUCCESS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t ef_close_file(void *vfile)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return apr_file_close(vfile);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick/* init_ext_filter_process: get the external filter process going
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * This is per-filter-instance (i.e., per-request) initialization.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t init_ext_filter_process(ap_filter_t *f)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_ctx_t *ctx = f->ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc = ctx->dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char * const *env;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ctx->proc = apr_pcalloc(ctx->p, sizeof(*ctx->proc));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rc = apr_procattr_create(&ctx->procattr, ctx->p);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rc = apr_procattr_io_set(ctx->procattr,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            APR_CHILD_BLOCK,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            APR_CHILD_BLOCK,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            APR_CHILD_BLOCK);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rc = set_resource_limits(f->r, ctx->procattr);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (dc->log_stderr > 0) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_procattr_child_err_set(ctx->procattr,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                      f->r->server->error_log, /* stderr in child */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                      NULL);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* add standard CGI variables as well as DOCUMENT_URI, DOCUMENT_PATH_INFO,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * and QUERY_STRING_UNESCAPED
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ap_add_cgi_vars(f->r);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_table_setn(f->r->subprocess_env, "DOCUMENT_URI", f->r->uri);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_table_setn(f->r->subprocess_env, "DOCUMENT_PATH_INFO", f->r->path_info);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (f->r->args) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            /* QUERY_STRING is added by ap_add_cgi_vars */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        char *arg_copy = apr_pstrdup(f->r->pool, f->r->args);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_unescape_url(arg_copy);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        apr_table_setn(f->r->subprocess_env, "QUERY_STRING_UNESCAPED",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                       ap_escape_shell_cmd(f->r->pool, arg_copy));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    env = (const char * const *) ap_create_environment(ctx->p,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                                       f->r->subprocess_env);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rc = apr_proc_create(ctx->proc,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            ctx->filter->command,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            (const char * const *)ctx->filter->args,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            env, /* environment */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            ctx->procattr,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                            ctx->p);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (rc != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_log_rerror(APLOG_MARK, APLOG_ERR, rc, f->r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      "couldn't create child process to run `%s'",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      ctx->filter->command);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return rc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_pool_note_subprocess(ctx->p, ctx->proc, APR_KILL_AFTER_TIMEOUT);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* We don't want the handle to the child's stdin inherited by any
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * other processes created by httpd.  Otherwise, when we close our
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * handle, the child won't see EOF because another handle will still
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * be open.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_pool_cleanup_register(ctx->p, ctx->proc->in,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                         apr_pool_cleanup_null, /* other mechanism */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                         ef_close_file);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if APR_FILES_AS_SOCKETS
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        apr_socket_t *newsock;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_poll_setup(&ctx->pollset, 2, ctx->p);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_socket_from_file(&newsock, ctx->proc->in);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_poll_socket_add(ctx->pollset, newsock, APR_POLLOUT);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_socket_from_file(&newsock, ctx->proc->out);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rc = apr_poll_socket_add(ctx->pollset, newsock, APR_POLLIN);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_assert(rc == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return APR_SUCCESS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic const char *get_cfg_string(ef_dir_t *dc, ef_filter_t *filter, apr_pool_t *p)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *debug_str = dc->debug == -1 ?
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        "DebugLevel=0" : apr_psprintf(p, "DebugLevel=%d", dc->debug);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *log_stderr_str = dc->log_stderr < 1 ?
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        "NoLogStderr" : "LogStderr";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *preserve_content_length_str = filter->preserves_content_length ?
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        "PreservesContentLength" : "!PreserveContentLength";
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *intype_str = !filter->intype ?
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        "*/*" : filter->intype;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *outtype_str = !filter->outtype ?
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        "(unchanged)" : filter->outtype;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return apr_psprintf(p,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                        "ExtFilterOptions %s %s %s ExtFilterInType %s "
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                        "ExtFilterOuttype %s",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                        debug_str, log_stderr_str, preserve_content_length_str,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                        intype_str, outtype_str);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic ef_filter_t *find_filter_def(const server_rec *s, const char *fname)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_server_t *sc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_filter_t *f;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    sc = ap_get_module_config(s->module_config, &ext_filter_module);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    f = apr_hash_get(sc->h, fname, APR_HASH_KEY_STRING);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!f && s != main_server) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        s = main_server;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        sc = ap_get_module_config(s->module_config, &ext_filter_module);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        f = apr_hash_get(sc->h, fname, APR_HASH_KEY_STRING);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return f;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t init_filter_instance(ap_filter_t *f)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_ctx_t *ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    f->ctx = ctx = apr_pcalloc(f->r->pool, sizeof(ef_ctx_t));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    dc = ap_get_module_config(f->r->per_dir_config,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                              &ext_filter_module);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ctx->dc = dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* look for the user-defined filter */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ctx->filter = find_filter_def(f->r->server, f->frec->name);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!ctx->filter) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_log_rerror(APLOG_MARK, APLOG_ERR, 0, f->r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      "couldn't find definition of filter '%s'",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      f->frec->name);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return APR_EINVAL;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ctx->p = f->r->pool;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (ctx->filter->intype &&
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ctx->filter->intype != INTYPE_ALL) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!f->r->content_type) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ctx->noop = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        else {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            const char *ctypes = f->r->content_type;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            const char *ctype = ap_getword(f->r->pool, &ctypes, ';');
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (strcasecmp(ctx->filter->intype, ctype)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                /* wrong IMT for us; don't mess with the output */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                ctx->noop = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (ctx->filter->enable_env &&
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        !apr_table_get(f->r->subprocess_env, ctx->filter->enable_env)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* an environment variable that enables the filter isn't set; bail */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ctx->noop = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (ctx->filter->disable_env &&
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        apr_table_get(f->r->subprocess_env, ctx->filter->disable_env)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* an environment variable that disables the filter is set; bail */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ctx->noop = 1;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!ctx->noop) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = init_ext_filter_process(f);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (ctx->filter->outtype &&
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ctx->filter->outtype != OUTTYPE_UNCHANGED) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_set_content_type(f->r, ctx->filter->outtype);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (ctx->filter->preserves_content_length != 1) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            /* nasty, but needed to avoid confusing the browser
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick             */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            apr_table_unset(f->r->headers_out, "Content-Length");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (dc->debug >= DBGLVL_SHOWOPTIONS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_log_rerror(APLOG_MARK, APLOG_DEBUG, 0, f->r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      "%sfiltering `%s' of type `%s' through `%s', cfg %s",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      ctx->noop ? "NOT " : "",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      f->r->uri ? f->r->uri : f->r->filename,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      f->r->content_type ? f->r->content_type : "(unspecified)",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      ctx->filter->command,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      get_cfg_string(dc, ctx->filter, f->r->pool));
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return APR_SUCCESS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick/* drain_available_output():
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick *
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * if any data is available from the filter, read it and pass it
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick * to the next filter
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t drain_available_output(ap_filter_t *f)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    request_rec *r = f->r;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    conn_rec *c = r->connection;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_ctx_t *ctx = f->ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc = ctx->dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_size_t len;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    char buf[4096];
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_bucket_brigade *bb;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_bucket *b;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    while (1) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        len = sizeof(buf);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_file_read(ctx->proc->out,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      buf,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      &len);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv && !APR_STATUS_IS_EAGAIN(rv)) ||
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            dc->debug >= DBGLVL_GORY) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_DEBUG, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "apr_file_read(child output), len %" APR_SIZE_T_FMT,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          !rv ? len : -1);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        bb = apr_brigade_create(r->pool, c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        b = apr_bucket_transient_create(buf, len, c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        APR_BRIGADE_INSERT_TAIL(bb, b);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv = ap_pass_brigade(f->next, bb)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "ap_pass_brigade()");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* we should never get here; if we do, a bogus error message would be
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * the least of our problems
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return APR_ANONYMOUS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t pass_data_to_filter(ap_filter_t *f, const char *data,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                        apr_size_t len)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_ctx_t *ctx = f->ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc = ctx->dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_size_t bytes_written = 0;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_size_t tmplen;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    do {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        tmplen = len - bytes_written;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_file_write(ctx->proc->in,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                       (const char *)data + bytes_written,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                       &tmplen);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        bytes_written += tmplen;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv != APR_SUCCESS && !APR_STATUS_IS_EAGAIN(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, f->r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "apr_file_write(child input), len %" APR_SIZE_T_FMT,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          tmplen);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (APR_STATUS_IS_EAGAIN(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            /* XXX handle blocking conditions here...  if we block, we need
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick             * to read data from the child process and pass it down to the
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick             * next filter!
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick             */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            rv = drain_available_output(f);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (APR_STATUS_IS_EAGAIN(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if APR_FILES_AS_SOCKETS
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                int num_events;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                rv = apr_poll(ctx->pollset, 2,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                              &num_events, f->r->server->timeout);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                if (rv || dc->debug >= DBGLVL_GORY) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    ap_log_rerror(APLOG_MARK, APLOG_DEBUG,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                  rv, f->r, "apr_poll()");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                if (rv != APR_SUCCESS && !APR_STATUS_IS_EINTR(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    /* some error such as APR_TIMEUP */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#else /* APR_FILES_AS_SOCKETS */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                /* Yuck... I'd really like to wait until I can read
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                 * or write, but instead I have to sleep and try again
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                 */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                apr_sleep(100000); /* 100 milliseconds */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                if (dc->debug >= DBGLVL_GORY) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                    ap_log_rerror(APLOG_MARK, APLOG_DEBUG,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                  0, f->r, "apr_sleep()");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif /* APR_FILES_AS_SOCKETS */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            else if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    } while (bytes_written < len);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic apr_status_t ef_output_filter(ap_filter_t *f, apr_bucket_brigade *bb)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    request_rec *r = f->r;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    conn_rec *c = r->connection;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_ctx_t *ctx = f->ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_bucket *b;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    ef_dir_t *dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_size_t len;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    const char *data;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    char buf[4096];
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_bucket *eos = NULL;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!ctx) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv = init_filter_instance(f)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ctx = f->ctx;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (ctx->noop) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        ap_remove_output_filter(f);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return ap_pass_brigade(f->next, bb);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    dc = ctx->dc;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    APR_BRIGADE_FOREACH(b, bb) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (APR_BUCKET_IS_EOS(b)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            eos = b;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            break;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_bucket_read(b, &data, &len, APR_BLOCK_READ);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r, "apr_bucket_read()");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* Good cast, we just tested len isn't negative */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (len > 0 &&
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            (rv = pass_data_to_filter(f, data, (apr_size_t)len))
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_brigade_destroy(bb);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    /* XXX What we *really* need to do once we've hit eos is create a pipe bucket
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     * from the child output pipe and pass down the pipe bucket + eos.
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick     */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (eos) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* close the child's stdin to signal that no more data is coming;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         * that will cause the child to finish generating output
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv = apr_file_close(ctx->proc->in)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "apr_file_close(child input)");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* since we've seen eos and closed the child's stdin, set the proper pipe
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         * timeout; we don't care if we don't return from apr_file_read() for a while...
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick         */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_file_pipe_timeout_set(ctx->proc->out,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                                       r->server->timeout);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "apr_file_pipe_timeout_set(child output)");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    do {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        len = sizeof(buf);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        rv = apr_file_read(ctx->proc->out,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      buf,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                      &len);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv && !APR_STATUS_IS_EOF(rv) && !APR_STATUS_IS_EAGAIN(rv)) ||
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            dc->debug >= DBGLVL_GORY) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_DEBUG, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "apr_file_read(child output), len %" APR_SIZE_T_FMT,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          !rv ? len : -1);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (APR_STATUS_IS_EAGAIN(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if (eos) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                /* should not occur, because we have an APR timeout in place */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                AP_DEBUG_ASSERT(1 != 1);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return APR_SUCCESS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (rv == APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            bb = apr_brigade_create(r->pool, c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            b = apr_bucket_transient_create(buf, len, c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            APR_BRIGADE_INSERT_TAIL(bb, b);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if ((rv = ap_pass_brigade(f->next, bb)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                              "ap_pass_brigade(filtered buffer) failed");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    } while (rv == APR_SUCCESS);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (!APR_STATUS_IS_EOF(rv)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (eos) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        /* pass down eos */
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        bb = apr_brigade_create(r->pool, c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        b = apr_bucket_eos_create(c->bucket_alloc);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        APR_BRIGADE_INSERT_TAIL(bb, b);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if ((rv = ap_pass_brigade(f->next, bb)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, r,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                          "ap_pass_brigade(eos) failed");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return APR_SUCCESS;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#if 0
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickstatic int ef_input_filter(ap_filter_t *f, apr_bucket_brigade *bb,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                           ap_input_mode_t mode, apr_read_type_e block,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                           apr_off_t readbytes)
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_status_t rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_bucket *b;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    char *buf;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    apr_ssize_t len;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    char *zero;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    rv = ap_get_brigade(f->next, bb, mode, block, readbytes);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    if (rv != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    APR_BRIGADE_FOREACH(b, bb) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        if (!APR_BUCKET_IS_EOS(b)) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            if ((rv = apr_bucket_read(b, (const char **)&buf, &len, APR_BLOCK_READ)) != APR_SUCCESS) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                ap_log_rerror(APLOG_MARK, APLOG_ERR, rv, f->r, "apr_bucket_read() failed");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_error(APLOG_MARK, APLOG_ERR, 0, NULL, "apr_bucket_read -> %d bytes",
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                         len);
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            while ((zero = memchr(buf, '0', len))) {
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick                *zero = 'a';
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick        else
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick            ap_log_error(APLOG_MARK, APLOG_ERR, 0, NULL, "got eos bucket");
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    }
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    return rv;
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick}
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick#endif
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawickmodule AP_MODULE_DECLARE_DATA ext_filter_module =
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick{
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    STANDARD20_MODULE_STUFF,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    create_ef_dir_conf,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    merge_ef_dir_conf,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    create_ef_server_conf,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    NULL,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    cmds,
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick    register_hooks
acc9093ae1f3c97acc635bd5b2c7c0969da21183trawick};