summaryrefslogtreecommitdiff
path: root/tests/threads.c
diff options
context:
space:
mode:
Diffstat (limited to 'tests/threads.c')
-rw-r--r--tests/threads.c122
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