Fix typo for xcql encoding
[yaz-moved-to-github.git] / src / mutex.c
1 /* This file is part of the YAZ toolkit.
2  * Copyright (C) 1995-2013 Index Data
3  * See the file LICENSE for details.
4  */
5
6 /**
7  * \file mutex.c
8  * \brief Implements MUTEX functions
9  *
10  */
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
41 void yaz_mutex_create(YAZ_MUTEX *p)
42 {
43     if (!*p)
44     {
45         *p = (YAZ_MUTEX) malloc(sizeof(**p));
46 #ifdef WIN32
47         InitializeCriticalSection(&(*p)->handle);
48 #elif YAZ_POSIX_THREADS
49         pthread_mutex_init(&(*p)->handle, 0);
50 #endif
51         (*p)->name = 0;
52         (*p)->log_level = 0;
53     }
54 }
55
56 void yaz_mutex_set_name(YAZ_MUTEX p, int log_level, const char *name)
57 {
58     if (p->name)
59         free(p->name);
60     p->name = 0;
61     p->log_level = 0;
62     if (name)
63     {
64         p->name = strdup(name);
65         p->log_level = log_level;
66     }
67 }
68
69 void yaz_mutex_enter(YAZ_MUTEX p)
70 {
71     if (p)
72     {
73 #ifdef WIN32
74         EnterCriticalSection(&p->handle);
75 #elif YAZ_POSIX_THREADS
76         int r = 1; /* signal : not locked (yet) */
77
78         if (p->log_level)
79         {   /* debugging */
80             r = pthread_mutex_trylock(&p->handle);
81             if (r)
82             {
83 #if HAVE_SYS_TIME_H
84                 long long d;
85                 struct timeval tv1, tv2;
86                 gettimeofday(&tv1, 0);
87 #endif
88                 yaz_log(p->log_level,
89                         "yaz_mutex_enter: %p tid=%p name=%s waiting",
90                         p, (void *) pthread_self(), p->name);
91 #if HAVE_SYS_TIME_H
92                 r = pthread_mutex_lock(&p->handle);
93                 gettimeofday(&tv2, 0);
94                 d = 1000000LL * ((long long) tv2.tv_sec - tv1.tv_sec) +
95                     tv2.tv_usec - tv1.tv_usec;
96                 yaz_log(p->log_level, "yaz_mutex_enter: %p tid=%p name=%s "
97                         "lock delay %lld",
98                         p, (void *) pthread_self(), p->name, d);
99 #endif
100             }
101             else
102             {
103                 yaz_log(p->log_level, "yaz_mutex_enter: %p tid=%p name=%s lock",
104                         p, (void *) pthread_self(), p->name);
105             }
106         }
107         if (r)
108         {
109             r = pthread_mutex_lock(&p->handle);
110             if (p->log_level)
111             {
112                 yaz_log(p->log_level, "yaz_mutex_enter: %p tid=%p name=%s lock",
113                         p, (void *) pthread_self(), p->name);
114             }
115         }
116 #endif
117     }
118 }
119
120 void yaz_mutex_leave(YAZ_MUTEX p)
121 {
122     if (p)
123     {
124 #ifdef WIN32
125         LeaveCriticalSection(&p->handle);
126 #elif YAZ_POSIX_THREADS
127         pthread_mutex_unlock(&p->handle);
128         if (p->log_level)
129         {
130             yaz_log(p->log_level,
131                     "yaz_mutex_leave: %p tid=%p name=%s unlock",
132                     p, (void *) pthread_self(), p->name);
133         }
134 #endif
135     }
136 }
137
138 void yaz_mutex_destroy(YAZ_MUTEX *p)
139 {
140     if (*p)
141     {
142 #ifdef WIN32
143         DeleteCriticalSection(&(*p)->handle);
144 #elif YAZ_POSIX_THREADS
145         pthread_mutex_destroy(&(*p)->handle);
146 #endif
147         if ((*p)->name)
148             free((*p)->name);
149         free(*p);
150         *p = 0;
151     }
152 }
153
154 /*
155  * Local variables:
156  * c-basic-offset: 4
157  * c-file-style: "Stroustrup"
158  * indent-tabs-mode: nil
159  * End:
160  * vim: shiftwidth=4 tabstop=8 expandtab
161  */
162