5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define CORE_PRIVATE

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define INCL_DOS

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define INCL_DOSERRORS

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "ap_config.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "httpd.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "mpm_default.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "http_main.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "http_log.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "http_config.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "http_core.h" /* for get_remote_host */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "http_connection.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "mpm.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "ap_mpm.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "ap_listen.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "apr_portable.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include "mpm_common.h"

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann#include "apr_strings.h"

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include <os2.h>

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include <stdlib.h>

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include <sys/signal.h>

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include <process.h>

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann#include <time.h>

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#include <io.h>

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int ap_max_requests_per_child=0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic char *ap_pid_fname=NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int ap_daemons_to_start=0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int ap_daemons_min_free=0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int ap_daemons_max_free=0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int ap_daemons_limit=0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int max_daemons_limit = -1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannint ap_threads_per_child = HARD_THREAD_LIMIT;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannap_generation_t volatile ap_my_generation=0; /* Used by the scoreboard */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannchar ap_coredump_dir[MAX_STRING_LEN];

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannserver_rec *ap_server_conf;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int one_process = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic apr_pool_t *pconf; /* Pool for config stuff */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstruct thread_globals {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int thread_num;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_t *pchild; /* Pool for httpd child stuff */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int usr1_just_die;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann};

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic struct thread_globals **ppthread_globals = NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define THREAD_GLOBAL(gvar) ((*ppthread_globals)->gvar)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstruct thread_control_t {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_wait_t thread_retval;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann char deferred_die;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_generation_t generation; /* generation of this thread */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann} thread_control[HARD_THREAD_LIMIT];

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void clean_child_exit(int code)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (THREAD_GLOBAL(pchild)) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_destroy(THREAD_GLOBAL(pchild));

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].deferred_die = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].thread_retval = code;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann _endthread();

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmannstatic apr_lock_t *accept_mutex = NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic apr_status_t accept_mutex_child_cleanup(void *foo)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return apr_lock_release(accept_mutex);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void accept_mutex_child_init(apr_pool_t *p)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_cleanup_register(p, NULL, accept_mutex_child_cleanup, apr_pool_cleanup_null);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void accept_mutex_init(apr_pool_t *p)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_status_t rc = apr_lock_create(&accept_mutex, APR_MUTEX, APR_INTRAPROCESS, NULL, p);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (rc != APR_SUCCESS) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_EMERG, rc, ap_server_conf,

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann "Error creating accept lock. Exiting!");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann clean_child_exit(APEXIT_CHILDFATAL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void accept_mutex_on(void)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_status_t rc = apr_lock_acquire(accept_mutex);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (rc != APR_SUCCESS) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_EMERG, rc, ap_server_conf,

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann "Error getting accept lock. Exiting!");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann clean_child_exit(APEXIT_CHILDFATAL);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmannstatic void accept_mutex_off(void)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_status_t rc = apr_lock_release(accept_mutex);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (rc != APR_SUCCESS) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_EMERG, rc, ap_server_conf,

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann "Error freeing accept lock. Exiting!");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann clean_child_exit(APEXIT_CHILDFATAL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SINGLE_LISTEN_UNSERIALIZED_ACCEPT

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define SAFE_ACCEPT(stmt) do {if (ap_listeners->next) {stmt;}} while(0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#else

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define SAFE_ACCEPT(stmt) do {stmt;} while(0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int find_thread_by_tid(int tid)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int i;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann for (i = 0; i < max_daemons_limit; ++i)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (ap_scoreboard_image->servers[0][i].tid == tid)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return i;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return -1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifndef INTERVAL_OF_WRITABLE_PROBES

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#define INTERVAL_OF_WRITABLE_PROBES 10

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int wait_or_timeout_counter;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int wait_or_timeout(apr_wait_t *status)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int ret;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ULONG tid;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ++wait_or_timeout_counter;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (wait_or_timeout_counter == INTERVAL_OF_WRITABLE_PROBES) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann wait_or_timeout_counter = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#if APR_HAS_OTHER_CHILD

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_proc_probe_writable_fds();

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann tid = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ret = DosWaitThread(&tid, DCWW_NOWAIT);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (ret == 0) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int thread_num = find_thread_by_tid(tid);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_assert( thread_num > 0 );

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann *status = thread_control[thread_num].thread_retval;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return tid;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann DosSleep(SCOREBOARD_MAINTENANCE_INTERVAL / 1000);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return -1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void sig_coredump(int sig)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann chdir(ap_coredump_dir);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(sig, SIG_DFL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann kill(getpid(), sig);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* At this point we've got sig blocked, because we're still inside

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void just_die(int sig)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann clean_child_exit(0);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void usr1_handler(int sig)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (THREAD_GLOBAL(usr1_just_die)) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann just_die(sig);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].deferred_die = 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int volatile shutdown_pending;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int volatile restart_pending;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int volatile is_graceful;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void sig_term(int sig)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (shutdown_pending == 1) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* Um, is this _probably_ not an error, if the user has

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann shutdown_pending = 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void restart(int sig)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (restart_pending == 1) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* Probably not an error - don't bother reporting it */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann restart_pending = 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann is_graceful = sig == SIGUSR1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void set_signals(void)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifndef NO_USE_SIGACTION

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann struct sigaction sa;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sigemptyset(&sa.sa_mask);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_flags = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (!one_process) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = sig_coredump;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#if defined(SA_ONESHOT)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_flags = SA_ONESHOT;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#elif defined(SA_RESETHAND)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_flags = SA_RESETHAND;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGSEGV, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGSEGV)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGBUS

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGBUS, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGBUS)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGABORT

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGABORT, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGABORT)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGABRT

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGABRT, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGABRT)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGILL

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGILL, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGILL)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_flags = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = sig_term;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGTERM, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGTERM)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGINT

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (sigaction(SIGINT, &sa, NULL) < 0)

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGINT)");

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGXCPU

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = SIG_DFL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGXCPU, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGXCPU)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGXFSZ

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = SIG_DFL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGXFSZ, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGXFSZ)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGPIPE

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = SIG_IGN;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGPIPE, &sa, NULL) < 0)

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGPIPE)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* we want to ignore HUPs and USR1 while we're busy processing one */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sigaddset(&sa.sa_mask, SIGHUP);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sigaddset(&sa.sa_mask, SIGUSR1);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann sa.sa_handler = restart;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGHUP, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGHUP)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (sigaction(SIGUSR1, &sa, NULL) < 0)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_WARNING, errno, ap_server_conf, "sigaction(SIGUSR1)");

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#else

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (!one_process) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGSEGV, sig_coredump);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGBUS

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGBUS, sig_coredump);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGBUS */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGABORT

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGABORT, sig_coredump);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGABORT */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGABRT

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGABRT, sig_coredump);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGABRT */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGILL

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGILL, sig_coredump);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGILL */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGXCPU

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGXCPU, SIG_DFL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGXCPU */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGXFSZ

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGXFSZ, SIG_DFL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGXFSZ */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGTERM, sig_term);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGHUP

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGHUP, restart);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGHUP */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGUSR1

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGUSR1, restart);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGUSR1 */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#ifdef SIGPIPE

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGPIPE, SIG_IGN);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann#endif /* SIGPIPE */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann#endif

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel HoltmannAP_DECLARE(void) ap_child_terminate(request_rec *r)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann r->connection->keepalive = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].deferred_die = 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmannint ap_graceful_stop_signalled(void)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (thread_control[THREAD_GLOBAL(thread_num)].deferred_die ||

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_scoreboard_image->global.running_generation != thread_control[THREAD_GLOBAL(thread_num)].generation) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannint ap_stop_signalled(void)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (shutdown_pending || restart_pending ||

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].deferred_die ||

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_scoreboard_image->global.running_generation != thread_control[THREAD_GLOBAL(thread_num)].generation) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann return 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic int setup_listen_poll(apr_pool_t *pchild, apr_pollfd_t **listen_poll)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_listen_rec *lr;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int numfds = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann for (lr = ap_listeners; lr; lr = lr->next) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann numfds++;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_poll_setup(listen_poll, numfds, pchild);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann for (lr = ap_listeners; lr; lr = lr->next) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_poll_socket_add(*listen_poll, lr->sd, APR_POLLIN);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann return 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann}

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmannstatic void thread_main(void *thread_num_arg)

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann{

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_listen_rec *lr = NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_listen_rec *first_lr = NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_t *ptrans;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann conn_rec *current_conn;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_t *pchild;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int requests_this_child = 0;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pollfd_t *listen_poll;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_socket_t *csd = NULL;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int nsds, rv;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* Disable the restart signal handlers and enable the just_die stuff.

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann set_signals(); /* signals aren't inherrited by child threads */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGHUP, just_die);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGUSR1, just_die);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGTERM, just_die);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* Get a sub pool for global allocations in this child, so that

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_pool_create(&pchild, pconf);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann *ppthread_globals = (struct thread_globals *)apr_palloc(pchild, sizeof(struct thread_globals));

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann THREAD_GLOBAL(thread_num) = (int)thread_num_arg;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann THREAD_GLOBAL(pchild) = pchild;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann thread_control[THREAD_GLOBAL(thread_num)].generation = ap_scoreboard_image->global.running_generation;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann apr_pool_create(&ptrans, pchild);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann if (setup_listen_poll(pchild, &listen_poll)) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann clean_child_exit(1);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann }

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* needs to be done before we switch UIDs so we have permissions */

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann SAFE_ACCEPT(accept_mutex_child_init(pchild));

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann ap_run_child_init(pchild, ap_server_conf);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann (void) ap_update_child_status(0, THREAD_GLOBAL(thread_num), SERVER_READY, (request_rec *) NULL);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGHUP, just_die);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGTERM, just_die);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann while (!ap_stop_signalled()) {

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann int srv;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann apr_socket_t *sd;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /* Prepare to receive a SIGUSR1 due to graceful restart so that

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann THREAD_GLOBAL(usr1_just_die) = 1;

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann signal(SIGUSR1, usr1_handler);

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann

94f5bbc626f2a4102debd9b17c964170a887cb49Marcel Holtmann /*

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann current_conn = NULL;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann apr_pool_clear(ptrans);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if ((ap_max_requests_per_child > 0

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann && requests_this_child++ >= ap_max_requests_per_child)) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(0);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann (void) ap_update_child_status(0, THREAD_GLOBAL(thread_num), SERVER_READY, (request_rec *) NULL);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /*

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* Lock around "accept", if necessary */

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann SAFE_ACCEPT(accept_mutex_on());

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (ap_stop_signalled()) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(0);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann for (;;) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (ap_listeners->next) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* more than one socket */

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann srv = apr_poll(listen_poll, &nsds, -1);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (srv != APR_SUCCESS) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* Single Unix documents select as returning errnos

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_log_error(APLOG_MARK, APLOG_ERR, errno, ap_server_conf, "select: (listen)");

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(1);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* we remember the last_lr we searched last time around so that

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (first_lr == NULL) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann first_lr = ap_listeners;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann lr = first_lr;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann do {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann apr_int16_t event;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (!lr) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann lr = ap_listeners;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann apr_poll_revents_get(&event, lr->sd, listen_poll);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (event == APR_POLLIN) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann first_lr = lr->next;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann break;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann lr = lr->next;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann } while (lr != first_lr);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (lr == first_lr) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann continue;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann sd = lr->sd;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann else {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* only one socket, just pretend we did the other stuff */

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann sd = ap_listeners->sd;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* if we accept() something we don't want to die, so we have to

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann THREAD_GLOBAL(usr1_just_die) = 0;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann rv = apr_accept(&csd, sd, ptrans);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (APR_STATUS_IS_SUCCESS(rv)) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann break; /* We have a socket ready for reading */

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann else if (APR_STATUS_IS_ECONNABORTED(rv)

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann || APR_STATUS_IS_ECONNRESET(rv)

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann || APR_STATUS_IS_ETIMEDOUT(rv)

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann || APR_STATUS_IS_EHOSTUNREACH(rv)

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann || APR_STATUS_IS_ENETUNREACH(rv)) {

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann /* Our old behaviour here was to continue after accept()

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* Linux generates most of these, other tcp

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann break;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann else if (APR_STATUS_IS_EINTR(rv)) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* We only get hit by an EINTR if the parent is

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(0);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann else {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_log_error(APLOG_MARK, APLOG_ERR, rv, ap_server_conf,

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann "accept: (client socket)");

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(1);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (ap_stop_signalled()) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(0);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann THREAD_GLOBAL(usr1_just_die) = 1;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann SAFE_ACCEPT(accept_mutex_off()); /* unlock after "accept" */

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /* We've got a socket, let's at least process one request off the

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGUSR1, SIG_IGN);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann /*

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_sock_disable_nagle(csd);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann current_conn = ap_new_connection(ptrans, ap_server_conf, csd,

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann THREAD_GLOBAL(thread_num));

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (current_conn) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_process_connection(current_conn);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_lingering_close(current_conn);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann clean_child_exit(0);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann}

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmannstatic int make_child(server_rec *s, int slot)

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann{

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann TID tid;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (slot + 1 > max_daemons_limit) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann max_daemons_limit = slot + 1;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann if (one_process) {

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann struct thread_globals *parent_globals = *ppthread_globals;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGHUP, just_die);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGINT, just_die);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann#ifdef SIGQUIT

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGQUIT, SIG_DFL);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann#endif

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann signal(SIGTERM, just_die);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann thread_main((void *)slot);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann *ppthread_globals = parent_globals;

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann }

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann ap_update_child_status(0, slot, SERVER_STARTING, (request_rec *) NULL);

5476ad087c0f2d45ab0dab1bab9ef3e9d70418bcMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if ((tid = _beginthread(thread_main, NULL, 256*1024, (void *)slot)) == -1) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ap_log_error(APLOG_MARK, APLOG_ERR|APLOG_NOERRNO, 0, s, "_beginthread: Unable to create new thread");

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* _beginthread didn't succeed. Fix the scoreboard or else

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann (void) ap_update_child_status(0, slot, SERVER_DEAD, (request_rec *) NULL);

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* In case system resources are maxxed out, we don't want

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann sleep(10);

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann return -1;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ap_scoreboard_image->servers[0][slot].tid = tid;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann return 0;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann}

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmannstatic void startup_children(int number_to_start)

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann{

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int i;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann for (i = 0; number_to_start && i < ap_daemons_limit; ++i) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (ap_scoreboard_image->servers[0][i].status != SERVER_DEAD) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann continue;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (make_child(ap_server_conf, i) < 0) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann break;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann --number_to_start;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann}

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmannstatic int idle_spawn_rate = 1;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann#ifndef MAX_SPAWN_RATE

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann#define MAX_SPAWN_RATE (32)

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann#endif

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmannstatic int hold_off_on_exponential_spawning;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmannstatic void perform_idle_server_maintenance(void)

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann{

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int i;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int to_kill;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int idle_count;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann short_score *ss;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int free_length;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int free_slots[MAX_SPAWN_RATE];

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int last_non_dead;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int total_non_dead;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* initialize the free_list */

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann free_length = 0;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann to_kill = -1;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann idle_count = 0;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann last_non_dead = -1;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann total_non_dead = 0;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann for (i = 0; i < ap_daemons_limit; ++i) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann int status;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (i >= max_daemons_limit && free_length == idle_spawn_rate)

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann break;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ss = &ap_scoreboard_image->servers[0][i];

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann status = ss->status;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (status == SERVER_DEAD) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* try to keep children numbers as low as possible */

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (free_length < idle_spawn_rate) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann free_slots[free_length] = i;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ++free_length;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann else {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* We consider a starting server as idle because we started it

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann if (status <= SERVER_READY) {

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ++ idle_count;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann /* always kill the highest numbered child if we have to...

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann to_kill = i;

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann }

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann

c6f3f5b4b3ec439ae911ca0644237d96fd31893eMarcel Holtmann ++total_non_dead;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann last_non_dead = i;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann }

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann }

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann max_daemons_limit = last_non_dead + 1;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann if (idle_count > ap_daemons_max_free) {

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann /* kill off one child... we use SIGUSR1 because that'll cause it to

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann thread_control[to_kill].deferred_die = 1;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann idle_spawn_rate = 1;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann }

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann else if (idle_count < ap_daemons_min_free) {

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann /* terminate the free list */

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann if (free_length == 0) {

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann /* only report this condition once */

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann static int reported = 0;

0234c599218518b1eb478d64d9883ba46e4ce5d8Marcel Holtmann

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann if (!reported) {

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ERR, 0, ap_server_conf,

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann "server reached MaxClients setting, consider"

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann " raising the MaxClients setting");

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann reported = 1;

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann }

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann idle_spawn_rate = 1;

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann }

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann else {

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann if (idle_spawn_rate >= 8) {

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_INFO, 0, ap_server_conf,

c4a3a17ee919e8b1197328394709edfe36d8b710Marcel Holtmann "server seems busy, (you may need "

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann "to increase StartServers, or Min/MaxSpareServers), "

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann "spawning %d children, there are %d idle, and "

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann "%d total children", idle_spawn_rate,

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann idle_count, total_non_dead);

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann }

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann for (i = 0; i < free_length; ++i) {

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann make_child(ap_server_conf, free_slots[i]);

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann }

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann /* the next time around we want to spawn twice as many if this

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann if (hold_off_on_exponential_spawning) {

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann --hold_off_on_exponential_spawning;

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann }

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann else if (idle_spawn_rate < MAX_SPAWN_RATE) {

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann idle_spawn_rate *= 2;

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann }

43d9c2b5848b1363b659c38443c1c94db57415fdMarcel Holtmann }

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann }

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann else {

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann idle_spawn_rate = 1;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann }

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann}

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel HoltmannAP_DECLARE(apr_status_t) ap_mpm_query(int query_code, int *result)

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann{

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann switch(query_code){

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann case AP_MPMQ_MAX_DAEMONS:

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann *result = max_daemons_limit;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann return APR_SUCCESS;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann case AP_MPMQ_IS_THREADED:

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann *result = 1;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann return APR_SUCCESS;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann case AP_MPMQ_IS_FORKED:

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann *result = 0;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann return APR_SUCCESS;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann }

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann return APR_ENOTIMPL;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann}

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmannint ap_mpm_run(apr_pool_t *_pconf, apr_pool_t *plog, server_rec *s)

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann{

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann int remaining_children_to_start;

4b28cdeb2332cfbd3f5172b43a2f5f534b7e6e57Marcel Holtmann int i;

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann apr_status_t status;

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann pconf = _pconf;

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann ap_server_conf = s;

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann ap_log_pid(pconf, ap_pid_fname);

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann if ((status = ap_listen_open(s->process, s->port)) != APR_SUCCESS) {

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ALERT, status, s,

e525326bd07ebf3cabcfd730bc479166723f2d44Marcel Holtmann "no listening sockets available, shutting down");

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann return -1;

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann }

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann SAFE_ACCEPT(accept_mutex_init(pconf));

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann if (!is_graceful) {

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann ap_create_scoreboard(pconf, SB_NOT_SHARED);

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann memset(thread_control, 0, sizeof(thread_control));

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann }

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann set_signals();

f401e2b24ba17452f9655993a6dedefdffe06d23Marcel Holtmann

if (ppthread_globals == NULL) {

if (DosAllocThreadLocalMemory(1, (PULONG *)&ppthread_globals)) {

ap_log_error(APLOG_MARK, APLOG_ALERT|APLOG_NOERRNO, 0, ap_server_conf,

"Error allocating thread local storage"

"Apache is exiting!");

} else {

*ppthread_globals = (struct thread_globals *)apr_palloc(pconf, sizeof(struct thread_globals));

}

}

if (ap_daemons_max_free < ap_daemons_min_free + 1) /* Don't thrash... */

ap_daemons_max_free = ap_daemons_min_free + 1;

/* If we're doing a graceful_restart then we're going to see a lot

remaining_children_to_start = ap_daemons_to_start;

if (remaining_children_to_start > ap_daemons_limit) {

remaining_children_to_start = ap_daemons_limit;

}

if (!is_graceful) {

startup_children(remaining_children_to_start);

remaining_children_to_start = 0;

}

else {

/* give the system some time to recover before kicking into

hold_off_on_exponential_spawning = 10;

}

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_NOTICE, 0, ap_server_conf,

"%s configured -- resuming normal operations",

ap_get_server_version());

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_INFO, 0, ap_server_conf,

"Server built: %s", ap_get_server_built());

restart_pending = shutdown_pending = 0;

printf("%s \n", ap_get_server_version());

while (!restart_pending && !shutdown_pending) {

int thread_slot;

apr_wait_t status;

int tid = wait_or_timeout(&status);

/* XXX: if it takes longer than 1 second for all our children

if (tid >= 0) {

apr_proc_t dummyproc;

dummyproc.pid = tid;

ap_process_child_status(&dummyproc, status);

/* non-fatal death... note that it's gone in the scoreboard. */

thread_slot = find_thread_by_tid(tid);

if (thread_slot >= 0) {

(void) ap_update_child_status(0, thread_slot, SERVER_DEAD,

(request_rec *) NULL);

if (remaining_children_to_start

&& thread_slot < ap_daemons_limit) {

/* we're still doing a 1-for-1 replacement of dead

make_child(ap_server_conf, thread_slot);

--remaining_children_to_start;

}

#if APR_HAS_OTHER_CHILD

#endif

}

else if (is_graceful) {

/* Great, we've probably just lost a slot in the

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_WARNING, 0, ap_server_conf,

"long lost child came home! (tid %d)", tid);

}

/* Don't perform idle maintenance when a child dies,

continue;

}

else if (remaining_children_to_start) {

/* we hit a 1 second timeout in which none of the previous

startup_children(remaining_children_to_start);

remaining_children_to_start = 0;

/* In any event we really shouldn't do the code below because

continue;

}

perform_idle_server_maintenance();

}

if (shutdown_pending) {

/* Time to gracefully shut down */

const char *pidfile = NULL;

int slot;

TID tid;

ULONG rc;

ap_listen_rec *lr;

for (lr = ap_listeners; lr; lr = lr->next) {

apr_socket_close(lr->sd);

DosSleep(0);

}

/* Kill off running threads */

for (slot=0; slot<max_daemons_limit; slot++) {

if (ap_scoreboard_image->servers[0][slot].status != SERVER_DEAD) {

tid = ap_scoreboard_image->servers[0][slot].tid;

rc = DosKillThread(tid);

if (rc != ERROR_INVALID_THREADID) { // Already dead, ignore

if (rc == 0) {

rc = DosWaitThread(&tid, DCWW_WAIT);

if (rc) {

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_WARNING, 0, ap_server_conf,

"error %lu waiting for thread to terminate", rc);

}

} else {

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_WARNING, 0, ap_server_conf,

"error %lu killing thread", rc);

}

}

}

}

/* cleanup pid file on normal shutdown */

pidfile = ap_server_root_relative (pconf, ap_pid_fname);

if ( pidfile != NULL && unlink(pidfile) == 0)

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_INFO, 0,

ap_server_conf,

"removed PID file %s (pid=%ld)",

pidfile, (long)getpid());

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_NOTICE, 0, ap_server_conf,

"caught SIGTERM, shutting down");

return 1;

}

/* we've been told to restart */

signal(SIGHUP, SIG_IGN);

signal(SIGUSR1, SIG_IGN);

if (one_process) {

/* not worth thinking about */

return 1;

}

/* advance to the next generation */

/* XXX: we really need to make sure this new generation number isn't in

++ap_scoreboard_image->global.running_generation;

if (is_graceful) {

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_NOTICE, 0, ap_server_conf,

"SIGUSR1 received. Doing graceful restart");

/* kill off the idle ones */

for (i = 0; i < ap_daemons_limit; ++i) {

thread_control[i].deferred_die = 1;

}

/* This is mostly for debugging... so that we know what is still

for (i = 0; i < ap_daemons_limit; ++i) {

if (ap_scoreboard_image->servers[0][i].status != SERVER_DEAD) {

ap_scoreboard_image->servers[0][i].status = SERVER_GRACEFUL;

}

}

}

else {

/* Kill 'em off */

for (i = 0; i < ap_daemons_limit; ++i) {

DosKillThread(ap_scoreboard_image->servers[0][i].tid);

}

ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_NOTICE, 0, ap_server_conf,

"SIGHUP received. Attempting to restart");

}

return 0;

}

static void spmt_os2_pre_config(apr_pool_t *pconf, apr_pool_t *plog, apr_pool_t *ptemp)

{

one_process = !!ap_exists_config_define("ONE_PROCESS");

is_graceful = 0;

ap_listen_pre_config();

ap_daemons_to_start = DEFAULT_START_DAEMON;

ap_daemons_min_free = DEFAULT_MIN_FREE_DAEMON;

ap_daemons_max_free = DEFAULT_MAX_FREE_DAEMON;

ap_daemons_limit = HARD_THREAD_LIMIT;

ap_pid_fname = DEFAULT_PIDLOG;

ap_max_requests_per_child = DEFAULT_MAX_REQUESTS_PER_CHILD;

ap_extended_status = 0;

ap_scoreboard_fname = NULL;

apr_cpystrn(ap_coredump_dir, ap_server_root, sizeof(ap_coredump_dir));

}

static void spmt_os2_hooks(apr_pool_t *p)

{

/* TODO: set one_process properly */ one_process = 0;

ap_hook_pre_config(spmt_os2_pre_config, NULL, NULL, APR_HOOK_MIDDLE);

}

static const char *set_pidfile(cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

if (cmd->server->is_virtual) {

return "PidFile directive not allowed in <VirtualHost>";

}

ap_pid_fname = arg;

return NULL;

}

static const char *set_daemons_to_start(cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

ap_daemons_to_start = atoi(arg);

return NULL;

}

static const char *set_min_free_servers(cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

ap_daemons_min_free = atoi(arg);

if (ap_daemons_min_free <= 0) {

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

"WARNING: detected MinSpareServers set to non-positive.");

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

"Resetting to 1 to avoid almost certain Apache failure.");

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

"Please read the documentation.");

ap_daemons_min_free = 1;

}

return NULL;

}

static const char *set_max_free_servers(cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

ap_daemons_max_free = atoi(arg);

return NULL;

}

static const char *set_server_limit (cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

ap_daemons_limit = atoi(arg);

if (ap_daemons_limit > HARD_THREAD_LIMIT) {

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

"WARNING: MaxClients of %d exceeds compile time limit "

"of %d servers,", ap_daemons_limit, HARD_THREAD_LIMIT);

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

" lowering MaxClients to %d. To increase, please "

"see the", HARD_THREAD_LIMIT);

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

" HARD_THREAD_LIMIT define in %s.",

AP_MPM_HARD_LIMITS_FILE);

ap_daemons_limit = HARD_THREAD_LIMIT;

}

else if (ap_daemons_limit < 1) {

ap_log_error(APLOG_MARK, APLOG_STARTUP | APLOG_NOERRNO, 0, NULL,

"WARNING: Require MaxClients > 0, setting to 1");

ap_daemons_limit = 1;

}

return NULL;

}

static const char *set_max_requests(cmd_parms *cmd, void *dummy, char *arg)

{

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

ap_max_requests_per_child = atoi(arg);

return NULL;

}

static const char *set_coredumpdir (cmd_parms *cmd, void *dummy, char *arg)

{

apr_finfo_t finfo;

const char *fname;

const char *err = ap_check_cmd_context(cmd, GLOBAL_ONLY);

if (err != NULL) {

return err;

}

fname = ap_server_root_relative(cmd->pool, arg);

if ((apr_stat(&finfo, fname, APR_FINFO_TYPE, cmd->pool) != APR_SUCCESS)

|| (finfo.filetype != APR_DIR)) {

return apr_pstrcat(cmd->pool, "CoreDumpDirectory ", fname,

" does not exist or is not a directory", NULL);

}

apr_cpystrn(ap_coredump_dir, fname, sizeof(ap_coredump_dir));

return NULL;

}

AP_DECLARE(void) ap_update_connection_status(long conn_id, const char *key, \

const char *value)

{

/* NOP */

}

AP_DECLARE(void) ap_reset_connection_status(long conn_id)

{

/* NOP */

}

static const command_rec spmt_os2_cmds[] = {

{ "PidFile", set_pidfile, NULL, RSRC_CONF, TAKE1,

"A file for logging the server process ID"},

{ "StartServers", set_daemons_to_start, NULL, RSRC_CONF, TAKE1,

"Number of child processes launched at server startup" },

{ "MinSpareServers", set_min_free_servers, NULL, RSRC_CONF, TAKE1,

"Minimum number of idle children, to handle request spikes" },

{ "MaxSpareServers", set_max_free_servers, NULL, RSRC_CONF, TAKE1,

"Maximum number of idle children" },

{ "MaxClients", set_server_limit, NULL, RSRC_CONF, TAKE1,

"Maximum number of children alive at the same time" },

{ "MaxRequestsPerChild", set_max_requests, NULL, RSRC_CONF, TAKE1,

"Maximum number of requests a particular child serves before dying." },

{ "CoreDumpDirectory", set_coredumpdir, NULL, RSRC_CONF, TAKE1,

"The location of the directory Apache changes to before dumping core" },

{ NULL }

};

module AP_MODULE_DECLARE_DATA mpm_spmt_os2_module = {

MPM20_MODULE_STUFF,

NULL, /* hook to run before apache parses args */

NULL, /* create per-directory config structure */

NULL, /* merge per-directory config structures */

NULL, /* create per-server config structure */

NULL, /* merge per-server config structures */

spmt_os2_cmds, /* command apr_table_t */

spmt_os2_hooks, /* register_hooks */

};