if (shutdown_in_progress && !allowed_globals.jobhead) {
apr_thread_mutex_unlock(allowed_globals.jobmutex);
- return (-1);
+ return (INVALID_SOCKET);
}
job = allowed_globals.jobhead;
ap_assert(job);
while (1) {
apr_pool_clear(context->ptrans);
context->accept_socket = remove_job();
- if (context->accept_socket == -1) {
+ if (context->accept_socket == INVALID_SOCKET) {
return NULL;
}
len = sizeof(struct sockaddr);
while (1) {
rv = WaitForSingleObject(context->Overlapped.hEvent, 1000);
if (rv == WAIT_OBJECT_0) {
- if (context->accept_socket == -1) {
+ if (context->accept_socket == INVALID_SOCKET) {
/* socket already closed */
break;
}
/* Shutdown the worker threads */
if (osver.dwPlatformId == VER_PLATFORM_WIN32_WINDOWS) {
for (i = 0; i < threads_created; i++) {
- add_job(-1);
+ add_job(INVALID_SOCKET);
}
}
else { /* Windows NT/2000 */