b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#define CORE_PRIVATE

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "httpd.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "http_main.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "http_log.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "http_config.h" /* for read_config */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "http_core.h" /* for get_remote_host */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "http_connection.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "apr_portable.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "apr_getopt.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "apr_strings.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "ap_mpm.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "ap_config.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "ap_listen.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "mpm_default.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "mpm_winnt.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "mpm_common.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#include "scoreboard.h"

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbtypedef HANDLE thread;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic int workers_may_exit = 0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic int shutdown_in_progress = 0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic unsigned int g_blocked_threads = 0;

f888346b48f5e5b5e3f0a47dedb8cefd2759a4e2gregames

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic char *ap_pid_fname = NULL;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbint ap_threads_per_child = 0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic int max_requests_per_child = 0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic HANDLE shutdown_event; /* used to signal shutdown to parent */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic HANDLE restart_event; /* used to signal a restart to parent */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#define MAX_SIGNAL_NAME 30 /* Long enough for apPID_shutdown, where PID is an int */

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzchar signal_name_prefix[MAX_SIGNAL_NAME];

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzchar signal_restart_name[MAX_SIGNAL_NAME];

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzchar signal_shutdown_name[MAX_SIGNAL_NAME];

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzstatic struct fd_set listenfds;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzstatic int num_listenfds = 0;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzstatic SOCKET listenmaxfd = INVALID_SOCKET;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzstatic apr_pool_t *pconf; /* Pool for config stuff */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic char ap_coredump_dir[MAX_STRING_LEN];

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic server_rec *server_conf;

a2a0abd88b19e042a3eb2a9fa1702c25ad51303dwrowestatic HANDLE AcceptExCompPort = NULL;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic int one_process = 0;

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic char const* signal_arg;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerOSVERSIONINFO osver; /* VER_PLATFORM_WIN32_NT */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerint ap_max_requests_per_child=0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbint ap_daemons_to_start=0;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic HANDLE exit_event;

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic HANDLE maintenance_event;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbapr_lock_t *start_mutex;

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerDWORD my_pid;

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerDWORD parent_pid;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewroweap_generation_t volatile ap_my_generation=0; /* Used by the scoreboard */

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawickAP_DECLARE(int) ap_get_max_daemons(void)

c2cf53a40a9814eb91db2cdf820f97d943f21628coar{

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe return 1;

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowestatic const char* const lateDllName[DLL_defined] = {

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe "kernel32", "advapi32", "mswsock", "ws2_32" };

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowestatic HMODULE lateDllHandle[DLL_defined] = {

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe NULL, NULL, NULL, NULL };

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

3e392a5afd51526de3cb15d57ee46d8cb160ae65gregamesFARPROC ap_load_dll_func(ap_dlltoken_e fnLib, char* fnName, int ordinal)

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe{

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe if (!lateDllHandle[fnLib]) {

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe lateDllHandle[fnLib] = LoadLibrary(lateDllName[fnLib]);

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe if (!lateDllHandle[fnLib])

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz return NULL;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz }

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz if (ordinal)

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz return GetProcAddress(lateDllHandle[fnLib], (char *) ordinal);

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe else

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe return GetProcAddress(lateDllHandle[fnLib], fnName);

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic apr_status_t socket_cleanup(void *sock)

4f9c22c4f27571d54197be9674e1fc0d528192aestriker{

3e392a5afd51526de3cb15d57ee46d8cb160ae65gregames apr_socket_t *thesocket = sock;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe SOCKET sd;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (apr_get_os_sock(&sd, thesocket) == APR_SUCCESS) {

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe closesocket(sd);

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe }

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return APR_SUCCESS;

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic HANDLE create_semaphore(int initial)

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe{

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return(CreateSemaphore(NULL, initial, 1000000, NULL));

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe}

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowestatic void acquire_semaphore(HANDLE semaphore_id)

4775dfc34c90fada8c7c4d6a57ed8a3114d55c2dtrawick{

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe int rv;

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe rv = WaitForSingleObject(semaphore_id, INFINITE);

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar return;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe}

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowestatic int release_semaphore(HANDLE semaphore_id)

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe{

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return(ReleaseSemaphore(semaphore_id, 1, NULL));

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowestatic void destroy_semaphore(HANDLE semaphore_id)

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe{

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe CloseHandle(semaphore_id);

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowestatic PSECURITY_ATTRIBUTES GetNullACL()

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe{

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe PSECURITY_DESCRIPTOR pSD;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe PSECURITY_ATTRIBUTES sa;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe sa = (PSECURITY_ATTRIBUTES) LocalAlloc(LPTR, sizeof(SECURITY_ATTRIBUTES));

4f9c22c4f27571d54197be9674e1fc0d528192aestriker pSD = (PSECURITY_DESCRIPTOR) LocalAlloc(LPTR,

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe SECURITY_DESCRIPTOR_MIN_LENGTH);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (pSD == NULL || sa == NULL) {

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return NULL;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe }

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar apr_set_os_error(0);

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe if (!InitializeSecurityDescriptor(pSD, SECURITY_DESCRIPTOR_REVISION)

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe || apr_get_os_error()) {

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe LocalFree( pSD );

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe LocalFree( sa );

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return NULL;

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (!SetSecurityDescriptorDacl(pSD, TRUE, (PACL) NULL, FALSE)

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe || apr_get_os_error()) {

c2cf53a40a9814eb91db2cdf820f97d943f21628coar LocalFree( pSD );

c2cf53a40a9814eb91db2cdf820f97d943f21628coar LocalFree( sa );

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe return NULL;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz }

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz sa->nLength = sizeof(sa);

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz sa->lpSecurityDescriptor = pSD;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe sa->bInheritHandle = TRUE;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker return sa;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar}

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowestatic void CleanNullACL( void *sa ) {

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz if( sa ) {

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz LocalFree( ((PSECURITY_ATTRIBUTES)sa)->lpSecurityDescriptor);

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz LocalFree( sa );

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe }

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantzstatic DWORD wait_for_many_objects(DWORD nCount, CONST HANDLE *lpHandles,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz DWORD dwSeconds)

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe{

4f9c22c4f27571d54197be9674e1fc0d528192aestriker time_t tStopTime;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar DWORD dwRet = WAIT_TIMEOUT;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar DWORD dwIndex=0;

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe BOOL bFirst = TRUE;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz tStopTime = time(NULL) + dwSeconds;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe do {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (!bFirst)

c2cf53a40a9814eb91db2cdf820f97d943f21628coar Sleep(1000);

c2cf53a40a9814eb91db2cdf820f97d943f21628coar else

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe bFirst = FALSE;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz for (dwIndex = 0; dwIndex * MAXIMUM_WAIT_OBJECTS < nCount; dwIndex++) {

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz dwRet = WaitForMultipleObjects(

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe min(MAXIMUM_WAIT_OBJECTS, nCount - (dwIndex * MAXIMUM_WAIT_OBJECTS)),

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe lpHandles + (dwIndex * MAXIMUM_WAIT_OBJECTS),

fa06de8a28a737e8fbaad76d7f3ff67aaa5e4a09wrowe 0, 0);

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe if (dwRet != WAIT_TIMEOUT) {

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe break;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe }

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe } while((time(NULL) < tStopTime) && (dwRet == WAIT_TIMEOUT));

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz return dwRet;

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe}

83a8dc5a596a8a1b9d14f063268287d123b9ed7ewrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestrikervoid signal_parent(int type)

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe{

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe HANDLE e;

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp char *signal_name;

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe /* after updating the shutdown_pending or restart flags, we need

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe if (one_process) {

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe return;

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe }

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp switch(type) {

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp case 0: signal_name = signal_shutdown_name; break;

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp case 1: signal_name = signal_restart_name; break;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker default: return;

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp }

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp e = OpenEvent(EVENT_ALL_ACCESS, FALSE, signal_name);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (!e) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /* Um, problem, can't signal the parent, which means we can't

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_EMERG, apr_get_os_error(), server_conf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker "OpenEvent on %s event", signal_name);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker return;

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp }

7a2edaa0193cbb0d79a65a8461a609a9402aea49brianp if (SetEvent(e) == 0) {

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe /* Same problem as above */

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe ap_log_error(APLOG_MARK, APLOG_EMERG, apr_get_os_error(), server_conf,

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe "SetEvent on %s event", signal_name);

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe CloseHandle(e);

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe return;

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker CloseHandle(e);

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp}

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowestatic int volatile is_graceful = 0;

cc9582e53aead2a044077c4a92f3dfc3605590b3wrowe

cc9582e53aead2a044077c4a92f3dfc3605590b3wroweAP_DECLARE(int) ap_graceful_stop_signalled(void)

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb{

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb return is_graceful;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb}

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbAP_DECLARE(void) ap_start_shutdown(void)

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb{

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb signal_parent(0);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb}

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbAP_DECLARE(void) ap_start_restart(int gracefully)

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb{

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb is_graceful = gracefully;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb signal_parent(1);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb}

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbvoid setup_signal_names(char *prefix)

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb{

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb apr_snprintf(signal_name_prefix, sizeof(signal_name_prefix), prefix);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb apr_snprintf(signal_shutdown_name, sizeof(signal_shutdown_name),

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb "%s_shutdown", signal_name_prefix);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb apr_snprintf(signal_restart_name, sizeof(signal_restart_name),

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb "%s_restart", signal_name_prefix);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb}

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic void sock_disable_nagle(int s)

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb{

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe /* The Nagle algorithm says that we should delay sending partial

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe int just_say_no = 1;

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (setsockopt(s, IPPROTO_TCP, TCP_NODELAY, (char *) &just_say_no,

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe sizeof(int)) < 0) {

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe ap_log_error(APLOG_MARK, APLOG_WARNING, APR_SUCCESS, server_conf,

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe "setsockopt: (TCP_NODELAY)");

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe }

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe}

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowestatic ap_listen_rec *head_listener;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowestatic apr_inline ap_listen_rec *find_ready_listener(fd_set * main_fds)

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz{

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz ap_listen_rec *lr;

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz SOCKET nsd;

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe

659ad814f714e556bdd03e1d771cba156baab92ewrowe for (lr = head_listener; lr ; lr = lr->next) {

659ad814f714e556bdd03e1d771cba156baab92ewrowe apr_get_os_sock(&nsd, lr->sd);

659ad814f714e556bdd03e1d771cba156baab92ewrowe if (FD_ISSET(nsd, main_fds)) {

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe head_listener = lr->next;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (head_listener == NULL)

11fb2f3611e6ff9a541e10b13e3108934f828141gregames head_listener = ap_listeners;

11fb2f3611e6ff9a541e10b13e3108934f828141gregames

11fb2f3611e6ff9a541e10b13e3108934f828141gregames return (lr);

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz }

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz }

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz return NULL;

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz}

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowestatic int setup_listeners(server_rec *s)

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe{

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe ap_listen_rec *lr;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker int num_listeners = 0;

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe SOCKET nsd;

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe /* Setup the listeners */

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar FD_ZERO(&listenfds);

2f1949bb0e3c209db94c8d521cba7380b9d11421trawick

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (ap_listen_open(s->process, s->port)) {

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe return 0;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

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

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe num_listeners++;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (lr->sd != NULL) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_get_os_sock(&nsd, lr->sd);

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe FD_SET(nsd, &listenfds);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (listenmaxfd == INVALID_SOCKET || nsd > listenmaxfd) {

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe listenmaxfd = nsd;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe }

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar lr->count = 0;

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe }

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe head_listener = ap_listeners;

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz return num_listeners;

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz}

7c301a1818939f85da8f3629cc3e9b5588610ef0jerenkrantz

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic int setup_inherited_listeners(server_rec *s)

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe{

290ecc1ddceca1ed49bc1a5338921264b5c3e07cwrowe WSAPROTOCOL_INFO WSAProtocolInfo;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb HANDLE pipe;

8aefbd756763807188d2e3ce336a8680e4893066wrowe ap_listen_rec *lr;

8aefbd756763807188d2e3ce336a8680e4893066wrowe DWORD BytesRead;

8aefbd756763807188d2e3ce336a8680e4893066wrowe int num_listeners = 0;

8aefbd756763807188d2e3ce336a8680e4893066wrowe SOCKET nsd;

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Setup the listeners */

8aefbd756763807188d2e3ce336a8680e4893066wrowe FD_ZERO(&listenfds);

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Set up a default listener if necessary */

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (ap_listeners == NULL) {

8aefbd756763807188d2e3ce336a8680e4893066wrowe ap_listen_rec *lr;

8aefbd756763807188d2e3ce336a8680e4893066wrowe lr = apr_palloc(s->process->pool, sizeof(ap_listen_rec));

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (!lr)

8aefbd756763807188d2e3ce336a8680e4893066wrowe return 0;

8aefbd756763807188d2e3ce336a8680e4893066wrowe lr->sd = NULL;

a2a0abd88b19e042a3eb2a9fa1702c25ad51303dwrowe lr->next = ap_listeners;

8aefbd756763807188d2e3ce336a8680e4893066wrowe ap_listeners = lr;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Open the pipe to the parent process to receive the inherited socket

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe pipe = GetStdHandle(STD_INPUT_HANDLE);

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

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (!ReadFile(pipe, &WSAProtocolInfo, sizeof(WSAPROTOCOL_INFO),

8aefbd756763807188d2e3ce336a8680e4893066wrowe &BytesRead, (LPOVERLAPPED) NULL)) {

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe ap_log_error(APLOG_MARK, APLOG_CRIT, apr_get_os_error(), server_conf,

a8d11d78181478da6a672f7fbc58b8d523351f49wrowe "setup_inherited_listeners: Unable to read socket data from parent");

4f9c22c4f27571d54197be9674e1fc0d528192aestriker signal_parent(0); /* tell parent to die */

23c6309e36a63b13b61c35999c978017521993d6wrowe exit(1);

23c6309e36a63b13b61c35999c978017521993d6wrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_NOERRNO|APLOG_INFO, APR_SUCCESS, server_conf,

23c6309e36a63b13b61c35999c978017521993d6wrowe "Child %d: setup_inherited_listener() read = %d bytes of WSAProtocolInfo.", my_pid);

8aefbd756763807188d2e3ce336a8680e4893066wrowe nsd = WSASocket(FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO,

23c6309e36a63b13b61c35999c978017521993d6wrowe &WSAProtocolInfo, 0, 0);

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawick if (nsd == INVALID_SOCKET) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_CRIT, apr_get_netos_error(), server_conf,

23c6309e36a63b13b61c35999c978017521993d6wrowe "Child %d: setup_inherited_listeners(), WSASocket failed to open the inherited socket.", my_pid);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe signal_parent(0); /* tell parent to die */

8aefbd756763807188d2e3ce336a8680e4893066wrowe exit(1);

8aefbd756763807188d2e3ce336a8680e4893066wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (nsd >= 0) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe FD_SET(nsd, &listenfds);

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (listenmaxfd == INVALID_SOCKET || nsd > listenmaxfd) {

8aefbd756763807188d2e3ce336a8680e4893066wrowe listenmaxfd = nsd;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_put_os_sock(&lr->sd, &nsd, pconf);

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawick lr->count = 0;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /* Now, read the AcceptExCompPort from the parent */

a8d11d78181478da6a672f7fbc58b8d523351f49wrowe ReadFile(pipe, &AcceptExCompPort, sizeof(AcceptExCompPort), &BytesRead, (LPOVERLAPPED) NULL);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe CloseHandle(pipe);

8aefbd756763807188d2e3ce336a8680e4893066wrowe

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

cf6ef072483172309861d06e85b1aeff4573c060wrowe num_listeners++;

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe head_listener = ap_listeners;

cf6ef072483172309861d06e85b1aeff4573c060wrowe return num_listeners;

cf6ef072483172309861d06e85b1aeff4573c060wrowe}

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp

cf6ef072483172309861d06e85b1aeff4573c060wrowestatic void bind_listeners_to_completion_port()

4f9c22c4f27571d54197be9674e1fc0d528192aestriker{

cf6ef072483172309861d06e85b1aeff4573c060wrowe /* Associate the open listeners with the completion port.

cf6ef072483172309861d06e85b1aeff4573c060wrowe ap_listen_rec *lr;

cf6ef072483172309861d06e85b1aeff4573c060wrowe

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (osver.dwPlatformId != VER_PLATFORM_WIN32_WINDOWS) {

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

cf6ef072483172309861d06e85b1aeff4573c060wrowe int nsd;

cf6ef072483172309861d06e85b1aeff4573c060wrowe apr_get_os_sock(&nsd,lr->sd);

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe CreateIoCompletionPort((HANDLE) nsd, AcceptExCompPort, 0, 0);

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe }

d75626f0952c6152a99acd013a4f127d46f0f9edtrawick }

d75626f0952c6152a99acd013a4f127d46f0f9edtrawick}

d75626f0952c6152a99acd013a4f127d46f0f9edtrawick

cf6ef072483172309861d06e85b1aeff4573c060wrowe

cf6ef072483172309861d06e85b1aeff4573c060wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantztypedef struct joblist_s {

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz struct joblist_s *next;

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz int sock;

cf6ef072483172309861d06e85b1aeff4573c060wrowe} joblist;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowetypedef struct globals_s {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe HANDLE jobsemaphore;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe joblist *jobhead;

8aefbd756763807188d2e3ce336a8680e4893066wrowe joblist *jobtail;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_lock_t *jobmutex;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe int jobcount;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe} globals;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

8aefbd756763807188d2e3ce336a8680e4893066wroweglobals allowed_globals =

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe{NULL, NULL, NULL, NULL, 0};

4f9c22c4f27571d54197be9674e1fc0d528192aestriker#define MAX_SELECT_ERRORS 100

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe#define PADDED_ADDR_SIZE sizeof(SOCKADDR_IN)+16

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestrikerstatic void add_job(int sock)

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe{

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe joblist *new_job;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe new_job = (joblist *) malloc(sizeof(joblist));

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe if (new_job == NULL) {

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

cf6ef072483172309861d06e85b1aeff4573c060wrowe "Ouch! Out of memory in add_job()!");

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe return;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker new_job->next = NULL;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe new_job->sock = sock;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_lock(allowed_globals.jobmutex);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe if (allowed_globals.jobtail != NULL)

4f9c22c4f27571d54197be9674e1fc0d528192aestriker allowed_globals.jobtail->next = new_job;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe allowed_globals.jobtail = new_job;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (!allowed_globals.jobhead)

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe allowed_globals.jobhead = new_job;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker allowed_globals.jobcount++;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker release_semaphore(allowed_globals.jobsemaphore);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe apr_unlock(allowed_globals.jobmutex);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe}

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowestatic int remove_job(void)

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe{

4f9c22c4f27571d54197be9674e1fc0d528192aestriker joblist *job;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int sock;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe acquire_semaphore(allowed_globals.jobsemaphore);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe apr_lock(allowed_globals.jobmutex);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe if (shutdown_in_progress && !allowed_globals.jobhead) {

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe apr_unlock(allowed_globals.jobmutex);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe return (-1);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe }

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe job = allowed_globals.jobhead;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe ap_assert(job);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe allowed_globals.jobhead = job->next;

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (allowed_globals.jobhead == NULL)

4f9c22c4f27571d54197be9674e1fc0d528192aestriker allowed_globals.jobtail = NULL;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_unlock(allowed_globals.jobmutex);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe sock = job->sock;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe free(job);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe return (sock);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe}

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowestatic void accept_and_queue_connections(void * dummy)

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe{

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int requests_this_child = 0;

38bcc87d9a06e8ba81165421403f275eca4e313btrawick struct timeval tv;

38bcc87d9a06e8ba81165421403f275eca4e313btrawick fd_set main_fds;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int wait_time = 1;

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz int csd;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int nsd = INVALID_SOCKET;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe struct sockaddr_in sa_client;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int count_select_errors = 0;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int rc;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe int clen;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker while (!shutdown_in_progress) {

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe if (ap_max_requests_per_child && (requests_this_child > ap_max_requests_per_child)) {

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe break;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe }

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe tv.tv_sec = wait_time;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe tv.tv_usec = 0;

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz memcpy(&main_fds, &listenfds, sizeof(fd_set));

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz rc = select(listenmaxfd + 1, &main_fds, NULL, NULL, &tv);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (rc == 0 || (rc == SOCKET_ERROR && APR_STATUS_IS_EINTR(apr_get_netos_error()))) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe count_select_errors = 0; /* reset count of errors */

8aefbd756763807188d2e3ce336a8680e4893066wrowe continue;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe else if (rc == SOCKET_ERROR) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* A "real" error occurred, log it and increment the count of

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_INFO, apr_get_netos_error(), server_conf,

cf6ef072483172309861d06e85b1aeff4573c060wrowe "select failed with error %d", apr_get_netos_error());

cf6ef072483172309861d06e85b1aeff4573c060wrowe count_select_errors++;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (count_select_errors > MAX_SELECT_ERRORS) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker shutdown_in_progress = 1;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz ap_log_error(APLOG_MARK, APLOG_ERR, apr_get_netos_error(), server_conf,

cf6ef072483172309861d06e85b1aeff4573c060wrowe "Too many errors in select loop. Child process exiting.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe break;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe } else {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_listen_rec *lr;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

4f9c22c4f27571d54197be9674e1fc0d528192aestriker lr = find_ready_listener(&main_fds);

548b2980e83f609186a76e98fb245d02e8547bc3jerenkrantz if (lr != NULL) {

548b2980e83f609186a76e98fb245d02e8547bc3jerenkrantz /* fetch the native socket descriptor */

4fca95918a9c0ae93593806544b425d0adc2fcc3wrowe apr_get_os_sock(&nsd, lr->sd);

548b2980e83f609186a76e98fb245d02e8547bc3jerenkrantz }

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz }

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz do {

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar clen = sizeof(sa_client);

8aefbd756763807188d2e3ce336a8680e4893066wrowe csd = accept(nsd, (struct sockaddr *) &sa_client, &clen);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (csd == INVALID_SOCKET) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe csd = -1;

4fca95918a9c0ae93593806544b425d0adc2fcc3wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe } while (csd < 0 && APR_STATUS_IS_EINTR(apr_get_netos_error()));

8aefbd756763807188d2e3ce336a8680e4893066wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (csd < 0) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (APR_STATUS_IS_ECONNABORTED(apr_get_netos_error())) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_ERR, apr_get_netos_error(), server_conf,

8aefbd756763807188d2e3ce336a8680e4893066wrowe "accept: (client socket)");

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe else {

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar add_job(csd);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe requests_this_child++;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

8aefbd756763807188d2e3ce336a8680e4893066wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe SetEvent(exit_event);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker}

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowestatic PCOMP_CONTEXT win9x_get_connection(PCOMP_CONTEXT context)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe{

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe int len;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

f08810eff40a2bddd2bc0103453c4ae775ea62bewrowe if (context == NULL) {

f08810eff40a2bddd2bc0103453c4ae775ea62bewrowe /* allocate the completion context and the transaction pool */

f08810eff40a2bddd2bc0103453c4ae775ea62bewrowe context = apr_pcalloc(pconf, sizeof(COMP_CONTEXT));

f08810eff40a2bddd2bc0103453c4ae775ea62bewrowe if (!context) {

f08810eff40a2bddd2bc0103453c4ae775ea62bewrowe ap_log_error(APLOG_MARK,APLOG_ERR, apr_get_os_error(), server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "win9x_get_connection: apr_pcalloc() failed. Process will exit.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return NULL;

8aefbd756763807188d2e3ce336a8680e4893066wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_create_pool(&context->ptrans, pconf);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe while (1) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_clear_pool(context->ptrans);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->accept_socket = remove_job();

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->accept_socket == -1) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return NULL;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe len = sizeof(struct sockaddr);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->sa_server = apr_palloc(context->ptrans, len);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (getsockname(context->accept_socket,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->sa_server, &len)== SOCKET_ERROR) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_WARNING, apr_get_netos_error(), server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "getsockname failed");

8aefbd756763807188d2e3ce336a8680e4893066wrowe continue;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker len = sizeof(struct sockaddr);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->sa_client = apr_palloc(context->ptrans, len);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if ((getpeername(context->accept_socket,

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar context->sa_client, &len)) == SOCKET_ERROR) {

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar ap_log_error(APLOG_MARK, APLOG_WARNING, apr_get_netos_error(), server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "getpeername failed");

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar memset(&context->sa_client, '\0', sizeof(context->sa_client));

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* do we NEED_DUPPED_CSD ?? */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return context;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe}

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

8aefbd756763807188d2e3ce336a8680e4893066wrowestatic void drain_acceptex_complport(HANDLE hComplPort, BOOLEAN bCleanUp)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe{

4f9c22c4f27571d54197be9674e1fc0d528192aestriker LPOVERLAPPED pol;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz PCOMP_CONTEXT context;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz int rc;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker DWORD BytesRead;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz DWORD CompKey;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe while (1) {

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz context = NULL;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz rc = GetQueuedCompletionStatus(hComplPort, &BytesRead, &CompKey,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz &pol, 1000);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (!rc) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker rc = apr_get_os_error();

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (rc == APR_FROM_OS_ERROR(ERROR_OPERATION_ABORTED)) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_DEBUG, APR_SUCCESS, server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "Child %d: Draining an ABORTED packet off "

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "the AcceptEx completion port.", my_pid);

8aefbd756763807188d2e3ce336a8680e4893066wrowe continue;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe break;

8aefbd756763807188d2e3ce336a8680e4893066wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_INFO, APR_SUCCESS, server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "Child %d: Draining and discarding an active connection "

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "off the AcceptEx completion port.", my_pid);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context = (PCOMP_CONTEXT) pol;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context && bCleanUp) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* It is only valid to clean-up in the process that initiated the I/O */

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar closesocket(context->accept_socket);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe CloseHandle(context->Overlapped.hEvent);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe}

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowestatic int create_acceptex_context(apr_pool_t *_pconf, ap_listen_rec *lr)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe{

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe PCOMP_CONTEXT context;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker DWORD BytesRead;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe SOCKET nsd;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe int lasterror;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* allocate the completion context */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context = apr_pcalloc(_pconf, sizeof(COMP_CONTEXT));

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (!context) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK,APLOG_ERR, apr_get_os_error(), server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "create_acceptex_context: apr_pcalloc() failed. Process will exit.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return -1;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /* initialize the completion context */

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz context->lr = lr;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->Overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->Overlapped.hEvent == NULL) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK,APLOG_ERR, apr_get_os_error(), server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "create_acceptex_context: CreateEvent() failed. Process will exit.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return -1;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* create and initialize the accept socket */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_get_os_sock(&nsd, context->lr->sd);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar context->accept_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (context->accept_socket == INVALID_SOCKET) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK,APLOG_ERR, apr_get_netos_error(), server_conf,

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar "create_acceptex_context: socket() failed. Process will exit.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return -1;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* SO_UPDATE_ACCEPT_CONTEXT is required for shutdown() to work */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (setsockopt(context->accept_socket, SOL_SOCKET,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker SO_UPDATE_ACCEPT_CONTEXT, (char *)&nsd,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz sizeof(nsd))) {

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz ap_log_error(APLOG_MARK, APLOG_ERR, apr_get_netos_error(), server_conf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker "setsockopt(SO_UPDATE_ACCEPT_CONTEXT) failed.");

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz /* Not a failure condition. Keep running. */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_create_pool(&context->ptrans, _pconf);

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

c2cf53a40a9814eb91db2cdf820f97d943f21628coar /* recv_buf must be large enough to hold the remote and local

4f9c22c4f27571d54197be9674e1fc0d528192aestriker context->recv_buf = apr_pcalloc(_pconf, 2*PADDED_ADDR_SIZE);

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz context->recv_buf_size = 0;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz /* AcceptEx on the completion context. The completion context will be signaled

2787ef5edc27fa4f6777ba8d51aa48fd9fdf54bbwrowe if (!AcceptEx(nsd, context->accept_socket,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz context->recv_buf,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz context->recv_buf_size,

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz PADDED_ADDR_SIZE, PADDED_ADDR_SIZE,

2787ef5edc27fa4f6777ba8d51aa48fd9fdf54bbwrowe &BytesRead,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker (LPOVERLAPPED) context)) {

2787ef5edc27fa4f6777ba8d51aa48fd9fdf54bbwrowe lasterror = apr_get_netos_error();

2787ef5edc27fa4f6777ba8d51aa48fd9fdf54bbwrowe if (lasterror != APR_FROM_OS_ERROR(ERROR_IO_PENDING)) {

2787ef5edc27fa4f6777ba8d51aa48fd9fdf54bbwrowe ap_log_error(APLOG_MARK,APLOG_ERR, lasterror, server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "create_acceptex_context: AcceptEx failed. Process will exit.");

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return -1;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

8aefbd756763807188d2e3ce336a8680e4893066wrowe lr->count++;

2520f59894a3e07fefa881ef68aaded763a8d447ben

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz return 0;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar}

8aefbd756763807188d2e3ce336a8680e4893066wrowestatic apr_inline apr_status_t reset_acceptex_context(PCOMP_CONTEXT context)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe{

8aefbd756763807188d2e3ce336a8680e4893066wrowe DWORD BytesRead;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar SOCKET nsd;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe int rc, i;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* reset the buffer pools */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_clear_pool(context->ptrans);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->sock = NULL;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* recreate and initialize the accept socket if it is not being reused */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_get_os_sock(&nsd, context->lr->sd);

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* AcceptEx on the completion context. The completion context will be signaled

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe for (i=0; i<2; i++) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->accept_socket == INVALID_SOCKET) {

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz context->accept_socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz if (context->accept_socket == INVALID_SOCKET) {

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz rc = apr_get_netos_error();

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz ap_log_error(APLOG_MARK,APLOG_ERR, rc, server_conf,

8aefbd756763807188d2e3ce336a8680e4893066wrowe "reset_acceptex_context: socket() failed. Process will exit.");

4f9c22c4f27571d54197be9674e1fc0d528192aestriker return rc;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* SO_UPDATE_ACCEPT_CONTEXT is required for shutdown() to work */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (setsockopt(context->accept_socket, SOL_SOCKET,

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar SO_UPDATE_ACCEPT_CONTEXT, (char *)&nsd, sizeof(nsd))) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_WARNING, apr_get_netos_error(),

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar server_conf,

8aefbd756763807188d2e3ce336a8680e4893066wrowe "setsockopt(SO_UPDATE_ACCEPT_CONTEXT) failed.");

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (!AcceptEx(nsd, context->accept_socket,

cf6ef072483172309861d06e85b1aeff4573c060wrowe context->recv_buf,

cf6ef072483172309861d06e85b1aeff4573c060wrowe context->recv_buf_size,

cf6ef072483172309861d06e85b1aeff4573c060wrowe PADDED_ADDR_SIZE,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker PADDED_ADDR_SIZE,

cf6ef072483172309861d06e85b1aeff4573c060wrowe &BytesRead,

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe (LPOVERLAPPED) context)) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker rc = apr_get_netos_error();

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe if (rc != APR_FROM_OS_ERROR(ERROR_IO_PENDING)) {

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe ap_log_error(APLOG_MARK, APLOG_DEBUG, rc, server_conf,

cf6ef072483172309861d06e85b1aeff4573c060wrowe "reset_acceptex_context: AcceptEx failed for "

cf6ef072483172309861d06e85b1aeff4573c060wrowe "listening socket: %d and accept socket: %d. Getting a new accept socket.",

cf6ef072483172309861d06e85b1aeff4573c060wrowe nsd, context->accept_socket);

cf6ef072483172309861d06e85b1aeff4573c060wrowe closesocket(context->accept_socket);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->accept_socket = INVALID_SOCKET;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe continue;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe break;

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

cf6ef072483172309861d06e85b1aeff4573c060wrowe context->lr->count++;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return APR_SUCCESS;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe}

c2cf53a40a9814eb91db2cdf820f97d943f21628coarstatic PCOMP_CONTEXT winnt_get_connection(PCOMP_CONTEXT context)

c2cf53a40a9814eb91db2cdf820f97d943f21628coar{

8aefbd756763807188d2e3ce336a8680e4893066wrowe int requests_this_child = 0;

cf6ef072483172309861d06e85b1aeff4573c060wrowe int rc;

8aefbd756763807188d2e3ce336a8680e4893066wrowe LPOVERLAPPED pol;

8aefbd756763807188d2e3ce336a8680e4893066wrowe DWORD CompKey;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe DWORD BytesRead;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (context != NULL) {

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (shutdown_in_progress) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /* Clean-up the AcceptEx completion context */

cf6ef072483172309861d06e85b1aeff4573c060wrowe CloseHandle(context->Overlapped.hEvent);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (context->accept_socket != INVALID_SOCKET)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe closesocket(context->accept_socket);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe else {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* Prepare the completion context for reuse */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if ((rc = reset_acceptex_context(context)) != APR_SUCCESS) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK, APLOG_CRIT, rc, server_conf,

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe "Child %d: winnt_get_connection: reset_acceptex_context failed.",

69adb3d949e3dd17c0492a01fc2cf298832c7eefwrowe my_pid);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->accept_socket != INVALID_SOCKET)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe closesocket(context->accept_socket);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe CloseHandle(context->Overlapped.hEvent);

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Probably should just die now... */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker }

cf6ef072483172309861d06e85b1aeff4573c060wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* May need to atomize the workers_may_exit check with the

cadddb2c31d24d48f4017db4df0a29687432326cwrowe if (workers_may_exit) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe return NULL;

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

0e58e92812f2f679d6bf2ff66cbcfa6c1d1e14bbjerenkrantz g_blocked_threads++;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe while (1) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe rc = GetQueuedCompletionStatus(AcceptExCompPort, &BytesRead, &CompKey,

cf6ef072483172309861d06e85b1aeff4573c060wrowe &pol, INFINITE);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (!rc) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker rc = apr_get_os_error();

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (rc != APR_FROM_OS_ERROR(ERROR_OPERATION_ABORTED)) {

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawick /* Is this a deadly condition?

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe ap_log_error(APLOG_MARK,APLOG_DEBUG, rc, server_conf,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe "Child %d: - GetQueuedCompletionStatus() failed",

cf6ef072483172309861d06e85b1aeff4573c060wrowe my_pid);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* Reset the completion context */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (pol) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context = (PCOMP_CONTEXT) pol;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->accept_socket != INVALID_SOCKET)

cf6ef072483172309861d06e85b1aeff4573c060wrowe closesocket(context->accept_socket);

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawick if ((rc = reset_acceptex_context(context)) != APR_SUCCESS) {

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_CRIT, rc, server_conf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker "Child %d: winnt_get_connection: reset_acceptex_context failed.",

4f9c22c4f27571d54197be9674e1fc0d528192aestriker my_pid);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->accept_socket != INVALID_SOCKET)

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe closesocket(context->accept_socket);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe CloseHandle(context->Overlapped.hEvent);

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Probably should just die now... */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe else {

cf6ef072483172309861d06e85b1aeff4573c060wrowe /* Sometimes we catch ERROR_OPERATION_ABORTED completion packets

cf6ef072483172309861d06e85b1aeff4573c060wrowe ap_log_error(APLOG_MARK,APLOG_DEBUG, rc, server_conf,

cf6ef072483172309861d06e85b1aeff4573c060wrowe "Child %d: - Draining ERROR_OPERATION_ABORTED packet off "

cf6ef072483172309861d06e85b1aeff4573c060wrowe "the completion port.", my_pid);

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe continue;

cf6ef072483172309861d06e85b1aeff4573c060wrowe }

cf6ef072483172309861d06e85b1aeff4573c060wrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker if (CompKey != 0) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe /* CompKey == my_pid means this thread was unblocked by

cf6ef072483172309861d06e85b1aeff4573c060wrowe if (CompKey == my_pid) {

cf6ef072483172309861d06e85b1aeff4573c060wrowe g_blocked_threads--;

cf6ef072483172309861d06e85b1aeff4573c060wrowe return NULL;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* Sometimes we catch shutdown io completion packets

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe continue;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker context = (PCOMP_CONTEXT) pol;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe break;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe g_blocked_threads--;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* Check to see if we need to create more completion contexts,

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar if (!shutdown_in_progress) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_lock(allowed_globals.jobmutex);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe context->lr->count--;

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe if (context->lr->count < 2) {

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe SetEvent(maintenance_event);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe apr_unlock(allowed_globals.jobmutex);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe }

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe /* Received a connection */

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe GetAcceptExSockaddrs(context->recv_buf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker context->recv_buf_size,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe PADDED_ADDR_SIZE,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe PADDED_ADDR_SIZE,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe &context->sa_server,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe &context->sa_server_len,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe &context->sa_client,

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe &context->sa_client_len);

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar return context;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

e4a3f3c2f080cac75a15a6454cca429b8161c050wrowe}

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

c2cf53a40a9814eb91db2cdf820f97d943f21628coarstatic void worker_main(int thread_num)

c2cf53a40a9814eb91db2cdf820f97d943f21628coar{

c2cf53a40a9814eb91db2cdf820f97d943f21628coar PCOMP_CONTEXT context = NULL;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar apr_os_sock_info_t sockinfo;

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe while (1) {

8aefbd756763807188d2e3ce336a8680e4893066wrowe conn_rec *c;

8aefbd756763807188d2e3ce336a8680e4893066wrowe apr_int32_t disconnected;

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe ap_update_child_status(0, thread_num, SERVER_READY,

5bb29f57ae0184d2b3c1cdf35132f8ceb011f882wrowe (request_rec *) NULL);

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe /* Grab a connection off the network */

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (osver.dwPlatformId == VER_PLATFORM_WIN32_WINDOWS) {

c2cf53a40a9814eb91db2cdf820f97d943f21628coar context = win9x_get_connection(context);

c2cf53a40a9814eb91db2cdf820f97d943f21628coar }

2d399cd7535887fceaa9f8f116eb98ce68ddd602trawick else {

c2cf53a40a9814eb91db2cdf820f97d943f21628coar context = winnt_get_connection(context);

8aefbd756763807188d2e3ce336a8680e4893066wrowe }

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe if (!context)

8aefbd756763807188d2e3ce336a8680e4893066wrowe break;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe sock_disable_nagle(context->accept_socket);

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe sockinfo.os_sock = &context->accept_socket;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe sockinfo.local = context->sa_server;

1b315ee865b0f11e582beb64127ca3a99a319d2fwrowe sockinfo.remote = context->sa_client;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar sockinfo.family = APR_INET;

0540a0b469147b52e858587270dba31c2aaa9e09wrowe sockinfo.type = SOCK_STREAM;

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar apr_make_os_sock(&context->sock, &sockinfo, context->ptrans);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar

0540a0b469147b52e858587270dba31c2aaa9e09wrowe ap_update_child_status(0, thread_num,

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar SERVER_BUSY_READ, (request_rec *) NULL);

0540a0b469147b52e858587270dba31c2aaa9e09wrowe

0540a0b469147b52e858587270dba31c2aaa9e09wrowe c = ap_new_connection(context->ptrans, server_conf, context->sock,

a9a4544168a37b43bd180b3703ccee995f27a80awrowe thread_num);

0540a0b469147b52e858587270dba31c2aaa9e09wrowe

0540a0b469147b52e858587270dba31c2aaa9e09wrowe ap_process_connection(c);

0540a0b469147b52e858587270dba31c2aaa9e09wrowe

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar apr_getsocketopt(context->sock, APR_SO_DISCONNECTED, &disconnected);

0540a0b469147b52e858587270dba31c2aaa9e09wrowe if (!disconnected) {

0540a0b469147b52e858587270dba31c2aaa9e09wrowe context->accept_socket = INVALID_SOCKET;

0540a0b469147b52e858587270dba31c2aaa9e09wrowe ap_lingering_close(c);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

0540a0b469147b52e858587270dba31c2aaa9e09wrowe }

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe

0540a0b469147b52e858587270dba31c2aaa9e09wrowe ap_update_child_status(0, thread_num, SERVER_DEAD, (request_rec *) NULL);

8aefbd756763807188d2e3ce336a8680e4893066wrowe

8aefbd756763807188d2e3ce336a8680e4893066wrowe ap_log_error(APLOG_MARK, APLOG_DEBUG, APR_SUCCESS, server_conf,

0540a0b469147b52e858587270dba31c2aaa9e09wrowe "Child %d: Thread exiting.", my_pid);

a2a0abd88b19e042a3eb2a9fa1702c25ad51303dwrowe#if 0

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

948096a99010fccf648814fecf38f75c689172d7wrowe SetEvent(exit_event);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb#endif

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb /* TODO: Add code to clean-up completion contexts here */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker}

0540a0b469147b52e858587270dba31c2aaa9e09wrowe

948096a99010fccf648814fecf38f75c689172d7wrowestatic void cleanup_thread(thread *handles, int *thread_cnt, int thread_to_clean)

948096a99010fccf648814fecf38f75c689172d7wrowe{

948096a99010fccf648814fecf38f75c689172d7wrowe int i;

948096a99010fccf648814fecf38f75c689172d7wrowe

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe CloseHandle(handles[thread_to_clean]);

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe for (i = thread_to_clean; i < ((*thread_cnt) - 1); i++)

053497224246c4dbef9af594cacf5c00ed271e6cwrowe handles[i] = handles[i + 1];

0540a0b469147b52e858587270dba31c2aaa9e09wrowe (*thread_cnt)--;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz}

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb

b38846b15c8891c6dec44dcc4f96ca40721bf663rbbstatic void create_listeners()

42da244268b11ec661b528510f80a18b73c51727brianp{

42da244268b11ec661b528510f80a18b73c51727brianp#define NUM_LISTENERS 5

948096a99010fccf648814fecf38f75c689172d7wrowe ap_listen_rec *lr;

948096a99010fccf648814fecf38f75c689172d7wrowe for (lr = ap_listeners; lr != NULL; lr = lr->next) {

948096a99010fccf648814fecf38f75c689172d7wrowe while (lr->count < NUM_LISTENERS) {

948096a99010fccf648814fecf38f75c689172d7wrowe if (create_acceptex_context(pconf, lr) == -1) {

948096a99010fccf648814fecf38f75c689172d7wrowe ap_log_error(APLOG_MARK,APLOG_ERR, apr_get_os_error(), server_conf,

948096a99010fccf648814fecf38f75c689172d7wrowe "Unable to create an AcceptEx completion context -- process will exit");

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz signal_parent(0); /* tell parent to die */

948096a99010fccf648814fecf38f75c689172d7wrowe }

948096a99010fccf648814fecf38f75c689172d7wrowe }

948096a99010fccf648814fecf38f75c689172d7wrowe }

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz}

948096a99010fccf648814fecf38f75c689172d7wrowestatic void child_main()

4f9c22c4f27571d54197be9674e1fc0d528192aestriker{

948096a99010fccf648814fecf38f75c689172d7wrowe apr_status_t status;

948096a99010fccf648814fecf38f75c689172d7wrowe HANDLE child_events[2];

053497224246c4dbef9af594cacf5c00ed271e6cwrowe char* exit_event_name;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe int nthreads = ap_threads_per_child;

948096a99010fccf648814fecf38f75c689172d7wrowe int tid;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe thread *child_handles;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker int rv;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe time_t end_time;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe int i;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe int cld;

a9a4544168a37b43bd180b3703ccee995f27a80awrowe apr_pool_t *pchild;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar /* Set up the scoreboard. The scoreboard in this MPM only applies to the

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar ap_restart_time = apr_now();

948096a99010fccf648814fecf38f75c689172d7wrowe ap_create_scoreboard(pconf, SB_NOT_SHARED);

948096a99010fccf648814fecf38f75c689172d7wrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /* This is the child process or we are running in single process

0540a0b469147b52e858587270dba31c2aaa9e09wrowe exit_event_name = apr_psprintf(pconf, "apC%d", my_pid);

948096a99010fccf648814fecf38f75c689172d7wrowe setup_signal_names(apr_psprintf(pconf,"ap%d", parent_pid));

aa047239dedf0d26e8efecfade32e7337f35df19wrowe

948096a99010fccf648814fecf38f75c689172d7wrowe if (one_process) {

948096a99010fccf648814fecf38f75c689172d7wrowe /* Single process mode */

948096a99010fccf648814fecf38f75c689172d7wrowe apr_create_lock(&start_mutex,APR_MUTEX, APR_CROSS_PROCESS,signal_name_prefix,pconf);

948096a99010fccf648814fecf38f75c689172d7wrowe exit_event = CreateEvent(NULL, TRUE, FALSE, exit_event_name);

948096a99010fccf648814fecf38f75c689172d7wrowe

053497224246c4dbef9af594cacf5c00ed271e6cwrowe setup_listeners(server_conf);

0540a0b469147b52e858587270dba31c2aaa9e09wrowe bind_listeners_to_completion_port();

053497224246c4dbef9af594cacf5c00ed271e6cwrowe }

4f9c22c4f27571d54197be9674e1fc0d528192aestriker else {

0540a0b469147b52e858587270dba31c2aaa9e09wrowe /* Child process mode */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker apr_child_init_lock(&start_mutex, signal_name_prefix, pconf);

aa047239dedf0d26e8efecfade32e7337f35df19wrowe exit_event = OpenEvent(EVENT_ALL_ACCESS, FALSE, exit_event_name);

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz ap_log_error(APLOG_MARK, APLOG_INFO, APR_SUCCESS, server_conf,

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb "Child %d: exit_event_name = %s", my_pid, exit_event_name);

053497224246c4dbef9af594cacf5c00ed271e6cwrowe

4f9c22c4f27571d54197be9674e1fc0d528192aestriker setup_inherited_listeners(server_conf);

053497224246c4dbef9af594cacf5c00ed271e6cwrowe }

053497224246c4dbef9af594cacf5c00ed271e6cwrowe

053497224246c4dbef9af594cacf5c00ed271e6cwrowe /* Initialize the child_events */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker maintenance_event = CreateEvent(NULL, TRUE, FALSE, NULL);

c2cf53a40a9814eb91db2cdf820f97d943f21628coar child_events[0] = exit_event;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar child_events[1] = maintenance_event;

c2cf53a40a9814eb91db2cdf820f97d943f21628coar

c2cf53a40a9814eb91db2cdf820f97d943f21628coar ap_assert(start_mutex);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_assert(exit_event);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_assert(maintenance_event);

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz apr_create_pool(&pchild, pconf);

053497224246c4dbef9af594cacf5c00ed271e6cwrowe allowed_globals.jobsemaphore = create_semaphore(0);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb apr_create_lock(&allowed_globals.jobmutex, APR_MUTEX, APR_INTRAPROCESS, NULL, pchild);

948096a99010fccf648814fecf38f75c689172d7wrowe

948096a99010fccf648814fecf38f75c689172d7wrowe /*

948096a99010fccf648814fecf38f75c689172d7wrowe status = apr_lock(start_mutex);

948096a99010fccf648814fecf38f75c689172d7wrowe if (status != APR_SUCCESS) {

948096a99010fccf648814fecf38f75c689172d7wrowe ap_log_error(APLOG_MARK,APLOG_ERR, status, server_conf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker "Child %d: Failed to acquire the start_mutex. Process will exit.", my_pid);

948096a99010fccf648814fecf38f75c689172d7wrowe signal_parent(0); /* tell parent to die */

948096a99010fccf648814fecf38f75c689172d7wrowe exit(0);

948096a99010fccf648814fecf38f75c689172d7wrowe }

948096a99010fccf648814fecf38f75c689172d7wrowe ap_log_error(APLOG_MARK,APLOG_INFO, APR_SUCCESS, server_conf,

948096a99010fccf648814fecf38f75c689172d7wrowe "Child %d: Acquired the start mutex.", my_pid);

948096a99010fccf648814fecf38f75c689172d7wrowe

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb /* Create the worker thread pool */

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar ap_log_error(APLOG_MARK,APLOG_INFO, APR_SUCCESS, server_conf,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker "Child %d: Starting %d worker threads.", my_pid, nthreads);

948096a99010fccf648814fecf38f75c689172d7wrowe child_handles = (thread) alloca(nthreads * sizeof(int));

0540a0b469147b52e858587270dba31c2aaa9e09wrowe for (i = 0; i < nthreads; i++) {

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar ap_update_child_status(0, i, SERVER_STARTING, (request_rec *) NULL);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar child_handles[i] = (thread) _beginthreadex(NULL, 0, (LPTHREAD_START_ROUTINE) worker_main,

0540a0b469147b52e858587270dba31c2aaa9e09wrowe (void *) i, 0, &tid);

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

696218c49632c863d18b25fa52ab63617088cb38wrowe

948096a99010fccf648814fecf38f75c689172d7wrowe /* Begin accepting connections */

0540a0b469147b52e858587270dba31c2aaa9e09wrowe if (osver.dwPlatformId == VER_PLATFORM_WIN32_WINDOWS) {

948096a99010fccf648814fecf38f75c689172d7wrowe /* Win95/98: Start the accept thread */

948096a99010fccf648814fecf38f75c689172d7wrowe _beginthreadex(NULL, 0, (LPTHREAD_START_ROUTINE) accept_and_queue_connections,

4f9c22c4f27571d54197be9674e1fc0d528192aestriker (void *) i, 0, &tid);

948096a99010fccf648814fecf38f75c689172d7wrowe } else {

948096a99010fccf648814fecf38f75c689172d7wrowe /* Windows NT/2000: Create AcceptEx completion contexts */

053497224246c4dbef9af594cacf5c00ed271e6cwrowe create_listeners();

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar }

948096a99010fccf648814fecf38f75c689172d7wrowe

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar /* Wait for one of three events:

731344ed8f3677d1661c261ca5fcdd2ee3dbc74ccoar while (1) {

948096a99010fccf648814fecf38f75c689172d7wrowe rv = WaitForMultipleObjects(2, (HANDLE *) child_events, FALSE, INFINITE);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb cld = rv - WAIT_OBJECT_0;

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb if (rv == WAIT_FAILED) {

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb /* Something serious is wrong */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb ap_log_error(APLOG_MARK, APLOG_CRIT, apr_get_os_error(), server_conf,

a2a0abd88b19e042a3eb2a9fa1702c25ad51303dwrowe "Child %d: WAIT_FAILED -- shutting down server");

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb break;

aa047239dedf0d26e8efecfade32e7337f35df19wrowe }

aa047239dedf0d26e8efecfade32e7337f35df19wrowe else if (rv == WAIT_TIMEOUT) {

aa047239dedf0d26e8efecfade32e7337f35df19wrowe /* Hey, this cannot happen */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_CRIT, APR_SUCCESS, server_conf,

0540a0b469147b52e858587270dba31c2aaa9e09wrowe "Child %d: WAIT_TIMEOUT -- shutting down server", my_pid);

aa047239dedf0d26e8efecfade32e7337f35df19wrowe break;

aa047239dedf0d26e8efecfade32e7337f35df19wrowe }

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb else if (cld == 0) {

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe /* Exit event was signaled */

4f9c22c4f27571d54197be9674e1fc0d528192aestriker ap_log_error(APLOG_MARK, APLOG_INFO, APR_SUCCESS, server_conf,

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe "Child %d: Exit event signaled. Child process is ending.", my_pid);

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe break;

b5bd19d82874782007a2f9bcb19341a483c1270cwrowe }

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe else {

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe /* Child maintenance event signaled */

dc8692c6c0ca616a09aa12dad005f2ef23baa1a0wrowe if (osver.dwPlatformId != VER_PLATFORM_WIN32_WINDOWS) {

a2b181763cb35fd899feb4a436aeadaa80bf91eabrianp create_listeners();

aa047239dedf0d26e8efecfade32e7337f35df19wrowe }

aa047239dedf0d26e8efecfade32e7337f35df19wrowe ResetEvent(maintenance_event);

aa047239dedf0d26e8efecfade32e7337f35df19wrowe ap_log_error(APLOG_MARK, APLOG_INFO, APR_SUCCESS, server_conf,

aa047239dedf0d26e8efecfade32e7337f35df19wrowe "Child %d: Child maintenance event signaled.", my_pid);

aa047239dedf0d26e8efecfade32e7337f35df19wrowe }

0540a0b469147b52e858587270dba31c2aaa9e09wrowe }

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz

aa047239dedf0d26e8efecfade32e7337f35df19wrowe /* Setting is_graceful will close keep-alive connections */

aa047239dedf0d26e8efecfade32e7337f35df19wrowe is_graceful = 1;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker

aa047239dedf0d26e8efecfade32e7337f35df19wrowe /* Shutdown the worker threads */

aa047239dedf0d26e8efecfade32e7337f35df19wrowe if (osver.dwPlatformId == VER_PLATFORM_WIN32_WINDOWS) {

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb /* workers_may_exit = 1; Not used on Win9x */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb shutdown_in_progress = 1;

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz for (i = 0; i < nthreads; i++) {

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb add_job(-1);

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb }

d4abb06ac220bb280ae996b6d21bbd257db51bb1jerenkrantz }

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb else { /* Windows NT/2000 */

b38846b15c8891c6dec44dcc4f96ca40721bf663rbb SOCKET nsd;

aa047239dedf0d26e8efecfade32e7337f35df19wrowe ap_listen_rec *lr;

4f9c22c4f27571d54197be9674e1fc0d528192aestriker /*