798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_portable.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_strings.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_thread_proc.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_signal.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_tables.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_getopt.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_thread_mutex.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define APR_WANT_STDIO

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define APR_WANT_STRFUNC

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "apr_want.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#if APR_HAVE_UNISTD_H

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <unistd.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#if APR_HAVE_SYS_TYPES_H

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <sys/types.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define CORE_PRIVATE

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "ap_config.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "httpd.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "mpm_default.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "http_main.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "http_log.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "http_config.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "http_core.h" /* for get_remote_host */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "http_connection.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "scoreboard.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "ap_mpm.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "mpm_common.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "ap_listen.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include "ap_mmn.h"

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#ifdef HAVE_TIME_H

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <time.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <signal.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <netware.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <nks/netware.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#include <library.h>

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#ifndef HARD_SERVER_LIMIT

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define HARD_SERVER_LIMIT 1

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define WORKER_DEAD SERVER_DEAD

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define WORKER_STARTING SERVER_STARTING

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define WORKER_READY SERVER_READY

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define WORKER_IDLE_KILL SERVER_IDLE_KILL

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint ap_threads_per_child=0; /* Worker threads per child */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint ap_thread_stack_size=65536;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_thread_mutex_t *accept_lock;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int ap_threads_to_start=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int ap_threads_min_free=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int ap_threads_max_free=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int ap_threads_limit=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint ap_max_workers_limit = -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekserver_rec *ap_server_conf;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic fd_set listenfds;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int listenmaxfd;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_pool_t *pconf; /* Pool for config stuff */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_pool_t *pmain; /* Pool for httpd child stuff */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic pid_t ap_my_pid; /* it seems silly to call getpid all the time */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic char *ap_my_addrspace = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int die_now = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_thread_mutex_t *accept_mutex = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int worker_thread_count;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_thread_mutex_t *worker_thread_count_mutex;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int request_count;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int InstallConsoleHandler(void);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void RemoveConsoleHandler(void);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int CommandLineInterpreter(scr_t screenID, const char *commandLine);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic CommandParser_t ConsoleHandler = {0, NULL, 0};

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define HANDLEDCOMMAND 0

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define NOTMYCOMMAND 1

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int show_settings = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#if 0

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT0(s) printf(s)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT1(s,v1) printf(s,v1)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT2(s,v1,v2) printf(s,v1,v2)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#else

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT0(s)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT1(s,v1)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define DBPRINT2(s,v1,v2)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void clean_child_exit(int code, int worker_num) __attribute__ ((noreturn));

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void clean_child_exit(int code, int worker_num)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_mutex_lock(worker_thread_count_mutex);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek worker_thread_count--;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_mutex_unlock(worker_thread_count_mutex);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (worker_num >=0)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, worker_num, WORKER_DEAD,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek NXThreadExit((void*)&code);

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering}

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart PoetteringAP_DECLARE(apr_status_t) ap_mpm_query(int query_code, int *result)

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering{

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering switch(query_code){

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering case AP_MPMQ_MAX_DAEMON_USED:

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering *result = 1;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering return APR_SUCCESS;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering case AP_MPMQ_IS_THREADED:

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering *result = AP_MPMQ_DYNAMIC;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering return APR_SUCCESS;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering case AP_MPMQ_IS_FORKED:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = AP_MPMQ_NOT_SUPPORTED;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_HARD_LIMIT_DAEMONS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = HARD_SERVER_LIMIT;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_HARD_LIMIT_THREADS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = HARD_THREAD_LIMIT;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MAX_THREADS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = ap_threads_limit;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MIN_SPARE_DAEMONS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MIN_SPARE_THREADS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = ap_threads_min_free;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MAX_SPARE_DAEMONS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MAX_SPARE_THREADS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = ap_threads_max_free;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MAX_REQUESTS_DAEMON:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = ap_max_requests_per_child;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case AP_MPMQ_MAX_DAEMONS:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek *result = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_SUCCESS;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return APR_ENOTIMPL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int volatile shutdown_pending;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int volatile restart_pending;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int volatile is_graceful;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int volatile wait_to_finish=1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekap_generation_t volatile ap_my_generation=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void mpm_term(void)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek RemoveConsoleHandler();

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek wait_to_finish = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void sig_term(int sig)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (shutdown_pending == 1) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* Um, is this _probably_ not an error, if the user has

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek shutdown_pending = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek DBPRINT0 ("waiting for threads\n");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek while (wait_to_finish) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_yield();

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek DBPRINT0 ("goodbye\n");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void restart(void)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (restart_pending == 1) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* Probably not an error - don't bother reporting it */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek restart_pending = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek is_graceful = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void set_signals(void)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_signal(SIGTERM, sig_term);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_signal(SIGABRT, sig_term);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint nlmUnloadSignaled()

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek shutdown_pending = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic fd_set main_fds;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint ap_graceful_stop_signalled(void)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* not ever called anymore... */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int dont_block = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int missed_accept = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic apr_socket_t *sd = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int skipped_selects = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int would_block = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekvoid worker_main(void *arg)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_listen_rec *lr;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_listen_rec *last_lr = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_pool_t *ptrans;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_allocator_t *allocator;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek conn_rec *current_conn;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_status_t stat = APR_EINIT;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int worker_num_arg = (int)arg;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_sb_handle_t *sbh;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int my_worker_num = worker_num_arg;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_socket_t *csd = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int requests_this_child = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int sockdes;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_listen_rec *first_lr;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int srv;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek struct timeval tv;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek tv.tv_sec = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek tv.tv_usec = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_allocator_create(&allocator);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_pool_create_ex(&ptrans, NULL, NULL, allocator);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_allocator_set_owner(allocator, ptrans);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_pool_tag(ptrans, "transaction");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_mutex_lock(worker_thread_count_mutex);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek worker_thread_count++;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_mutex_unlock(worker_thread_count_mutex);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, my_worker_num, WORKER_READY,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek while (!die_now) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /*

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek current_conn = NULL;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_pool_clear(ptrans);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if ((ap_max_requests_per_child > 0

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek && requests_this_child++ >= ap_max_requests_per_child)) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek clean_child_exit(0, my_worker_num);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, my_worker_num, WORKER_READY,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /*

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke /* Only allow a single thread at a time into the "accept" loop */

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke apr_thread_mutex_lock(accept_mutex);

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke for (;;) {

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke if (shutdown_pending || restart_pending || (ap_scoreboard_image->servers[0][my_worker_num].status == WORKER_IDLE_KILL)) {

cb7bb815d2ad7945e63214d21cec1d70152ba6abMarkus Knetschke DBPRINT1 ("\nThread slot %d is shutting down\n", my_worker_num);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_mutex_unlock(accept_mutex);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek clean_child_exit(0, my_worker_num);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* If we just satisfied a request on listen port x, assume that more

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (dont_block && (missed_accept<10)) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek skipped_selects++;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek else {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* If we determine that there are no more requests on the listen

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (dont_block) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_setsocketopt(sd, APR_SO_NONBLOCK, 0);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek dont_block = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* Check the listen queue on all sockets for requests */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek memcpy(&main_fds, &listenfds, sizeof(fd_set));

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek srv = select(listenmaxfd + 1, &main_fds, NULL, NULL, &tv);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (srv <= 0)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek continue;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* remember the last_lr we searched last time around so that

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (last_lr == NULL) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = ap_listeners;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek else {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = last_lr->next;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (!lr)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = ap_listeners;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek first_lr = lr;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek do {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_os_sock_get(&sockdes, lr->sd);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (FD_ISSET(sockdes, &main_fds))

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek goto got_listener;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = lr->next;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (!lr)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = ap_listeners;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek } while (lr != first_lr);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* FIXME: if we get here, something bad has happened, and we're

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek continue;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekgot_listener:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek last_lr = lr;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek sd = lr->sd;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* Just got a request on one of the listen sockets so assume that

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_setsocketopt(sd, APR_SO_NONBLOCK, 1);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek dont_block = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek missed_accept = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek stat = apr_accept(&csd, sd, ptrans);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* If we got a new socket, set it to non-blocking mode and process

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (stat == APR_SUCCESS) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_setsocketopt(csd, APR_SO_NONBLOCK, 0);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break; /* We have a socket ready for reading */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek else {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek switch (APR_TO_NETOS_ERROR(stat)) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* if the error is a wouldblock then maybe we were too

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case WSAEWOULDBLOCK:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek missed_accept++;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek would_block++;

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering apr_thread_yield();

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering continue;

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering break;

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering case WSAECONNRESET:

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering case WSAETIMEDOUT:

3fe22bb4b6b5faf27683ad2e231b5a69b6e63a9eLennart Poettering case WSAEHOSTUNREACH:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case WSAENETUNREACH:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case WSAENETDOWN:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /*

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_log_error(APLOG_MARK, APLOG_EMERG, stat, ap_server_conf,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek "apr_accept: giving up.");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek clean_child_exit(APEXIT_CHILDFATAL, my_worker_num);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering default:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_log_error(APLOG_MARK, APLOG_ERR, stat, ap_server_conf,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek "apr_accept: (client socket)");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek clean_child_exit(1, my_worker_num);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering }

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering /* Unlock the mutext so that the next thread can start listening for requests. */

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering apr_thread_mutex_unlock(accept_mutex);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering ap_create_sb_handle(&sbh, ptrans, 0, my_worker_num);

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering /*

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering current_conn = ap_run_create_connection(ptrans, ap_server_conf, csd,

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering my_worker_num, sbh);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering if (current_conn) {

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering ap_process_connection(current_conn, csd);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering ap_lingering_close(current_conn);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering }

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering request_count++;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering }

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering clean_child_exit(0, my_worker_num);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering}

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering

7de304525deafe4eb86060321e39787138dbbadfLennart Poetteringstatic int make_child(server_rec *s, int slot)

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering{

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering int tid;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering int err=0;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering NXContext_t ctx;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering if (slot + 1 > ap_max_workers_limit) {

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering ap_max_workers_limit = slot + 1;

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering }

d6ce17c7f02ed3facdb45f65f546e587c2f00950Lennart Poettering

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, slot, WORKER_STARTING,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (ctx = NXContextAlloc((void (*)(void *)) worker_main, (void*)slot, NX_PRIO_MED, ap_thread_stack_size, NX_CTX_NORMAL, &err)) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek char threadName[32];

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek sprintf (threadName, "Apache_Worker %d", slot);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek NXContextSetName(ctx, threadName);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek err = NXThreadCreate(ctx, NX_THR_BIND_CONTEXT, &tid);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (err) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek NXContextFree (ctx);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

f8b07704b86886e52902f9b320623ab10aad7dc4Richard Maw if (err) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* create thread didn't succeed. Fix the scoreboard or else

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, slot, WORKER_DEAD,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* In case system resources are maxxed out, we don't want

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_thread_yield();

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_scoreboard_image->servers[0][slot].tid = tid;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

12b42c76672a66c2d4ea7212c14f8f1b5a62b78dTom Gundersen return 0;

12b42c76672a66c2d4ea7212c14f8f1b5a62b78dTom Gundersen}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void startup_workers(int number_to_start)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int i;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek for (i = 0; number_to_start && i < ap_threads_limit; ++i) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (ap_scoreboard_image->servers[0][i].status != WORKER_DEAD) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek continue;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (make_child(ap_server_conf, i) < 0) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

6b94875fa3a7280e7f1c0df11027b927b6961edeRichard Maw }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek --number_to_start;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int idle_spawn_rate = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#ifndef MAX_SPAWN_RATE

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#define MAX_SPAWN_RATE (64)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int hold_off_on_exponential_spawning;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void perform_idle_server_maintenance(apr_pool_t *p)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int i;

f8b07704b86886e52902f9b320623ab10aad7dc4Richard Maw int to_kill;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int idle_count;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek worker_score *ws;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int free_length;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int free_slots[MAX_SPAWN_RATE];

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int last_non_dead;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int total_non_dead;

1d3eaa93616a2e9f6568b754a65c884766bac6c4Jay Strict

6b94875fa3a7280e7f1c0df11027b927b6961edeRichard Maw /* initialize the free_list */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek free_length = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek to_kill = -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek idle_count = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek last_non_dead = -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek total_non_dead = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek for (i = 0; i < ap_threads_limit; ++i) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek int status;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (i >= ap_max_workers_limit && free_length == idle_spawn_rate)

6b94875fa3a7280e7f1c0df11027b927b6961edeRichard Maw break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ws = &ap_scoreboard_image->servers[0][i];

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek status = ws->status;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (status == WORKER_DEAD) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* try to keep children numbers as low as possible */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (free_length < idle_spawn_rate) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek free_slots[free_length] = i;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ++free_length;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek else if (status == WORKER_IDLE_KILL) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* If it is already marked to die, skip it */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek continue;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek else {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* We consider a starting server as idle because we started it

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (status <= WORKER_READY) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ++ idle_count;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* always kill the highest numbered child if we have to...

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek to_kill = i;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

6b94875fa3a7280e7f1c0df11027b927b6961edeRichard Maw ++total_non_dead;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek last_non_dead = i;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek DBPRINT2("Total: %d Idle Count: %d \r", total_non_dead, idle_count);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_max_workers_limit = last_non_dead + 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (idle_count > ap_threads_max_free) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* kill off one child... we use the pod because that'll cause it to

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek idle_spawn_rate = 1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_update_child_status_from_indexes(0, last_non_dead, WORKER_IDLE_KILL,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek (request_rec *) NULL);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering DBPRINT1("\nKilling idle thread: %d\n", last_non_dead);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering }

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering else if (idle_count < ap_threads_min_free) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering /* terminate the free list */

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering if (free_length == 0) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering /* only report this condition once */

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering static int reported = 0;

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering if (!reported) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ERR, 0, ap_server_conf,

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering "server reached MaxClients setting, consider"

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering " raising the MaxClients setting");

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering reported = 1;

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering }

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering idle_spawn_rate = 1;

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering }

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering else {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering if (idle_spawn_rate >= 8) {

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

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering "server seems busy, (you may need "

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering "to increase StartServers, or Min/MaxSpareServers), "

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering "spawning %d children, there are %d idle, and "

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering "%d total children", idle_spawn_rate,

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering idle_count, total_non_dead);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering }

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering DBPRINT0("\n");

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering for (i = 0; i < free_length; ++i) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering DBPRINT1("Spawning additional thread slot: %d\n", free_slots[i]);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering make_child(ap_server_conf, free_slots[i]);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering }

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering /* the next time around we want to spawn twice as many if this

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering if (hold_off_on_exponential_spawning) {

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering --hold_off_on_exponential_spawning;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering else if (idle_spawn_rate < MAX_SPAWN_RATE) {

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering idle_spawn_rate *= 2;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering else {

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering idle_spawn_rate = 1;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering}

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poetteringstatic void display_settings ()

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering{

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering int status_array[SERVER_NUM_STATUS];

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering int i, status, total=0;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering int reqs = request_count;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering int skips = skipped_selects;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering int wblock = would_block;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering request_count = 0;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering skipped_selects = 0;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering would_block = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ClearScreen (getscreenhandle());

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf("%s \n", ap_get_server_version());

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering for (i=0;i<SERVER_NUM_STATUS;i++) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering status_array[i] = 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek for (i = 0; i < ap_threads_limit; ++i) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek status = (ap_scoreboard_image->servers[0][i]).status;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek status_array[status]++;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering for (i=0;i<SERVER_NUM_STATUS;i++) {

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering switch(i)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_DEAD:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Available:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_STARTING:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Starting:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_READY:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Ready:\t\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_BUSY_READ:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Busy:\t\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_BUSY_WRITE:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Busy Write:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_BUSY_KEEPALIVE:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Busy Keepalive:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek case SERVER_BUSY_LOG:

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering printf ("Busy Log:\t%d\n", status_array[i]);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering break;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering case SERVER_BUSY_DNS:

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering printf ("Busy DNS:\t%d\n", status_array[i]);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering break;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering case SERVER_CLOSING:

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering printf ("Closing:\t%d\n", status_array[i]);

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering break;

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering case SERVER_GRACEFUL:

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering printf ("Restart:\t%d\n", status_array[i]);

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering break;

af40e5d3acbdcff09c8809cd1b86ecf8871f65f0Lennart Poettering case SERVER_IDLE_KILL:

7de304525deafe4eb86060321e39787138dbbadfLennart Poettering printf ("Idle Kill:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek default:

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Unknown Status:\t%d\n", status_array[i]);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek break;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (i != SERVER_DEAD)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek total+=status_array[i];

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Total Running:\t%d\tout of: \t%d\n", total, ap_threads_limit);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Requests per interval:\t%d\n", reqs);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Skipped selects:\t%d\n", skips);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf ("Would blocks:\t%d\n", wblock);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic void show_server_data()

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_listen_rec *lr;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek module **m;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf("%s\n", ap_get_server_version());

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (ap_my_addrspace && (ap_my_addrspace[0] != 'O') && (ap_my_addrspace[1] != 'S'))

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf(" Running in address space %s\n", ap_my_addrspace);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek /* Display listening ports */

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf(" Listening on port(s):");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = ap_listeners;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek do {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf(" %d", lr->bind_addr->port);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek lr = lr->next;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek } while(lr && lr != ap_listeners);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

e0ea94c1e2ab3930c85c6057189a2a829a13a800Lennart Poettering /* Display dynamic modules loaded */

e0ea94c1e2ab3930c85c6057189a2a829a13a800Lennart Poettering printf("\n");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek for (m = ap_loaded_modules; *m != NULL; m++) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (((module*)*m)->dynamic_load_handle) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek printf(" Loaded dynamic module %s\n", ((module*)*m)->name);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int setup_listeners(server_rec *s)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke ap_listen_rec *lr;

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke int sockdes;

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke if (ap_setup_listeners(s) < 1 ) {

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ALERT, 0, s,

ac92ced5bb41def1d90f871d6c8cfec2b03c0c7dBenjamin Franzke "no listening sockets available, shutting down");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek listenmaxfd = -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek FD_ZERO(&listenfds);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek for (lr = ap_listeners; lr; lr = lr->next) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_os_sock_get(&sockdes, lr->sd);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek FD_SET(sockdes, &listenfds);

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (sockdes > listenmaxfd) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek listenmaxfd = sockdes;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek#ifdef NONBLOCK1

e0ea94c1e2ab3930c85c6057189a2a829a13a800Lennart Poettering apr_setsocketopt(lr->sd, APR_SO_NONBLOCK, 1);

e0ea94c1e2ab3930c85c6057189a2a829a13a800Lennart Poettering#endif

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return 0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek}

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekstatic int shutdown_listeners()

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering{

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering ap_listen_rec *lr;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering for (lr = ap_listeners; lr; lr = lr->next) {

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering apr_socket_close(lr->sd);

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering }

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering return 0;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering}

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmekint ap_mpm_run(apr_pool_t *_pconf, apr_pool_t *plog, server_rec *s)

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek{

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek apr_status_t status=0;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek pconf = _pconf;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_server_conf = s;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (setup_listeners(s)) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_ALERT, status, s,

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek "no listening sockets available, shutting down");

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return -1;

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek }

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek restart_pending = shutdown_pending = 0;

6e9efa59209d48fc69a456fbadb2b5c113f503a6Lennart Poettering worker_thread_count = 0;

16eb4024887b1b79fc56706fda25eadaecdef2d4Zbigniew Jędrzejewski-Szmek apr_thread_mutex_create(&worker_thread_count_mutex, APR_THREAD_MUTEX_DEFAULT, pconf);

16eb4024887b1b79fc56706fda25eadaecdef2d4Zbigniew Jędrzejewski-Szmek apr_thread_mutex_create(&accept_mutex, APR_THREAD_MUTEX_DEFAULT, pconf);

16eb4024887b1b79fc56706fda25eadaecdef2d4Zbigniew Jędrzejewski-Szmek

16eb4024887b1b79fc56706fda25eadaecdef2d4Zbigniew Jędrzejewski-Szmek if (!is_graceful) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek if (ap_run_pre_mpm(s->process->pool, SB_NOT_SHARED) != OK) {

798d3a524ea57aaf40cb53858aaa45ec702f012dZbigniew Jędrzejewski-Szmek return 1;

19887cd06a3af2f045e763986eda19e208bd3f85Zbigniew Jędrzejewski-Szmek }

19887cd06a3af2f045e763986eda19e208bd3f85Zbigniew Jędrzejewski-Szmek }

/* Only set slot 0 since that is all NetWare will ever have. */

ap_scoreboard_image->parent[0].pid = getpid();

set_signals();

apr_pool_create(&pmain, pconf);

ap_run_child_init(pmain, ap_server_conf);

if (ap_threads_max_free < ap_threads_min_free + 1) /* Don't thrash... */

ap_threads_max_free = ap_threads_min_free + 1;

request_count = 0;

startup_workers(ap_threads_to_start);

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());

#ifdef AP_MPM_WANT_SET_ACCEPT_LOCK_MECH

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

"AcceptMutex: %s", ap_mpm_show_accept_lock_mech());

#endif

show_server_data();

while (!restart_pending && !shutdown_pending) {

perform_idle_server_maintenance(pconf);

if (show_settings)

display_settings();

apr_thread_yield();

apr_sleep(SCOREBOARD_MAINTENANCE_INTERVAL);

}

/* Shutdown the listen sockets so that we don't get stuck in a blocking call.

if (shutdown_pending) { /* Got an unload from the console */

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

"caught SIGTERM, shutting down");

DBPRINT0 ("Shutdown pending. Waiting for threads to terminate...\n");

while (worker_thread_count > 0)

apr_thread_yield();

return 1;

}

else { /* the only other way out is a restart */

/* advance to the next generation */

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

++ap_my_generation;

ap_scoreboard_image->global->running_generation = ap_my_generation;

update_scoreboard_global();

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

"Graceful restart requested, doing restart");

/* Wait for all of the threads to terminate before initiating the restart */

DBPRINT0 ("Restart pending. Waiting for threads to terminate...\n");

while (worker_thread_count > 0) {

apr_thread_yield();

}

DBPRINT0 ("restarting...\n");

}

return 0;

}

struct _BogusAddressSpace { int a; int b; int c; char name[]; };

typedef struct _BogusAddressSpace BogusAddressSpace;

extern BogusAddressSpace* GetCurrentAddressSpace(void);

static int netware_pre_config(apr_pool_t *p, apr_pool_t *plog, apr_pool_t *ptemp)

{

int debug;

BogusAddressSpace *addrspace = NULL;

debug = ap_exists_config_define("DEBUG");

is_graceful = 0;

ap_my_pid = getpid();

addrspace = GetCurrentAddressSpace();

if (addrspace)

ap_my_addrspace = apr_pstrdup (p, addrspace->name);

ap_listen_pre_config();

ap_threads_to_start = DEFAULT_START_THREADS;

ap_threads_min_free = DEFAULT_MIN_FREE_THREADS;

ap_threads_max_free = DEFAULT_MAX_FREE_THREADS;

ap_threads_limit = HARD_THREAD_LIMIT;

ap_max_requests_per_child = DEFAULT_MAX_REQUESTS_PER_CHILD;

ap_extended_status = 0;

return OK;

}

static void netware_mpm_hooks(apr_pool_t *p)

{

ap_hook_pre_config(netware_pre_config, NULL, NULL, APR_HOOK_MIDDLE);

}

void netware_rewrite_args(process_rec *process)

{

char *def_server_root;

char optbuf[3];

const char *opt_arg;

apr_getopt_t *opt;

apr_array_header_t *mpm_new_argv;

atexit (mpm_term);

InstallConsoleHandler();

/* Rewrite process->argv[];

if (process->argc > 0) {

char *s = apr_pstrdup (process->pconf, process->argv[0]);

if (s) {

int i, len = strlen(s);

for (i=len; i; i--) {

if (s[i] == '\\' || s[i] == '/') {

s[i] = NULL;

apr_filepath_merge(&def_server_root, NULL, s,

APR_FILEPATH_TRUENAME, process->pool);

break;

}

}

/* Use process->pool so that the rewritten argv

mpm_new_argv = apr_array_make(process->pool, process->argc + 2,

sizeof(const char *));

*(const char **)apr_array_push(mpm_new_argv) = process->argv[0];

*(const char **)apr_array_push(mpm_new_argv) = "-d";

*(const char **)apr_array_push(mpm_new_argv) = def_server_root;

optbuf[0] = '-';

optbuf[2] = '\0';

apr_getopt_init(&opt, process->pool, process->argc, (char**) process->argv);

while (apr_getopt(opt, AP_SERVER_BASEARGS, optbuf + 1, &opt_arg) == APR_SUCCESS) {

switch (optbuf[1]) {

default:

*(const char **)apr_array_push(mpm_new_argv) =

apr_pstrdup(process->pool, optbuf);

if (opt_arg) {

*(const char **)apr_array_push(mpm_new_argv) = opt_arg;

}

break;

}

}

process->argc = mpm_new_argv->nelts;

process->argv = (const char * const *) mpm_new_argv->elts;

}

}

}

static int CommandLineInterpreter(scr_t screenID, const char *commandLine)

{

char *szCommand = "APACHE2 ";

int iCommandLen = 8;

char szcommandLine[256];

char *pID;

screenID = screenID;

if (commandLine == NULL)

return NOTMYCOMMAND;

if (strlen(commandLine) <= strlen(szCommand))

return NOTMYCOMMAND;

strncpy (szcommandLine, commandLine, sizeof(szcommandLine)-1);

/* All added commands begin with "APACHE2 " */

if (!strnicmp(szCommand, szcommandLine, iCommandLen)) {

ActivateScreen (getscreenhandle());

/* If an instance id was not given but the nlm is loaded in

pID = strstr (szcommandLine, "-p");

if ((pID == NULL) && nlmisloadedprotected())

return NOTMYCOMMAND;

/* If we got an instance id but it doesn't match this

if (pID && ap_my_addrspace && strnicmp(&pID[2], ap_my_addrspace, strlen(ap_my_addrspace)))

return NOTMYCOMMAND;

/* If we have determined that this command belongs to this

if (!strnicmp("RESTART",&szcommandLine[iCommandLen],3)) {

printf("Restart Requested...\n");

restart();

}

else if (!strnicmp("VERSION",&szcommandLine[iCommandLen],3)) {

printf("Server version: %s\n", ap_get_server_version());

printf("Server built: %s\n", ap_get_server_built());

}

else if (!strnicmp("MODULES",&szcommandLine[iCommandLen],3)) {

ap_show_modules();

}

else if (!strnicmp("DIRECTIVES",&szcommandLine[iCommandLen],3)) {

ap_show_directives();

}

else if (!strnicmp("SHUTDOWN",&szcommandLine[iCommandLen],3)) {

printf("Shutdown Requested...\n");

shutdown_pending = 1;

}

else if (!strnicmp("SETTINGS",&szcommandLine[iCommandLen],3)) {

if (show_settings) {

show_settings = 0;

ClearScreen (getscreenhandle());

show_server_data();

}

else {

show_settings = 1;

display_settings();

}

}

else {

show_settings = 0;

if (!strnicmp("HELP",&szcommandLine[iCommandLen],3))

printf("Unknown APACHE2 command %s\n", &szcommandLine[iCommandLen]);

printf("Usage: APACHE2 [command] [-p <instance ID>]\n");

printf("Commands:\n");

printf("\tDIRECTIVES - Show directives\n");

printf("\tHELP - Display this help information\n");

printf("\tMODULES - Show a list of the loaded modules\n");

printf("\tRESTART - Reread the configurtion file and restart Apache\n");

printf("\tSETTINGS - Show current thread status\n");

printf("\tSHUTDOWN - Shutdown Apache\n");

printf("\tVERSION - Display the server version information\n");

}

/* Tell NetWare we handled the command */

return HANDLEDCOMMAND;

}

/* Tell NetWare that the command isn't mine */

return NOTMYCOMMAND;

}

static int InstallConsoleHandler(void)

{

/* Our command line handler interfaces the system operator

NX_WRAP_INTERFACE(CommandLineInterpreter, 2, (void*)&(ConsoleHandler.parser));

ConsoleHandler.rTag = AllocateResourceTag(getnlmhandle(), "Command Line Processor",

ConsoleCommandSignature);

if (!ConsoleHandler.rTag)

{

printf("Error on allocate resource tag\n");

return 1;

}

RegisterConsoleCommand(&ConsoleHandler);

/* The Remove procedure unregisters the console handler */

return 0;

}

static void RemoveConsoleHandler(void)

{

UnRegisterConsoleCommand(&ConsoleHandler);

NX_UNWRAP_INTERFACE(ConsoleHandler.parser);

}

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

{

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

if (err != NULL) {

return err;

}

ap_threads_to_start = atoi(arg);

return NULL;

}

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

{

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

if (err != NULL) {

return err;

}

ap_threads_min_free = atoi(arg);

if (ap_threads_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_threads_min_free = 1;

}

return NULL;

}

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

{

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

if (err != NULL) {

return err;

}

ap_threads_max_free = atoi(arg);

return NULL;

}

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

{

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

if (err != NULL) {

return err;

}

ap_threads_limit = atoi(arg);

if (ap_threads_limit > HARD_THREAD_LIMIT) {

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

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

"of %d threads,", ap_threads_limit, HARD_THREAD_LIMIT);

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

" lowering MaxThreads 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_threads_limit = HARD_THREAD_LIMIT;

}

else if (ap_threads_limit < 1) {

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

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

ap_threads_limit = 1;

}

return NULL;

}

static const char *set_thread_stacksize(cmd_parms *cmd, void *dummy,

const char *arg)

{

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

if (err != NULL) {

return err;

}

ap_thread_stack_size = atoi(arg);

return NULL;

}

static const command_rec netware_mpm_cmds[] = {

AP_INIT_TAKE1("ThreadStackSize", set_thread_stacksize, NULL, RSRC_CONF,

"Stack size each created thread will use."),

LISTEN_COMMANDS,

AP_INIT_TAKE1("StartThreads", set_threads_to_start, NULL, RSRC_CONF,

"Number of worker threads launched at server startup"),

AP_INIT_TAKE1("MinSpareThreads", set_min_free_threads, NULL, RSRC_CONF,

"Minimum number of idle threads, to handle request spikes"),

AP_INIT_TAKE1("MaxSpareThreads", set_max_free_threads, NULL, RSRC_CONF,

"Maximum number of idle threads"),

AP_INIT_TAKE1("MaxThreads", set_thread_limit, NULL, RSRC_CONF,

"Maximum number of worker threads alive at the same time"),

{ NULL }

};

module AP_MODULE_DECLARE_DATA mpm_netware_module = {

MPM20_MODULE_STUFF,

netware_rewrite_args, /* 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 */

netware_mpm_cmds, /* command apr_table_t */

netware_mpm_hooks, /* register hooks */

};