diff options
Diffstat (limited to 'tests/threads.c')
-rw-r--r-- | tests/threads.c | 122 |
1 files changed, 122 insertions, 0 deletions
diff --git a/tests/threads.c b/tests/threads.c new file mode 100644 index 0000000..98195de --- /dev/null +++ b/tests/threads.c @@ -0,0 +1,122 @@ +/* + threads.c + + Posix and Windows threads + +gSOAP XML Web services tools +Copyright (C) 2000-2009, Robert van Engelen, Genivia Inc., All Rights Reserved. +This part of the software is released under one of the following licenses: +GPL, the gSOAP public license, or Genivia's license for commercial use. +-------------------------------------------------------------------------------- +gSOAP public license. + +The contents of this file are subject to the gSOAP Public License Version 1.3 +(the "License"); you may not use this file except in compliance with the +License. You may obtain a copy of the License at +http://www.cs.fsu.edu/~engelen/soaplicense.html +Software distributed under the License is distributed on an "AS IS" basis, +WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License +for the specific language governing rights and limitations under the License. + +The Initial Developer of the Original Code is Robert A. van Engelen. +Copyright (C) 2000-2009, Robert van Engelen, Genivia Inc., All Rights Reserved. +-------------------------------------------------------------------------------- +GPL license. + +This program is free software; you can redistribute it and/or modify it under +the terms of the GNU General Public License as published by the Free Software +Foundation; either version 2 of the License, or (at your option) any later +version. + +This program is distributed in the hope that it will be useful, but WITHOUT ANY +WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A +PARTICULAR PURPOSE. See the GNU General Public License for more details. + +You should have received a copy of the GNU General Public License along with +this program; if not, write to the Free Software Foundation, Inc., 59 Temple +Place, Suite 330, Boston, MA 02111-1307 USA + +Author contact information: +engelen@genivia.com / engelen@acm.org + +This program is released under the GPL with the additional exemption that +compiling, linking, and/or using OpenSSL is allowed. +-------------------------------------------------------------------------------- +A commercial use license is available from Genivia, Inc., contact@genivia.com +-------------------------------------------------------------------------------- +*/ + +#include "threads.h" + +/******************************************************************************\ + * + * Emulation of POSIX condition variables for WIN32 + * +\******************************************************************************/ + +#ifdef WIN32 + +#ifdef __cplusplus +extern "C" { +#endif + +int emulate_pthread_cond_init(COND_TYPE *cv) +{ + cv->waiters_count_ = 0; + cv->signal_event_ = CreateEvent(NULL, FALSE, FALSE, NULL); + InitializeCriticalSection(&cv->waiters_count_lock_); + + return 0; +} + +int emulate_pthread_cond_destroy(COND_TYPE *cv) +{ + CloseHandle(cv->signal_event_); + DeleteCriticalSection(&cv->waiters_count_lock_); + + return 0; +} + +int emulate_pthread_cond_signal(COND_TYPE *cv) +{ + int have_waiters; + + EnterCriticalSection(&cv->waiters_count_lock_); + have_waiters = cv->waiters_count_ > 0; + LeaveCriticalSection(&cv->waiters_count_lock_); + + if (have_waiters) + return SetEvent(cv->signal_event_) == 0; + + return 0; +} + +int emulate_pthread_cond_wait(COND_TYPE *cv, MUTEX_TYPE *cs) +{ + int result; + + EnterCriticalSection(&cv->waiters_count_lock_); + cv->waiters_count_++; + LeaveCriticalSection(&cv->waiters_count_lock_); + + ReleaseMutex(*cs); + + result = (WaitForSingleObject(cv->signal_event_, INFINITE) == WAIT_FAILED); + + if (!result) + { + EnterCriticalSection(&cv->waiters_count_lock_); + cv->waiters_count_--; + LeaveCriticalSection(&cv->waiters_count_lock_); + + result = (WaitForSingleObject(*cs, INFINITE) == WAIT_FAILED); + } + + return result; +} + +#ifdef __cplusplus +} +#endif + +#endif |