httpd/server/log.c

	log.c revision 404e2e1f8ad30c2d996f5fb6b3a9a4a4a14a004b
/* ====================================================================
 * The Apache Software License, Version 1.1
 *
 * Copyright (c) 2000 The Apache Software Foundation.  All rights
 * reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 *
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in
 *    the documentation and/or other materials provided with the
 *    distribution.
 *
 * 3. The end-user documentation included with the redistribution,
 *    if any, must include the following acknowledgment:
 *       "This product includes software developed by the
 *        Apache Software Foundation (http://www.apache.org/)."
 *    Alternately, this acknowledgment may appear in the software itself,
 *    if and wherever such third-party acknowledgments normally appear.
 *
 * 4. The names "Apache" and "Apache Software Foundation" must
 *    not be used to endorse or promote products derived from this
 *    software without prior written permission. For written
 *    permission, please contact apache@apache.org.
 *
 * 5. Products derived from this software may not be called "Apache",
 *    nor may "Apache" appear in their name, without prior written
 *    permission of the Apache Software Foundation.
 *
 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED.  IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
 * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of the Apache Software Foundation.  For more
 * information on the Apache Software Foundation, please see
 * <http://www.apache.org/>.
 *
 * Portions of this software are based upon public domain software
 * originally written at the National Center for Supercomputing Applications,
 * University of Illinois, Urbana-Champaign.
 */

/*
 * http_log.c: Dealing with the logs and errors
 *
 * Rob McCool
 *
 */


#define CORE_PRIVATE
#include "apr.h"  /* for ap_signal */
#include "ap_config.h"
#include "apr_lib.h"
#include "apr_portable.h"
#include "httpd.h"
#include "http_config.h"
#include "http_core.h"
#include "http_log.h"
#include "http_main.h"

#include <stdarg.h>

typedef struct {
    char    *t_name;
    int t_val;
} TRANS;

#ifdef HAVE_SYSLOG

static const TRANS facilities[] = {
    {"auth",    LOG_AUTH},
#ifdef LOG_AUTHPRIV
    {"authpriv",LOG_AUTHPRIV},
#endif
#ifdef LOG_CRON
    {"cron",    LOG_CRON},
#endif
#ifdef LOG_DAEMON
    {"daemon",  LOG_DAEMON},
#endif
#ifdef LOG_FTP
    {"ftp", LOG_FTP},
#endif
#ifdef LOG_KERN
    {"kern",    LOG_KERN},
#endif
#ifdef LOG_LPR
    {"lpr", LOG_LPR},
#endif
#ifdef LOG_MAIL
    {"mail",    LOG_MAIL},
#endif
#ifdef LOG_NEWS
    {"news",    LOG_NEWS},
#endif
#ifdef LOG_SYSLOG
    {"syslog",  LOG_SYSLOG},
#endif
#ifdef LOG_USER
    {"user",    LOG_USER},
#endif
#ifdef LOG_UUCP
    {"uucp",    LOG_UUCP},
#endif
#ifdef LOG_LOCAL0
    {"local0",  LOG_LOCAL0},
#endif
#ifdef LOG_LOCAL1
    {"local1",  LOG_LOCAL1},
#endif
#ifdef LOG_LOCAL2
    {"local2",  LOG_LOCAL2},
#endif
#ifdef LOG_LOCAL3
    {"local3",  LOG_LOCAL3},
#endif
#ifdef LOG_LOCAL4
    {"local4",  LOG_LOCAL4},
#endif
#ifdef LOG_LOCAL5
    {"local5",  LOG_LOCAL5},
#endif
#ifdef LOG_LOCAL6
    {"local6",  LOG_LOCAL6},
#endif
#ifdef LOG_LOCAL7
    {"local7",  LOG_LOCAL7},
#endif
    {NULL,      -1},
};
#endif

static const TRANS priorities[] = {
    {"emerg",   APLOG_EMERG},
    {"alert",   APLOG_ALERT},
    {"crit",    APLOG_CRIT},
    {"error",   APLOG_ERR},
    {"warn",    APLOG_WARNING},
    {"notice",  APLOG_NOTICE},
    {"info",    APLOG_INFO},
    {"debug",   APLOG_DEBUG},
    {NULL,  -1},
};

static int log_child(ap_pool_t *p, const char *progname,
                     ap_file_t **fpin)
{
    /* Child process code for 'ErrorLog "|..."';
     * may want a common framework for this, since I expect it will
     * be common for other foo-loggers to want this sort of thing...
     */
    int rc = -1;
    ap_procattr_t *procattr;
    ap_proc_t *procnew;

    ap_block_alarms();
    ap_cleanup_for_exec();

#ifdef SIGHUP
    /* No concept of a child process on Win32 */
    ap_signal(SIGHUP, SIG_IGN);
#endif /* ndef SIGHUP */

    if ((ap_createprocattr_init(&procattr, p) != APR_SUCCESS) ||
        (ap_setprocattr_io(procattr,
                           APR_FULL_BLOCK,
                           APR_NO_PIPE,
                           APR_NO_PIPE) != APR_SUCCESS)) {
        /* Something bad happened, give up and go away. */
        rc = -1;
    }
    else {
        rc = ap_create_process(&procnew, progname, NULL, NULL, procattr, p);

        if (rc == APR_SUCCESS) {
            ap_note_subprocess(p, procnew, kill_after_timeout);
            ap_get_childin(fpin, procnew);
        }
    }

    ap_unblock_alarms();

    return(rc);
}

static void open_error_log(server_rec *s, ap_pool_t *p)
{
    const char *fname;
    int rc;

    if (*s->error_fname == '|') {
    ap_file_t *dummy = NULL;

        /* This starts a new process... */
        rc = log_child (p, s->error_fname+1, &dummy);
        if (rc != APR_SUCCESS) {
        perror("ap_spawn_child");
        ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
                         "Couldn't fork child for ErrorLog process");
                     exit(1);
    }

        s->error_log = dummy;
    }

#ifdef HAVE_SYSLOG
    else if (!strncasecmp(s->error_fname, "syslog", 6)) {
    if ((fname = strchr(s->error_fname, ':'))) {
        const TRANS *fac;

        fname++;
        for (fac = facilities; fac->t_name; fac++) {
        if (!strcasecmp(fname, fac->t_name)) {
            openlog(ap_server_argv0, LOG_NDELAY|LOG_CONS|LOG_PID,
                fac->t_val);
            s->error_log = NULL;
            return;
        }
        }
    }
    else
        openlog(ap_server_argv0, LOG_NDELAY|LOG_CONS|LOG_PID, LOG_LOCAL7);

    s->error_log = NULL;
    }
#endif
    else {
    fname = ap_server_root_relative(p, s->error_fname);
    /*  Change to AP funcs. */
        if (ap_open(&s->error_log, fname, APR_APPEND |
                    APR_READ | APR_WRITE | APR_CREATE, APR_OS_DEFAULT, p) != APR_SUCCESS) {
            perror("fopen");
            ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
                         "%s: could not open error log file %s.",
                 ap_server_argv0, fname);
            exit(1);
    }
    }
}

void ap_open_logs(server_rec *s_main, ap_pool_t *p)
{
    ap_status_t rc = APR_SUCCESS;
    server_rec *virt, *q;
    int replace_stderr;
    ap_file_t *errfile = NULL;

    open_error_log(s_main, p);

    replace_stderr = 1;
    if (s_main->error_log) {
        /* replace stderr with this new log */
        ap_flush(s_main->error_log);
        ap_open_stderr(&errfile, p);
        if ((rc = ap_dupfile(&errfile, s_main->error_log)) != APR_SUCCESS) {
            ap_log_error(APLOG_MARK, APLOG_CRIT, rc, s_main,
                         "unable to replace stderr with error_log");
        } else {
            replace_stderr = 0;
        }
    }
    /* note that stderr may still need to be replaced with something
     * because it points to the old error log, or back to the tty
     * of the submitter.
     */
    if (replace_stderr && freopen("/dev/null", "w", stderr) == NULL) {
    ap_log_error(APLOG_MARK, APLOG_CRIT, errno, s_main,
        "unable to replace stderr with /dev/null");
    }

    for (virt = s_main->next; virt; virt = virt->next) {
    if (virt->error_fname) {
        for (q=s_main; q != virt; q = q->next)
        if (q->error_fname != NULL &&
            strcmp(q->error_fname, virt->error_fname) == 0)
            break;
        if (q == virt)
        open_error_log(virt, p);
        else
        virt->error_log = q->error_log;
    }
    else
        virt->error_log = s_main->error_log;
    }
}

API_EXPORT(void) ap_error_log2stderr(server_rec *s) {
    ap_file_t *errfile = NULL;

    ap_open_stderr(&errfile, s->process->pool);
    if (s->error_log != NULL) {
        ap_dupfile(&(s->error_log), errfile);
    }
}

static void log_error_core(const char *file, int line, int level,
                           ap_status_t status, const server_rec *s,
                           const request_rec *r, const char *fmt, va_list args)
{
    char errstr[MAX_STRING_LEN + 1];    /* + 1 to have room for '\n' */
    size_t len;
    ap_file_t *logf = NULL;

    if (s == NULL) {
    /*
     * If we are doing stderr logging (startup), don't log messages that are
     * above the default server log level unless it is a startup/shutdown
     * notice
     */
    if (((level & APLOG_LEVELMASK) != APLOG_NOTICE) &&
        ((level & APLOG_LEVELMASK) > DEFAULT_LOGLEVEL))
        return;
    ap_open_stderr(&logf, NULL);
    }
    else if (s->error_log) {
    /*
     * If we are doing normal logging, don't log messages that are
     * above the server log level unless it is a startup/shutdown notice
     */
    if (((level & APLOG_LEVELMASK) != APLOG_NOTICE) &&
        ((level & APLOG_LEVELMASK) > s->loglevel))
        return;
    logf = s->error_log;
    }
#ifdef TPF
    else if (tpf_child) {
    /*
     * If we are doing normal logging, don't log messages that are
     * above the server log level unless it is a startup/shutdown notice
     */
    if (((level & APLOG_LEVELMASK) != APLOG_NOTICE) &&
        ((level & APLOG_LEVELMASK) > s->loglevel))
        return;
    logf = stderr;
    }
#endif /* TPF */
    else {
    /*
     * If we are doing syslog logging, don't log messages that are
     * above the server log level (including a startup/shutdown notice)
     */
    if ((level & APLOG_LEVELMASK) > s->loglevel)
        return;
    logf = NULL;
    }

    if (logf && ((level & APLOG_STARTUP) != APLOG_STARTUP)) {
    errstr[0] = '[';
    ap_ctime(errstr + 1, ap_now());
    errstr[1 + AP_CTIME_LEN - 1] = ']';
    errstr[1 + AP_CTIME_LEN    ] = ' ';
    len = 1 + AP_CTIME_LEN + 1;
    } else {
    len = 0;
    }

    if ((level & APLOG_STARTUP) != APLOG_STARTUP) {
        len += ap_snprintf(errstr + len, MAX_STRING_LEN - len,
            "[%s] ", priorities[level & APLOG_LEVELMASK].t_name);
    }
#ifndef TPF
    if (file && (level & APLOG_LEVELMASK) == APLOG_DEBUG) {
#ifdef _OSD_POSIX
    char tmp[256];
    char *e = strrchr(file, '/');

    /* In OSD/POSIX, the compiler returns for __FILE__
     * a string like: __FILE__="*POSIX(/usr/include/stdio.h)"
     * (it even returns an absolute path for sources in
     * the current directory). Here we try to strip this
     * down to the basename.
     */
    if (e != NULL && e[1] != '\0') {
        ap_snprintf(tmp, sizeof(tmp), "%s", &e[1]);
        e = &tmp[strlen(tmp)-1];
        if (*e == ')')
        *e = '\0';
        file = tmp;
    }
#endif /*_OSD_POSIX*/
    len += ap_snprintf(errstr + len, MAX_STRING_LEN - len,
        "%s(%d): ", file, line);
    }
#endif /* TPF */
    if (r && r->connection) {
    /* XXX: TODO: add a method of selecting whether logged client
     * addresses are in dotted quad or resolved form... dotted
     * quad is the most secure, which is why I'm implementing it
     * first. -djg
     */
    len += ap_snprintf(errstr + len, MAX_STRING_LEN - len,
        "[client %s] ", r->connection->remote_ip);
    }
    /* XXX - need an APRized strerror() */
    if (!(level & APLOG_NOERRNO)
    && (status != 0)) {
    len += ap_snprintf(errstr + len, MAX_STRING_LEN - len,
        "(%d)%s: ", status, strerror(status));
    }

    len += ap_vsnprintf(errstr + len, MAX_STRING_LEN - len, fmt, args);

    /* NULL if we are logging to syslog */
    if (logf) {
        /* We know that we have one more character of space available because
         * the array is sized that way */
        /* ap_assert(len < MAX_STRING_LEN) */
        errstr[len++] = '\n';
        errstr[len] = '\0';
    ap_puts(errstr, logf);
    ap_flush(logf);
    }
#ifdef HAVE_SYSLOG
    else {
    syslog(level & APLOG_LEVELMASK, "%s", errstr);
    }
#endif
}

API_EXPORT(void) ap_log_error(const char *file, int line, int level,
                  ap_status_t status, const server_rec *s,
                              const char *fmt, ...)
{
    va_list args;

    va_start(args, fmt);
    log_error_core(file, line, level, status, s, NULL, fmt, args);
    va_end(args);
}

API_EXPORT(void) ap_log_rerror(const char *file, int line, int level,
                   ap_status_t status, const request_rec *r,
                               const char *fmt, ...)
{
    va_list args;

    va_start(args, fmt);
    log_error_core(file, line, level, status, r->server, r, fmt, args);
    /*
     * IF the error level is 'warning' or more severe,
     * AND there isn't already error text associated with this request,
     * THEN make the message text available to ErrorDocument and
     * other error processors.  This can be disabled by stuffing
     * something, even an empty string, into the "error-notes" cell
     * before calling this routine.
     */
    va_end(args);
    va_start(args,fmt);
    if (((level & APLOG_LEVELMASK) <= APLOG_WARNING)
    && (ap_table_get(r->notes, "error-notes") == NULL)) {
    ap_table_setn(r->notes, "error-notes",
              ap_escape_html(r->pool, ap_pvsprintf(r->pool, fmt,
              args)));
    }
    va_end(args);
}

void ap_log_pid(ap_pool_t *p, const char *fname)
{
    ap_file_t *pid_file = NULL;
    ap_finfo_t finfo;
    static pid_t saved_pid = -1;
    pid_t mypid;
#ifndef WIN32
    mode_t u;
#endif

    if (!fname)
    return;

    fname = ap_server_root_relative(p, fname);
    mypid = getpid();
    if (mypid != saved_pid && ap_stat(&finfo, fname, p) == APR_SUCCESS) {
      /* WINCH and HUP call this on each restart.
       * Only warn on first time through for this pid.
       *
       * XXX: Could just write first time through too, although
       *      that may screw up scripts written to do something
       *      based on the last modification time of the pid file.
       */
        ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_WARNING, 0, NULL,
             ap_psprintf(p,
                                 "pid file %s overwritten -- Unclean shutdown of previous Apache run?",
                     fname)
                   );
    }

#ifndef WIN32
    u = umask(022);
    (void) umask(u | 022);
#endif
    if(ap_open(&pid_file, fname, APR_WRITE | APR_CREATE, APR_OS_DEFAULT, p) != APR_SUCCESS) {
    perror("fopen");
        ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
                     "%s: could not log pid to file %s",
             ap_server_argv0, fname);
        exit(1);
    }
#ifndef WIN32
    (void) umask(u);
#endif
    ap_fprintf(pid_file, "%ld\n", (long)mypid);
    ap_close(pid_file);
    saved_pid = mypid;
}

API_EXPORT(void) ap_log_error_old(const char *err, server_rec *s)
{
    ap_log_error(APLOG_MARK, APLOG_ERR, errno, s, "%s", err);
}

API_EXPORT(void) ap_log_unixerr(const char *routine, const char *file,
                  const char *msg, server_rec *s)
{
    ap_log_error(file, 0, APLOG_ERR, errno, s, "%s", msg);
}

API_EXPORT(void) ap_log_printf(const server_rec *s, const char *fmt, ...)
{
    va_list args;

    va_start(args, fmt);
    log_error_core(APLOG_MARK, APLOG_ERR, errno, s, NULL, fmt, args);
    va_end(args);
}

API_EXPORT(void) ap_log_reason(const char *reason, const char *file, request_rec *r)
{
    ap_log_error(APLOG_MARK, APLOG_ERR, errno, r->server,
        "access to %s failed for %s, reason: %s",
        file,
        ap_get_remote_host(r->connection, r->per_dir_config, REMOTE_NAME),
        reason);
}

API_EXPORT(void) ap_log_assert(const char *szExp, const char *szFile, int nLine)
{
    char time_str[AP_CTIME_LEN];

    ap_ctime(time_str, ap_now());
    ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
                 "[%s] file %s, line %d, assertion \"%s\" failed",
             time_str, szFile, nLine, szExp);
#ifndef WIN32
    /* unix assert does an abort leading to a core dump */
    abort();
#else
    exit(1);
#endif
}

/* piped log support */

#ifdef HAVE_RELIABLE_PIPED_LOGS
/* forward declaration */
static void piped_log_maintenance(int reason, void *data, ap_wait_t status);

static int piped_log_spawn(piped_log *pl)
{
    int rc;
    ap_procattr_t *procattr;
    ap_os_proc_t pid;
    ap_proc_t *procnew;

    /* pjr - calls to block and unblock alarms weren't here before, was this */
    /*       an oversight or intentional?                                    */
/*  ap_block_alarms();   */

    ap_cleanup_for_exec();
#ifdef SIGHUP
    ap_signal(SIGHUP, SIG_IGN);
#endif
    if ((ap_createprocattr_init(&procattr, pl->p)         != APR_SUCCESS) ||
        (ap_setprocattr_dir(procattr, pl->program)        != APR_SUCCESS) ||
        (ap_set_childin(procattr, ap_piped_log_read_fd(pl), ap_piped_log_write_fd(pl)) != APR_SUCCESS)) {
        /* Something bad happened, give up and go away. */
    ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
        "piped_log_spawn: unable to exec '%s': %s",
        pl->program, strerror (errno));
        rc = -1;
    }
    else {
        rc = ap_create_process(&procnew, pl->program, NULL, NULL, procattr, pl->p);

        if (rc == APR_SUCCESS) {            /* pjr - This no longer happens inside the child, */
            RAISE_SIGSTOP(PIPED_LOG_SPAWN); /*   I am assuming that if ap_create_process was  */
                                            /*   successful that the child is running.        */
            pl->pid = procnew;
            ap_get_os_proc(&pid, procnew);
            ap_register_other_child(pid, piped_log_maintenance, pl, ap_piped_log_write_fd(pl));
        }
    }

/*  ap_unblock_alarms(); */

    return 0;
}


static void piped_log_maintenance(int reason, void *data, ap_wait_t status)
{
    piped_log *pl = data;

    switch (reason) {
    case OC_REASON_DEATH:
    case OC_REASON_LOST:
    pl->pid = NULL;
    ap_unregister_other_child(pl);
    if (pl->program == NULL) {
        /* during a restart */
        break;
    }
    if (piped_log_spawn(pl) != APR_SUCCESS) {
        /* what can we do?  This could be the error log we're having
         * problems opening up... */
        ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
        "piped_log_maintenance: unable to respawn '%s': %s",
        pl->program, strerror(errno));
    }
    break;

    case OC_REASON_UNWRITABLE:
    if (pl->pid != NULL) {
        ap_kill(pl->pid, SIGTERM);
    }
    break;

    case OC_REASON_RESTART:
    pl->program = NULL;
    if (pl->pid != NULL) {
        ap_kill(pl->pid, SIGTERM);
    }
    break;

    case OC_REASON_UNREGISTER:
    break;
    }
}


static ap_status_t piped_log_cleanup(void *data)
{
    piped_log *pl = data;

    if (pl->pid != NULL) {
    ap_kill(pl->pid, SIGTERM);
    }
    ap_unregister_other_child(pl);
    ap_close(ap_piped_log_read_fd(pl));
    ap_close(ap_piped_log_write_fd(pl));
    return APR_SUCCESS;
}


static ap_status_t piped_log_cleanup_for_exec(void *data)
{
    piped_log *pl = data;

    ap_close(ap_piped_log_read_fd(pl));
    ap_close(ap_piped_log_write_fd(pl));
    return APR_SUCCESS;
}

API_EXPORT(piped_log *) ap_open_piped_log(ap_pool_t *p, const char *program)
{
    piped_log *pl;

    pl = ap_palloc(p, sizeof (*pl));
    pl->p = p;
    pl->program = ap_pstrdup(p, program);
    pl->pid = NULL;
    if (ap_create_pipe(&ap_piped_log_read_fd(pl), &ap_piped_log_write_fd(pl), p) != APR_SUCCESS) {
    int save_errno = errno;
    errno = save_errno;
    return NULL;
    }
    ap_register_cleanup(p, pl, piped_log_cleanup, piped_log_cleanup_for_exec);
    if (piped_log_spawn(pl) == -1) {
    int save_errno = errno;
    ap_kill_cleanup(p, pl, piped_log_cleanup);
    ap_close(ap_piped_log_read_fd(pl));
    ap_close(ap_piped_log_write_fd(pl));
    errno = save_errno;
    return NULL;
    }
    return pl;
}

#else

static ap_status_t piped_log_cleanup(void *data)
{
    piped_log *pl = data;

    ap_close(ap_piped_log_write_fd(pl));
    return APR_SUCCESS;
}

API_EXPORT(piped_log *) ap_open_piped_log(ap_pool_t *p, const char *program)
{
    piped_log *pl;
    ap_file_t *dummy = NULL;
    int rc;

    rc = log_child(p, program, &dummy);
    if (rc != APR_SUCCESS) {
    perror("ap_spawn_child");
    ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,
                     "Couldn't fork child for piped log process");
    exit (1);
    }

    pl = ap_palloc(p, sizeof (*pl));
    pl->p = p;
    ap_piped_log_read_fd(pl) = NULL;
    ap_piped_log_write_fd(pl) = dummy;
    ap_register_cleanup(p, pl, piped_log_cleanup, piped_log_cleanup);

    return pl;
}

#endif

API_EXPORT(void) ap_close_piped_log(piped_log *pl)
{
    ap_run_cleanup(pl->p, pl, piped_log_cleanup);
}