1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski #include "system.h"
25*b1cdbd2cSJim Jagielski
26*b1cdbd2cSJim Jagielski #include <osl/mutex.h>
27*b1cdbd2cSJim Jagielski #include <osl/diagnose.h>
28*b1cdbd2cSJim Jagielski
29*b1cdbd2cSJim Jagielski #include <pthread.h>
30*b1cdbd2cSJim Jagielski #include <stdlib.h>
31*b1cdbd2cSJim Jagielski
32*b1cdbd2cSJim Jagielski #if defined LINUX /* bad hack */
33*b1cdbd2cSJim Jagielski int pthread_mutexattr_setkind_np(pthread_mutexattr_t *, int);
34*b1cdbd2cSJim Jagielski #define pthread_mutexattr_settype pthread_mutexattr_setkind_np
35*b1cdbd2cSJim Jagielski #define PTHREAD_MUTEX_RECURSIVE PTHREAD_MUTEX_RECURSIVE_NP
36*b1cdbd2cSJim Jagielski #endif
37*b1cdbd2cSJim Jagielski
38*b1cdbd2cSJim Jagielski /*
39*b1cdbd2cSJim Jagielski Implementation notes:
40*b1cdbd2cSJim Jagielski oslMutex hides a pointer to the oslMutexImpl structure, which
41*b1cdbd2cSJim Jagielski ist needed to manage recursive locks on a mutex.
42*b1cdbd2cSJim Jagielski
43*b1cdbd2cSJim Jagielski */
44*b1cdbd2cSJim Jagielski
45*b1cdbd2cSJim Jagielski typedef struct _oslMutexImpl
46*b1cdbd2cSJim Jagielski {
47*b1cdbd2cSJim Jagielski pthread_mutex_t mutex;
48*b1cdbd2cSJim Jagielski } oslMutexImpl;
49*b1cdbd2cSJim Jagielski
50*b1cdbd2cSJim Jagielski
51*b1cdbd2cSJim Jagielski /*****************************************************************************/
52*b1cdbd2cSJim Jagielski /* osl_createMutex */
53*b1cdbd2cSJim Jagielski /*****************************************************************************/
osl_createMutex()54*b1cdbd2cSJim Jagielski oslMutex SAL_CALL osl_createMutex()
55*b1cdbd2cSJim Jagielski {
56*b1cdbd2cSJim Jagielski oslMutexImpl* pMutex = (oslMutexImpl*) malloc(sizeof(oslMutexImpl));
57*b1cdbd2cSJim Jagielski pthread_mutexattr_t aMutexAttr;
58*b1cdbd2cSJim Jagielski int nRet=0;
59*b1cdbd2cSJim Jagielski
60*b1cdbd2cSJim Jagielski OSL_ASSERT(pMutex);
61*b1cdbd2cSJim Jagielski
62*b1cdbd2cSJim Jagielski if ( pMutex == 0 )
63*b1cdbd2cSJim Jagielski {
64*b1cdbd2cSJim Jagielski return 0;
65*b1cdbd2cSJim Jagielski }
66*b1cdbd2cSJim Jagielski
67*b1cdbd2cSJim Jagielski pthread_mutexattr_init(&aMutexAttr);
68*b1cdbd2cSJim Jagielski
69*b1cdbd2cSJim Jagielski nRet = pthread_mutexattr_settype(&aMutexAttr, PTHREAD_MUTEX_RECURSIVE);
70*b1cdbd2cSJim Jagielski
71*b1cdbd2cSJim Jagielski nRet = pthread_mutex_init(&(pMutex->mutex), &aMutexAttr);
72*b1cdbd2cSJim Jagielski if ( nRet != 0 )
73*b1cdbd2cSJim Jagielski {
74*b1cdbd2cSJim Jagielski OSL_TRACE("osl_createMutex : mutex init failed. Errno: %d; %s\n",
75*b1cdbd2cSJim Jagielski nRet, strerror(nRet));
76*b1cdbd2cSJim Jagielski
77*b1cdbd2cSJim Jagielski free(pMutex);
78*b1cdbd2cSJim Jagielski pMutex = 0;
79*b1cdbd2cSJim Jagielski }
80*b1cdbd2cSJim Jagielski
81*b1cdbd2cSJim Jagielski pthread_mutexattr_destroy(&aMutexAttr);
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski return (oslMutex) pMutex;
84*b1cdbd2cSJim Jagielski }
85*b1cdbd2cSJim Jagielski
86*b1cdbd2cSJim Jagielski /*****************************************************************************/
87*b1cdbd2cSJim Jagielski /* osl_destroyMutex */
88*b1cdbd2cSJim Jagielski /*****************************************************************************/
osl_destroyMutex(oslMutex Mutex)89*b1cdbd2cSJim Jagielski void SAL_CALL osl_destroyMutex(oslMutex Mutex)
90*b1cdbd2cSJim Jagielski {
91*b1cdbd2cSJim Jagielski oslMutexImpl* pMutex = (oslMutexImpl*) Mutex;
92*b1cdbd2cSJim Jagielski
93*b1cdbd2cSJim Jagielski OSL_ASSERT(pMutex);
94*b1cdbd2cSJim Jagielski
95*b1cdbd2cSJim Jagielski if ( pMutex != 0 )
96*b1cdbd2cSJim Jagielski {
97*b1cdbd2cSJim Jagielski int nRet=0;
98*b1cdbd2cSJim Jagielski
99*b1cdbd2cSJim Jagielski nRet = pthread_mutex_destroy(&(pMutex->mutex));
100*b1cdbd2cSJim Jagielski if ( nRet != 0 )
101*b1cdbd2cSJim Jagielski {
102*b1cdbd2cSJim Jagielski OSL_TRACE("osl_destroyMutex : mutex destroy failed. Errno: %d; %s\n",
103*b1cdbd2cSJim Jagielski nRet, strerror(nRet));
104*b1cdbd2cSJim Jagielski }
105*b1cdbd2cSJim Jagielski
106*b1cdbd2cSJim Jagielski free(pMutex);
107*b1cdbd2cSJim Jagielski }
108*b1cdbd2cSJim Jagielski
109*b1cdbd2cSJim Jagielski return;
110*b1cdbd2cSJim Jagielski }
111*b1cdbd2cSJim Jagielski
112*b1cdbd2cSJim Jagielski /*****************************************************************************/
113*b1cdbd2cSJim Jagielski /* osl_acquireMutex */
114*b1cdbd2cSJim Jagielski /*****************************************************************************/
osl_acquireMutex(oslMutex Mutex)115*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL osl_acquireMutex(oslMutex Mutex)
116*b1cdbd2cSJim Jagielski {
117*b1cdbd2cSJim Jagielski oslMutexImpl* pMutex = (oslMutexImpl*) Mutex;
118*b1cdbd2cSJim Jagielski
119*b1cdbd2cSJim Jagielski OSL_ASSERT(pMutex);
120*b1cdbd2cSJim Jagielski
121*b1cdbd2cSJim Jagielski if ( pMutex != 0 )
122*b1cdbd2cSJim Jagielski {
123*b1cdbd2cSJim Jagielski int nRet=0;
124*b1cdbd2cSJim Jagielski
125*b1cdbd2cSJim Jagielski nRet = pthread_mutex_lock(&(pMutex->mutex));
126*b1cdbd2cSJim Jagielski if ( nRet != 0 )
127*b1cdbd2cSJim Jagielski {
128*b1cdbd2cSJim Jagielski OSL_TRACE("osl_acquireMutex : mutex lock failed. Errno: %d; %s\n",
129*b1cdbd2cSJim Jagielski nRet, strerror(nRet));
130*b1cdbd2cSJim Jagielski return sal_False;
131*b1cdbd2cSJim Jagielski }
132*b1cdbd2cSJim Jagielski return sal_True;
133*b1cdbd2cSJim Jagielski }
134*b1cdbd2cSJim Jagielski
135*b1cdbd2cSJim Jagielski /* not initialized */
136*b1cdbd2cSJim Jagielski return sal_False;
137*b1cdbd2cSJim Jagielski }
138*b1cdbd2cSJim Jagielski
139*b1cdbd2cSJim Jagielski /*****************************************************************************/
140*b1cdbd2cSJim Jagielski /* osl_tryToAcquireMutex */
141*b1cdbd2cSJim Jagielski /*****************************************************************************/
osl_tryToAcquireMutex(oslMutex Mutex)142*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL osl_tryToAcquireMutex(oslMutex Mutex)
143*b1cdbd2cSJim Jagielski {
144*b1cdbd2cSJim Jagielski oslMutexImpl* pMutex = (oslMutexImpl*) Mutex;
145*b1cdbd2cSJim Jagielski
146*b1cdbd2cSJim Jagielski OSL_ASSERT(pMutex);
147*b1cdbd2cSJim Jagielski
148*b1cdbd2cSJim Jagielski if ( pMutex )
149*b1cdbd2cSJim Jagielski {
150*b1cdbd2cSJim Jagielski int nRet = 0;
151*b1cdbd2cSJim Jagielski nRet = pthread_mutex_trylock(&(pMutex->mutex));
152*b1cdbd2cSJim Jagielski if ( nRet != 0 )
153*b1cdbd2cSJim Jagielski return sal_False;
154*b1cdbd2cSJim Jagielski
155*b1cdbd2cSJim Jagielski return sal_True;
156*b1cdbd2cSJim Jagielski }
157*b1cdbd2cSJim Jagielski
158*b1cdbd2cSJim Jagielski /* not initialized */
159*b1cdbd2cSJim Jagielski return sal_False;
160*b1cdbd2cSJim Jagielski }
161*b1cdbd2cSJim Jagielski
162*b1cdbd2cSJim Jagielski /*****************************************************************************/
163*b1cdbd2cSJim Jagielski /* osl_releaseMutex */
164*b1cdbd2cSJim Jagielski /*****************************************************************************/
osl_releaseMutex(oslMutex Mutex)165*b1cdbd2cSJim Jagielski sal_Bool SAL_CALL osl_releaseMutex(oslMutex Mutex)
166*b1cdbd2cSJim Jagielski {
167*b1cdbd2cSJim Jagielski oslMutexImpl* pMutex = (oslMutexImpl*) Mutex;
168*b1cdbd2cSJim Jagielski
169*b1cdbd2cSJim Jagielski OSL_ASSERT(pMutex);
170*b1cdbd2cSJim Jagielski
171*b1cdbd2cSJim Jagielski if ( pMutex )
172*b1cdbd2cSJim Jagielski {
173*b1cdbd2cSJim Jagielski int nRet=0;
174*b1cdbd2cSJim Jagielski nRet = pthread_mutex_unlock(&(pMutex->mutex));
175*b1cdbd2cSJim Jagielski if ( nRet != 0 )
176*b1cdbd2cSJim Jagielski {
177*b1cdbd2cSJim Jagielski OSL_TRACE("osl_releaseMutex : mutex unlock failed. Errno: %d; %s\n",
178*b1cdbd2cSJim Jagielski nRet, strerror(nRet));
179*b1cdbd2cSJim Jagielski return sal_False;
180*b1cdbd2cSJim Jagielski }
181*b1cdbd2cSJim Jagielski
182*b1cdbd2cSJim Jagielski return sal_True;
183*b1cdbd2cSJim Jagielski }
184*b1cdbd2cSJim Jagielski
185*b1cdbd2cSJim Jagielski /* not initialized */
186*b1cdbd2cSJim Jagielski return sal_False;
187*b1cdbd2cSJim Jagielski }
188*b1cdbd2cSJim Jagielski
189*b1cdbd2cSJim Jagielski /*****************************************************************************/
190*b1cdbd2cSJim Jagielski /* osl_getGlobalMutex */
191*b1cdbd2cSJim Jagielski /*****************************************************************************/
192*b1cdbd2cSJim Jagielski
193*b1cdbd2cSJim Jagielski static oslMutexImpl globalMutexImpl;
194*b1cdbd2cSJim Jagielski
globalMutexInitImpl(void)195*b1cdbd2cSJim Jagielski static void globalMutexInitImpl(void) {
196*b1cdbd2cSJim Jagielski pthread_mutexattr_t attr;
197*b1cdbd2cSJim Jagielski if (pthread_mutexattr_init(&attr) != 0 ||
198*b1cdbd2cSJim Jagielski pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE) ||
199*b1cdbd2cSJim Jagielski pthread_mutex_init(&globalMutexImpl.mutex, &attr) != 0 ||
200*b1cdbd2cSJim Jagielski pthread_mutexattr_destroy(&attr) != 0)
201*b1cdbd2cSJim Jagielski {
202*b1cdbd2cSJim Jagielski abort();
203*b1cdbd2cSJim Jagielski }
204*b1cdbd2cSJim Jagielski }
205*b1cdbd2cSJim Jagielski
osl_getGlobalMutex()206*b1cdbd2cSJim Jagielski oslMutex * SAL_CALL osl_getGlobalMutex()
207*b1cdbd2cSJim Jagielski {
208*b1cdbd2cSJim Jagielski /* necessary to get a "oslMutex *" */
209*b1cdbd2cSJim Jagielski static oslMutex globalMutex = (oslMutex) &globalMutexImpl;
210*b1cdbd2cSJim Jagielski
211*b1cdbd2cSJim Jagielski static pthread_once_t once = PTHREAD_ONCE_INIT;
212*b1cdbd2cSJim Jagielski if (pthread_once(&once, &globalMutexInitImpl) != 0) {
213*b1cdbd2cSJim Jagielski abort();
214*b1cdbd2cSJim Jagielski }
215*b1cdbd2cSJim Jagielski
216*b1cdbd2cSJim Jagielski return &globalMutex;
217*b1cdbd2cSJim Jagielski }
218