YAZ 5.35.1
condvar.c
Go to the documentation of this file.
1/* This file is part of the YAZ toolkit.
2 * Copyright (C) Index Data
3 * See the file LICENSE for details.
4 */
5
11#if HAVE_CONFIG_H
12#include <config.h>
13#endif
14
15#include <assert.h>
16#include <stdlib.h>
17#include <string.h>
18#include <errno.h>
19#include <stddef.h>
20#include <yaz/xmalloc.h>
21#include <yaz/nmem.h>
22#include <yaz/log.h>
23#include <yaz/mutex.h>
24#include <yaz/gettimeofday.h>
25#ifdef WIN32
26#include <windows.h>
27#include <sys/timeb.h>
28#endif
29#include <time.h>
30
31#if HAVE_SYS_TIME_H
32#include <sys/time.h>
33#endif
34
35#if YAZ_POSIX_THREADS
36#include <pthread.h>
37#endif
38
39#include "mutex-p.h"
40
41struct yaz_cond {
42#ifdef WIN32
43 CONDITION_VARIABLE cond;
44#elif YAZ_POSIX_THREADS
45 pthread_cond_t cond;
46#endif
47};
48
49void yaz_cond_create(YAZ_COND *p)
50{
51#ifdef WIN32
52 *p = (YAZ_COND) malloc(sizeof(**p));
53 InitializeConditionVariable(&(*p)->cond);
54#elif YAZ_POSIX_THREADS
55 *p = (YAZ_COND) malloc(sizeof(**p));
56 pthread_cond_init(&(*p)->cond, 0);
57#else
58 *p = 0;
59#endif
60}
61
62void yaz_cond_destroy(YAZ_COND *p)
63{
64 if (*p)
65 {
66#ifdef WIN32
67#elif YAZ_POSIX_THREADS
68 pthread_cond_destroy(&(*p)->cond);
69#endif
70 free(*p);
71 *p = 0;
72 }
73}
74
75int yaz_cond_wait(YAZ_COND p, YAZ_MUTEX m, const struct timeval *abstime)
76{
77#ifdef WIN32
78 BOOL v;
79 if (abstime)
80 {
81 struct timeval tval_now;
82 int sec, msec;
83
84 yaz_gettimeofday(&tval_now);
85
86 sec = abstime->tv_sec - tval_now.tv_sec;
87 msec = (abstime->tv_usec - tval_now.tv_usec) / 1000;
88 v = SleepConditionVariableCS(&p->cond, &m->handle, sec*1000 + msec);
89 }
90 else
91 v = SleepConditionVariableCS(&p->cond, &m->handle, INFINITE);
92 return v ? 0 : -1;
93#elif YAZ_POSIX_THREADS
94 if (abstime)
95 {
96 struct timespec s;
97 s.tv_sec = abstime->tv_sec;
98 s.tv_nsec = abstime->tv_usec * 1000;
99 return pthread_cond_timedwait(&p->cond, &m->handle, &s);
100 }
101 else
102 return pthread_cond_wait(&p->cond, &m->handle);
103#else
104 return -1;
105#endif
106}
107
108int yaz_cond_signal(YAZ_COND p)
109{
110#ifdef WIN32
111 WakeConditionVariable(&p->cond);
112 return 0;
113#elif YAZ_POSIX_THREADS
114 return pthread_cond_signal(&p->cond);
115#else
116 return -1;
117#endif
118}
119
120int yaz_cond_broadcast(YAZ_COND p)
121{
122#ifdef WIN32
123 WakeAllConditionVariable(&p->cond);
124 return 0;
125#elif YAZ_POSIX_THREADS
126 return pthread_cond_broadcast(&p->cond);
127#else
128 return -1;
129#endif
130}
131
132/*
133 * Local variables:
134 * c-basic-offset: 4
135 * c-file-style: "Stroustrup"
136 * indent-tabs-mode: nil
137 * End:
138 * vim: shiftwidth=4 tabstop=8 expandtab
139 */
140
yaz_cond_destroy
void yaz_cond_destroy(YAZ_COND *p)
destroys condition variable
Definition condvar.c:62
yaz_cond_create
void yaz_cond_create(YAZ_COND *p)
creates condition variable
Definition condvar.c:49
yaz_cond_signal
int yaz_cond_signal(YAZ_COND p)
unblock one thread waiting for block
Definition condvar.c:108
yaz_cond_broadcast
int yaz_cond_broadcast(YAZ_COND p)
unblock all threads waiting for block
Definition condvar.c:120
yaz_cond_wait
int yaz_cond_wait(YAZ_COND p, YAZ_MUTEX m, const struct timeval *abstime)
waits for condition
Definition condvar.c:75
malloc
void * malloc(YYSIZE_T)
free
void free(void *)
errno.h
Header for errno utilities.
yaz_gettimeofday
int yaz_gettimeofday(struct timeval *tval)
gettimeofday
Definition gettimeofday.c:28
gettimeofday.h
Header for gettimeofday wrapper.
log.h
Logging utility.
mutex-p.h
Declares internal definitions of for Mutex functions.
mutex.h
Header for Mutex functions.
YAZ_COND
struct yaz_cond * YAZ_COND
YAZ condition opaque pointer.
Definition mutex.h:45
nmem.h
Header for Nibble Memory functions.
yaz_cond
Definition condvar.c:41
yaz_mutex
Definition mutex-p.h:33
xmalloc.h
Header for memory handling functions.
Generated by doxygen 1.9.8