xdasd_thread.h

Go to the documentation of this file.

/*----------------------------------------------------------------------------
 * Copyright (c) 2006, Novell, Inc.
 * All rights reserved.
 * 
 * Redistribution and use in source and binary forms, with or without 
 * modification, are permitted provided that the following conditions are 
 * met:
 * 
 *     * Redistributions of source code must retain the above copyright 
 *       notice, this list of conditions and the following disclaimer.
 *     * Redistributions in binary form must reproduce the above copyright 
 *       notice, this list of conditions and the following disclaimer in the 
 *       documentation and/or other materials provided with the distribution.
 *     * Neither the name of the Novell nor the names of its contributors 
 *       may be used to endorse or promote products derived from this 
 *       software without specific prior written permission.
 * 
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 
 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 
 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *--------------------------------------------------------------------------*/

#ifndef XDASD_THREAD_H_INCLUDED
#define XDASD_THREAD_H_INCLUDED

#ifdef _WIN32
# define WIN32_LEAN_AND_MEAN
# define _WIN32_WINNT 0x0400
# pragma warning(disable: 4201) /* non-standard extension used : nameless structure/union */
# include <windows.h>

/* mutex */
# define mutex_t         CRITICAL_SECTION
# define mutex_create    InitializeCriticalSection
# define mutex_destroy   DeleteCriticalSection
# define mutex_acquire   EnterCriticalSection
# define mutex_release   LeaveCriticalSection

/* semaphore */
# define sem_t           HANDLE
# define sem_create(y)   CreateSemaphore(0,(y),0x7FFFFFFFL,0)) == 0? -1: 0)
# define sem_destroy     (void)CloseHandle
# define sem_wait(x)     (void)WaitForSingleObject((x),INFINITE)
# define sem_signal(x,y) (void)ReleaseSemaphore((x),(y),0)

#else
# include <pthread.h>

/* mutex */
# define mutex_t         pthread_mutex_t
# define mutex_create(x) (void)pthread_mutex_init((x),0)
# define mutex_destroy   (void)pthread_mutex_destroy
# define mutex_acquire   (void)pthread_mutex_lock
# define mutex_release   (void)pthread_mutex_unlock

/* cv */
# define cv_t            pthread_cond_t
# define cv_create(x)    pthread_cond_init((x),0)
# define cv_destroy      pthread_cond_destroy
# define cv_signal       pthread_cond_signal
# define cv_wait         pthread_cond_wait

#endif

typedef void * thread_t;

thread_t thread_create(void *(*thread_proc)(void *), void * arg);
void * thread_wait(thread_t th);

#ifdef _WIN32

typedef struct cv_t
{
   long waitersBlocked;             /* Number of threads blocked */
   long waitersGone;                /* Number of threads timed out */
   long waitersToUnblock;           /* Number of threads to unblock */
   HANDLE semBlockQueue;            /* Queue up waiting threads */
   HANDLE semBlockLock;             /* Guards access to waiters queue */
   CRITICAL_SECTION csUnblockLock;  /* Guards access to waiters to unblock */
} cv_t;

int cv_create(cv_t * cvp);
void cv_destroy(cv_t * cvp);
int cv_wait(cv_t * cvp, mutex_t * mp);
int cv_signal(cv_t * cvp);
int cv_broadcast(cv_t * cvp);

#else

typedef struct sem_t
{
   pthread_mutex_t lock;
   pthread_cond_t cond;
   int count;
} sem_t;

int sem_create(sem_t * sp, int count);
void sem_destroy(sem_t * sp);
void sem_wait(sem_t * sp);
void sem_signal(sem_t * sp, int count);

#endif

#endif   /* XDASD_THREAD_H_INCLUDED */