1
0
mirror of https://github.com/lammertb/libhttp.git synced 2026-01-27 08:02:47 +03:00

Moved WIN32 pthread_mutex_init to own file

This commit is contained in:
Lammert Bies
2016-12-11 18:33:47 +01:00
parent a24a4bce7a
commit 1c92eed805
3 changed files with 83 additions and 45 deletions

View File

@@ -234,6 +234,7 @@ LIB_SOURCES = src/libhttp.c \
src/httplib_worker_thread.c \
src/httplib_write.c \
src/md5.c \
src/pthread_mutex_init.c \
src/sha1.c
LIB_INLINE = src/mod_lua.inl src/md5.inl
APP_SOURCES = src/main.c

View File

@@ -828,56 +828,42 @@ void XX_httplib_set_thread_name(const char *threadName) {
#if defined(_WIN32)
/* Create substitutes for POSIX functions in Win32. */
#if defined(__MINGW32__)
/* Show no warning in case system functions are not used. */
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wunused-function"
#endif
int pthread_mutex_destroy( pthread_mutex_t *mutex ) {
return ( CloseHandle(*mutex) == 0 ) ? -1 : 0;
} /* pthread_mutex_destroy */
static int pthread_mutex_init(pthread_mutex_t *mutex, void *unused) {
(void)unused;
*mutex = CreateMutex(NULL, FALSE, NULL);
return (*mutex == NULL) ? -1 : 0;
}
static int pthread_mutex_destroy(pthread_mutex_t *mutex) {
return (CloseHandle(*mutex) == 0) ? -1 : 0;
}
static int pthread_mutex_lock(pthread_mutex_t *mutex) {
int pthread_mutex_lock( pthread_mutex_t *mutex ) {
return (WaitForSingleObject(*mutex, INFINITE) == WAIT_OBJECT_0) ? 0 : -1;
}
} /* pthread_mutex_lock */
#ifdef ENABLE_UNUSED_PTHREAD_FUNCTIONS
static int pthread_mutex_trylock(pthread_mutex_t *mutex) {
int pthread_mutex_trylock( pthread_mutex_t *mutex ) {
switch (WaitForSingleObject(*mutex, 0)) {
switch ( WaitForSingleObject( *mutex, 0 ) ) {
case WAIT_OBJECT_0: return 0;
case WAIT_TIMEOUT: return -2; /* EBUSY */
}
return -1;
}
#endif
} /* pthread_mutex_trylock */
static int pthread_mutex_unlock(pthread_mutex_t *mutex) {
static int pthread_mutex_unlock( pthread_mutex_t *mutex ) {
return (ReleaseMutex(*mutex) == 0) ? -1 : 0;
}
return ( ReleaseMutex( *mutex ) == 0 ) ? -1 : 0;
} /* pthread_mutex_unlock */
#ifndef WIN_PTHREADS_TIME_H
static int clock_gettime(clockid_t clk_id, struct timespec *tp) {
int clock_gettime( clockid_t clk_id, struct timespec *tp ) {
FILETIME ft;
ULARGE_INTEGER li;
@@ -912,20 +898,24 @@ static int clock_gettime(clockid_t clk_id, struct timespec *tp) {
}
return ok ? 0 : -1;
}
} /* clock_gettime */
#endif
static int pthread_cond_init(pthread_cond_t *cv, const void *unused) {
int pthread_cond_init( pthread_cond_t *cv, const void *unused ) {
(void)unused;
InitializeCriticalSection(&cv->threadIdSec);
cv->waiting_thread = NULL;
return 0;
}
} /* pthread_cond_init */
static int pthread_cond_timedwait(pthread_cond_t *cv, pthread_mutex_t *mutex, const struct timespec *abstime) {
int pthread_cond_timedwait( pthread_cond_t *cv, pthread_mutex_t *mutex, const struct timespec *abstime ) {
struct mg_workerTLS **ptls;
struct mg_workerTLS *tls = (struct mg_workerTLS *)pthread_getspecific(XX_httplib_sTlsKey);
@@ -978,16 +968,18 @@ static int pthread_cond_timedwait(pthread_cond_t *cv, pthread_mutex_t *mutex, co
pthread_mutex_lock(mutex);
return ok ? 0 : -1;
}
} /* pthread_cond_timewait */
static int pthread_cond_wait(pthread_cond_t *cv, pthread_mutex_t *mutex) {
int pthread_cond_wait( pthread_cond_t *cv, pthread_mutex_t *mutex ) {
return pthread_cond_timedwait(cv, mutex, NULL);
}
} /* pthread_cond_wait */
static int pthread_cond_signal(pthread_cond_t *cv) {
int pthread_cond_signal( pthread_cond_t *cv ) {
HANDLE wkup = NULL;
BOOL ok = FALSE;
@@ -1003,20 +995,22 @@ static int pthread_cond_signal(pthread_cond_t *cv) {
LeaveCriticalSection(&cv->threadIdSec);
return ok ? 0 : 1;
}
} /* pthread_cond_signal */
static int pthread_cond_broadcast(pthread_cond_t *cv) {
int pthread_cond_broadcast( pthread_cond_t *cv ) {
EnterCriticalSection(&cv->threadIdSec);
while (cv->waiting_thread) pthread_cond_signal(cv);
LeaveCriticalSection(&cv->threadIdSec);
return 0;
}
} /* pthread_cond_broadcast */
static int pthread_cond_destroy(pthread_cond_t *cv) {
int pthread_cond_destroy( pthread_cond_t *cv ) {
EnterCriticalSection(&cv->threadIdSec);
assert(cv->waiting_thread == NULL);
@@ -1024,7 +1018,8 @@ static int pthread_cond_destroy(pthread_cond_t *cv) {
DeleteCriticalSection(&cv->threadIdSec);
return 0;
}
} /* pthread_cond_destroy */
#ifdef ALTERNATIVE_QUEUE
@@ -1047,7 +1042,7 @@ static int event_signal(void *eventhdl) {
return (int)SetEvent((HANDLE)eventhdl);
}a /* event_signal */
} /* event_signal */
static void event_destroy(void *eventhdl) {

42
src/pthread_mutex_init.c Normal file
View File

@@ -0,0 +1,42 @@
/*
* Copyright (c) 2016 Lammert Bies
* Copyright (c) 2013-2016 the Civetweb developers
* Copyright (c) 2004-2013 Sergey Lyubka
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
* OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
* THE SOFTWARE.
*/
#include "libhttp-private.h"
#if defined(_WIN32)
int pthread_mutex_init( pthread_mutex_t *mutex, void *unused ) {
(void)unused;
*mutex = CreateMutex( NULL, FALSE, NULL );
return (*mutex == NULL) ? -1 : 0;
} /* pthread_mutex_init */
#endif /* _WIN32 */