X-Git-Url: http://git.indexdata.com/?p=idzebra-moved-to-github.git;a=blobdiff_plain;f=util%2Fzebra-lock.c;h=3332edaacb567f0085a9813a42115cb73a68b02f;hp=47b24241d144dc5dc9c21809631d0ae47d445b66;hb=a5c8c78e8671af863fc61b2ad8b24f92f827f7b2;hpb=69da23537c6bb71ab948e079708bf8ea090de73f diff --git a/util/zebra-lock.c b/util/zebra-lock.c index 47b2424..3332eda 100644 --- a/util/zebra-lock.c +++ b/util/zebra-lock.c @@ -1,37 +1,88 @@ +/* This file is part of the Zebra server. + Copyright (C) 1994-2011 Index Data +Zebra 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, or (at your option) any later +version. + +Zebra 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., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA + +*/ + + + +#if HAVE_CONFIG_H +#include +#endif #include +#include #include + int zebra_mutex_init (Zebra_mutex *p) { -#if HAVE_PTHREAD_H + p->state = 1; +#if YAZ_POSIX_THREADS 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 + --(p->state); + if (p->state != 0) + { + fprintf (stderr, "zebra_mutex_destroy. state = %d\n", p->state); + } +#if YAZ_POSIX_THREADS 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 + if (p->state != 1) + { + fprintf (stderr, "zebra_mutex_lock. state = %d\n", p->state); + } +#if YAZ_POSIX_THREADS 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 + if (p->state != 1) + { + fprintf (stderr, "zebra_mutex_unlock. state = %d\n", p->state); + } +#if YAZ_POSIX_THREADS pthread_mutex_unlock (&p->mutex); #endif +#ifdef WIN32 + LeaveCriticalSection (&p->mutex); +#endif return 0; } @@ -39,7 +90,7 @@ int zebra_lock_rdwr_init (Zebra_lock_rdwr *p) { p->readers_reading = 0; p->writers_writing = 0; -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_init (&p->mutex, 0); pthread_cond_init (&p->lock_free, 0); #endif @@ -50,7 +101,7 @@ int zebra_lock_rdwr_destroy (Zebra_lock_rdwr *p) { assert (p->readers_reading == 0); assert (p->writers_writing == 0); -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_destroy (&p->mutex); pthread_cond_destroy (&p->lock_free); #endif @@ -59,7 +110,7 @@ int zebra_lock_rdwr_destroy (Zebra_lock_rdwr *p) int zebra_lock_rdwr_rlock (Zebra_lock_rdwr *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_lock (& p->mutex); while (p->writers_writing) pthread_cond_wait (&p->lock_free, &p->mutex); @@ -71,7 +122,7 @@ int zebra_lock_rdwr_rlock (Zebra_lock_rdwr *p) int zebra_lock_rdwr_wlock (Zebra_lock_rdwr *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_lock (&p->mutex); while (p->writers_writing || p->readers_reading) pthread_cond_wait (&p->lock_free, &p->mutex); @@ -83,7 +134,7 @@ int zebra_lock_rdwr_wlock (Zebra_lock_rdwr *p) int zebra_lock_rdwr_runlock (Zebra_lock_rdwr *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_lock (&p->mutex); if (p->readers_reading == 0) { @@ -103,7 +154,7 @@ int zebra_lock_rdwr_runlock (Zebra_lock_rdwr *p) int zebra_lock_rdwr_wunlock (Zebra_lock_rdwr *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_mutex_lock (&p->mutex); if (p->writers_writing == 0) { @@ -122,7 +173,7 @@ int zebra_lock_rdwr_wunlock (Zebra_lock_rdwr *p) int zebra_mutex_cond_init (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_cond_init (&p->cond, 0); pthread_mutex_init (&p->mutex, 0); #endif @@ -131,7 +182,7 @@ int zebra_mutex_cond_init (Zebra_mutex_cond *p) int zebra_mutex_cond_destroy (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS pthread_cond_destroy (&p->cond); pthread_mutex_destroy (&p->mutex); #endif @@ -140,7 +191,7 @@ int zebra_mutex_cond_destroy (Zebra_mutex_cond *p) int zebra_mutex_cond_lock (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS return pthread_mutex_lock (&p->mutex); #else return 0; @@ -149,7 +200,7 @@ int zebra_mutex_cond_lock (Zebra_mutex_cond *p) int zebra_mutex_cond_unlock (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS return pthread_mutex_unlock (&p->mutex); #else return 0; @@ -158,7 +209,7 @@ int zebra_mutex_cond_unlock (Zebra_mutex_cond *p) int zebra_mutex_cond_wait (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS return pthread_cond_wait (&p->cond, &p->mutex); #else return 0; @@ -167,9 +218,18 @@ int zebra_mutex_cond_wait (Zebra_mutex_cond *p) int zebra_mutex_cond_signal (Zebra_mutex_cond *p) { -#if HAVE_PTHREAD_H +#if YAZ_POSIX_THREADS return pthread_cond_signal (&p->cond); #else return 0; #endif } +/* + * Local variables: + * c-basic-offset: 4 + * c-file-style: "Stroustrup" + * indent-tabs-mode: nil + * End: + * vim: shiftwidth=4 tabstop=8 expandtab + */ +