mirror of
https://github.com/apache/httpd.git
synced 2025-08-20 16:09:55 +00:00
9d1a70c8d5
for future additions. git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@85372 13f79535-47bb-0310-9956-ffa450edef68
216 lines
7.7 KiB
C
216 lines
7.7 KiB
C
/* ====================================================================
|
|
* 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.
|
|
*/
|
|
|
|
/* The purpose of this file is to store the code that MOST mpm's will need
|
|
* this does not mean a function only goes into this file if every MPM needs
|
|
* it. It means that if a function is needed by more than one MPM, and
|
|
* future maintenance would be served by making the code common, then the
|
|
* function belongs here.
|
|
*
|
|
* This is going in src/main because it is not platform specific, it is
|
|
* specific to multi-process servers, but NOT to Unix. Which is why it
|
|
* does not belong in src/os/unix
|
|
*/
|
|
|
|
#include "apr_thread_proc.h"
|
|
#include "httpd.h"
|
|
#include "http_config.h"
|
|
#include "http_log.h"
|
|
#include "mpm.h"
|
|
#include "mpm_common.h"
|
|
|
|
#if defined(DEXTER_MPM) || defined(MPMT_BEOS_MPM)
|
|
#define CHILD_TABLE 1
|
|
#define CHILD_INFO_TABLE ap_child_table
|
|
#elif defined(MPMT_PTHREAD_MPM) || defined (PREFORK_MPM)
|
|
#define SCOREBOARD 1
|
|
#define CHILD_INFO_TABLE ap_scoreboard_image->parent
|
|
#endif
|
|
|
|
|
|
#ifdef CHILD_INFO_TABLE
|
|
void ap_reclaim_child_processes(int terminate)
|
|
{
|
|
int i, status;
|
|
long int waittime = 1024 * 16; /* in usecs */
|
|
struct timeval tv;
|
|
int waitret, tries;
|
|
int not_dead_yet;
|
|
|
|
#ifdef SCOREBOARD
|
|
ap_sync_scoreboard_image();
|
|
#endif
|
|
|
|
for (tries = terminate ? 4 : 1; tries <= 9; ++tries) {
|
|
/* don't want to hold up progress any more than
|
|
* necessary, but we need to allow children a few moments to exit.
|
|
* Set delay with an exponential backoff.
|
|
*/
|
|
tv.tv_sec = waittime / 1000000;
|
|
tv.tv_usec = waittime % 1000000;
|
|
waittime = waittime * 4;
|
|
ap_select(0, NULL, NULL, NULL, &tv);
|
|
|
|
/* now see who is done */
|
|
not_dead_yet = 0;
|
|
for (i = 0; i < ap_max_daemons_limit; ++i) {
|
|
pid_t pid = CHILD_INFO_TABLE[i].pid;
|
|
|
|
#ifdef CHILD_TABLE
|
|
if (ap_child_table[i].status == SERVER_DEAD)
|
|
#elif defined(SCOREBOARD)
|
|
if (pid == ap_my_pid || pid == 0)
|
|
#endif
|
|
continue;
|
|
|
|
waitret = waitpid(pid, &status, WNOHANG);
|
|
if (waitret == pid || waitret == -1) {
|
|
#ifdef CHILD_TABLE
|
|
ap_child_table[i].status = SERVER_DEAD;
|
|
#elif defined(SCOREBOARD)
|
|
ap_scoreboard_image->parent[i].pid = 0;
|
|
#endif
|
|
continue;
|
|
}
|
|
++not_dead_yet;
|
|
switch (tries) {
|
|
case 1: /* 16ms */
|
|
case 2: /* 82ms */
|
|
break;
|
|
case 3: /* 344ms */
|
|
case 4: /* 16ms */
|
|
case 5: /* 82ms */
|
|
case 6: /* 344ms */
|
|
case 7: /* 1.4sec */
|
|
/* ok, now it's being annoying */
|
|
ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_WARNING,
|
|
0, ap_server_conf,
|
|
"child process %ld still did not exit, sending a SIGTERM",
|
|
(long)pid);
|
|
kill(pid, SIGTERM);
|
|
break;
|
|
case 8: /* 6 sec */
|
|
/* die child scum */
|
|
ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ERR,
|
|
0, ap_server_conf,
|
|
"child process %ld still did not exit, sending a SIGKILL",
|
|
(long)pid);
|
|
kill(pid, SIGKILL);
|
|
break;
|
|
case 9: /* 14 sec */
|
|
/* gave it our best shot, but alas... If this really
|
|
* is a child we are trying to kill and it really hasn't
|
|
* exited, we will likely fail to bind to the port
|
|
* after the restart.
|
|
*/
|
|
ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ERR,
|
|
0, ap_server_conf,
|
|
"could not make child process %ld exit, "
|
|
"attempting to continue anyway", (long)pid);
|
|
break;
|
|
}
|
|
}
|
|
ap_check_other_child();
|
|
if (!not_dead_yet) {
|
|
/* nothing left to wait for */
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
#endif
|
|
|
|
/* number of calls to wait_or_timeout between writable probes */
|
|
#ifndef INTERVAL_OF_WRITABLE_PROBES
|
|
#define INTERVAL_OF_WRITABLE_PROBES 10
|
|
#endif
|
|
static int wait_or_timeout_counter;
|
|
|
|
void ap_wait_or_timeout(ap_wait_t *status, ap_proc_t *ret, ap_pool_t *p)
|
|
{
|
|
struct timeval tv;
|
|
ap_status_t rv;
|
|
|
|
++wait_or_timeout_counter;
|
|
if (wait_or_timeout_counter == INTERVAL_OF_WRITABLE_PROBES) {
|
|
wait_or_timeout_counter = 0;
|
|
#ifdef APR_HAS_OTHER_CHILD
|
|
ap_probe_writable_fds();
|
|
#endif
|
|
}
|
|
rv = ap_wait_all_procs(ret, status, APR_NOWAIT, p);
|
|
if (ap_canonical_error(rv) == APR_EINTR) {
|
|
ret->pid = -1;
|
|
return;
|
|
}
|
|
if (rv == APR_CHILD_DONE) {
|
|
return;
|
|
}
|
|
#ifdef NEED_WAITPID
|
|
if ((ret = reap_children(status)) > 0) {
|
|
return;
|
|
}
|
|
#endif
|
|
tv.tv_sec = SCOREBOARD_MAINTENANCE_INTERVAL / 1000000;
|
|
tv.tv_usec = SCOREBOARD_MAINTENANCE_INTERVAL % 1000000;
|
|
ap_select(0, NULL, NULL, NULL, &tv);
|
|
ret->pid = -1;
|
|
return;
|
|
}
|
|
|
|
|