X-Git-Url: http://git.indexdata.com/?a=blobdiff_plain;f=util%2Fzebra-lock.c;h=769de1babe451abf192b3130f4551c9dede7b356;hb=c4b3b6322c32ee380e63ff06cabaad213952c195;hp=0e08cde91986130eab37566cf3813c1d0bcea641;hpb=c41c84a497ae744aa825a90f144c85b54f1cd4bb;p=idzebra-moved-to-github.git

diff --git a/util/zebra-lock.c b/util/zebra-lock.c
index 0e08cde..769de1b 100644
--- a/util/zebra-lock.c
+++ b/util/zebra-lock.c
@@ -5,25 +5,45 @@
 
 int zebra_mutex_init (Zebra_mutex *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_init (&p->mutex, 0);
+#endif
+#ifdef WIN32
+    InitializeCriticalSection (&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_mutex_destroy (Zebra_mutex *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_destroy (&p->mutex);
+#endif
+#ifdef WIN32
+    DeleteCriticalSection (&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_mutex_lock (Zebra_mutex *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_lock (&p->mutex);
+#endif
+#ifdef WIN32
+    EnterCriticalSection (&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_mutex_unlock (Zebra_mutex *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_unlock (&p->mutex);
+#endif
+#ifdef WIN32
+    LeaveCriticalSection (&p->mutex);
+#endif
     return 0;
 }
 
@@ -31,8 +51,10 @@ int zebra_lock_rdwr_init (Zebra_lock_rdwr *p)
 {
     p->readers_reading = 0;
     p->writers_writing = 0;
+#if HAVE_PTHREAD_H
     pthread_mutex_init (&p->mutex, 0);
     pthread_cond_init (&p->lock_free, 0);
+#endif
     return 0;
 }
 
@@ -40,33 +62,40 @@ int zebra_lock_rdwr_destroy (Zebra_lock_rdwr *p)
 {
     assert (p->readers_reading == 0);
     assert (p->writers_writing == 0);
+#if HAVE_PTHREAD_H
     pthread_mutex_destroy (&p->mutex);
     pthread_cond_destroy (&p->lock_free);
+#endif
     return 0;
 }
 
 int zebra_lock_rdwr_rlock (Zebra_lock_rdwr *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_lock (& p->mutex);
     while (p->writers_writing)
 	pthread_cond_wait (&p->lock_free, &p->mutex);
     p->readers_reading++;
     pthread_mutex_unlock(&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_lock_rdwr_wlock (Zebra_lock_rdwr *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_lock (&p->mutex);
     while (p->writers_writing || p->readers_reading)
 	pthread_cond_wait (&p->lock_free, &p->mutex);
     p->writers_writing++;
     pthread_mutex_unlock (&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_lock_rdwr_runlock (Zebra_lock_rdwr *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_lock (&p->mutex);
     if (p->readers_reading == 0)
     {
@@ -80,11 +109,13 @@ int zebra_lock_rdwr_runlock (Zebra_lock_rdwr *p)
 	    pthread_cond_signal (&p->lock_free);
 	pthread_mutex_unlock (&p->mutex);
     }
+#endif
     return 0;
 }
 
 int zebra_lock_rdwr_wunlock (Zebra_lock_rdwr *p)
 {
+#if HAVE_PTHREAD_H
     pthread_mutex_lock (&p->mutex);
     if (p->writers_writing == 0)
     {
@@ -97,40 +128,60 @@ int zebra_lock_rdwr_wunlock (Zebra_lock_rdwr *p)
 	pthread_cond_broadcast(&p->lock_free);
 	pthread_mutex_unlock(&p->mutex);
     }
+#endif
     return 0;
 }
 
 int zebra_mutex_cond_init (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     pthread_cond_init (&p->cond, 0);
     pthread_mutex_init (&p->mutex, 0);
+#endif
     return 0;
 }
 
 int zebra_mutex_cond_destroy (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     pthread_cond_destroy (&p->cond);
     pthread_mutex_destroy (&p->mutex);
+#endif
     return 0;
 }
 
 int zebra_mutex_cond_lock (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     return pthread_mutex_lock (&p->mutex);
+#else
+    return 0;
+#endif
 }
 
 int zebra_mutex_cond_unlock (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     return pthread_mutex_unlock (&p->mutex);
+#else
+    return 0;
+#endif
 }
 
 int zebra_mutex_cond_wait (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     return pthread_cond_wait (&p->cond, &p->mutex);
+#else
+    return 0;
+#endif
 }
 
 int zebra_mutex_cond_signal (Zebra_mutex_cond *p)
 {
+#if HAVE_PTHREAD_H
     return pthread_cond_signal (&p->cond);
+#else
+    return 0;
+#endif
 }
-