1*647f063dSAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3*647f063dSAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4*647f063dSAndrew Rist * or more contributor license agreements. See the NOTICE file
5*647f063dSAndrew Rist * distributed with this work for additional information
6*647f063dSAndrew Rist * regarding copyright ownership. The ASF licenses this file
7*647f063dSAndrew Rist * to you under the Apache License, Version 2.0 (the
8*647f063dSAndrew Rist * "License"); you may not use this file except in compliance
9*647f063dSAndrew Rist * with the License. You may obtain a copy of the License at
10*647f063dSAndrew Rist *
11*647f063dSAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12*647f063dSAndrew Rist *
13*647f063dSAndrew Rist * Unless required by applicable law or agreed to in writing,
14*647f063dSAndrew Rist * software distributed under the License is distributed on an
15*647f063dSAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*647f063dSAndrew Rist * KIND, either express or implied. See the License for the
17*647f063dSAndrew Rist * specific language governing permissions and limitations
18*647f063dSAndrew Rist * under the License.
19*647f063dSAndrew Rist *
20*647f063dSAndrew Rist *************************************************************/
21*647f063dSAndrew Rist
22*647f063dSAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir
25cdf0e10cSrcweir #include "system.h"
26cdf0e10cSrcweir
27cdf0e10cSrcweir #include <osl/semaphor.h>
28cdf0e10cSrcweir #include <osl/diagnose.h>
29cdf0e10cSrcweir
30cdf0e10cSrcweir #ifndef OSL_USE_SYS_V_SEMAPHORE
31cdf0e10cSrcweir
32cdf0e10cSrcweir /* This is the (default) POSIX thread-local semaphore variant */
33cdf0e10cSrcweir
34cdf0e10cSrcweir /*
35cdf0e10cSrcweir Implemetation notes:
36cdf0e10cSrcweir The void* represented by oslSemaphore is used
37cdf0e10cSrcweir as a pointer to an sem_t struct
38cdf0e10cSrcweir */
39cdf0e10cSrcweir
40cdf0e10cSrcweir /*****************************************************************************/
41cdf0e10cSrcweir /* osl_createSemaphore */
42cdf0e10cSrcweir /*****************************************************************************/
43cdf0e10cSrcweir
osl_createSemaphore(sal_uInt32 initialCount)44cdf0e10cSrcweir oslSemaphore SAL_CALL osl_createSemaphore(sal_uInt32 initialCount)
45cdf0e10cSrcweir {
46cdf0e10cSrcweir int ret = 0;
47cdf0e10cSrcweir oslSemaphore Semaphore;
48cdf0e10cSrcweir
49cdf0e10cSrcweir Semaphore= malloc(sizeof(sem_t));
50cdf0e10cSrcweir
51cdf0e10cSrcweir OSL_ASSERT(Semaphore); /* ptr valid? */
52cdf0e10cSrcweir
53cdf0e10cSrcweir if ( Semaphore == 0 )
54cdf0e10cSrcweir {
55cdf0e10cSrcweir return 0;
56cdf0e10cSrcweir }
57cdf0e10cSrcweir
58cdf0e10cSrcweir /* unnamed semaphore, not shared between processes */
59cdf0e10cSrcweir
60cdf0e10cSrcweir ret= sem_init((sem_t*)Semaphore, 0, initialCount);
61cdf0e10cSrcweir
62cdf0e10cSrcweir /* create failed? */
63cdf0e10cSrcweir if (ret != 0)
64cdf0e10cSrcweir {
65cdf0e10cSrcweir OSL_TRACE("osl_createSemaphore failed. Errno: %d; %s\n",
66cdf0e10cSrcweir errno,
67cdf0e10cSrcweir strerror(errno));
68cdf0e10cSrcweir
69cdf0e10cSrcweir free(Semaphore);
70cdf0e10cSrcweir Semaphore = NULL;
71cdf0e10cSrcweir }
72cdf0e10cSrcweir
73cdf0e10cSrcweir return Semaphore;
74cdf0e10cSrcweir }
75cdf0e10cSrcweir
76cdf0e10cSrcweir /*****************************************************************************/
77cdf0e10cSrcweir /* osl_destroySemaphore */
78cdf0e10cSrcweir /*****************************************************************************/
osl_destroySemaphore(oslSemaphore Semaphore)79cdf0e10cSrcweir void SAL_CALL osl_destroySemaphore(oslSemaphore Semaphore)
80cdf0e10cSrcweir {
81cdf0e10cSrcweir if(Semaphore) /* ptr valid? */
82cdf0e10cSrcweir {
83cdf0e10cSrcweir sem_destroy((sem_t*)Semaphore);
84cdf0e10cSrcweir free(Semaphore);
85cdf0e10cSrcweir }
86cdf0e10cSrcweir }
87cdf0e10cSrcweir
88cdf0e10cSrcweir /*****************************************************************************/
89cdf0e10cSrcweir /* osl_acquireSemaphore */
90cdf0e10cSrcweir /*****************************************************************************/
osl_acquireSemaphore(oslSemaphore Semaphore)91cdf0e10cSrcweir sal_Bool SAL_CALL osl_acquireSemaphore(oslSemaphore Semaphore) {
92cdf0e10cSrcweir
93cdf0e10cSrcweir OSL_ASSERT(Semaphore != 0); /* abort in debug mode */
94cdf0e10cSrcweir
95cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
96cdf0e10cSrcweir {
97cdf0e10cSrcweir return (sem_wait((sem_t*)Semaphore) == 0);
98cdf0e10cSrcweir }
99cdf0e10cSrcweir
100cdf0e10cSrcweir return sal_False;
101cdf0e10cSrcweir }
102cdf0e10cSrcweir
103cdf0e10cSrcweir /*****************************************************************************/
104cdf0e10cSrcweir /* osl_tryToAcquireSemaphore */
105cdf0e10cSrcweir /*****************************************************************************/
osl_tryToAcquireSemaphore(oslSemaphore Semaphore)106cdf0e10cSrcweir sal_Bool SAL_CALL osl_tryToAcquireSemaphore(oslSemaphore Semaphore) {
107cdf0e10cSrcweir
108cdf0e10cSrcweir OSL_ASSERT(Semaphore != 0); /* abort in debug mode */
109cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
110cdf0e10cSrcweir {
111cdf0e10cSrcweir return (sem_trywait((sem_t*)Semaphore) == 0);
112cdf0e10cSrcweir }
113cdf0e10cSrcweir
114cdf0e10cSrcweir return sal_False;
115cdf0e10cSrcweir }
116cdf0e10cSrcweir
117cdf0e10cSrcweir /*****************************************************************************/
118cdf0e10cSrcweir /* osl_releaseSemaphore */
119cdf0e10cSrcweir /*****************************************************************************/
osl_releaseSemaphore(oslSemaphore Semaphore)120cdf0e10cSrcweir sal_Bool SAL_CALL osl_releaseSemaphore(oslSemaphore Semaphore) {
121cdf0e10cSrcweir
122cdf0e10cSrcweir OSL_ASSERT(Semaphore != 0); /* abort in debug mode */
123cdf0e10cSrcweir
124cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
125cdf0e10cSrcweir {
126cdf0e10cSrcweir return (sem_post((sem_t*)Semaphore) == 0);
127cdf0e10cSrcweir }
128cdf0e10cSrcweir
129cdf0e10cSrcweir return sal_False;
130cdf0e10cSrcweir }
131cdf0e10cSrcweir
132cdf0e10cSrcweir #else /* OSL_USE_SYS_V_SEMAPHORE */
133cdf0e10cSrcweir
134cdf0e10cSrcweir /*******************************************************************************/
135cdf0e10cSrcweir
136cdf0e10cSrcweir /* This is the SYS V private semaphore variant */
137cdf0e10cSrcweir
138cdf0e10cSrcweir /*
139cdf0e10cSrcweir Implemetation notes:
140cdf0e10cSrcweir The void* represented by oslSemaphore is used
141cdf0e10cSrcweir as a pointer to an osl_TSemImpl struct
142cdf0e10cSrcweir */
143cdf0e10cSrcweir
144cdf0e10cSrcweir
145cdf0e10cSrcweir #if defined(NETBSD)
146cdf0e10cSrcweir union semun {
147cdf0e10cSrcweir int val; /* value for SETVAL */
148cdf0e10cSrcweir struct semid_ds *buf; /* buffer for IPC_STAT & IPC_SET */
149cdf0e10cSrcweir u_short *array; /* array for GETALL & SETALL */
150cdf0e10cSrcweir };
151cdf0e10cSrcweir #endif
152cdf0e10cSrcweir
153cdf0e10cSrcweir typedef struct _osl_TSemImpl
154cdf0e10cSrcweir {
155cdf0e10cSrcweir int m_Id;
156cdf0e10cSrcweir
157cdf0e10cSrcweir } osl_TSemImpl;
158cdf0e10cSrcweir
159cdf0e10cSrcweir /*****************************************************************************/
160cdf0e10cSrcweir /* osl_createSemaphore */
161cdf0e10cSrcweir /*****************************************************************************/
osl_createSemaphore(sal_uInt32 initialCount)162cdf0e10cSrcweir oslSemaphore SAL_CALL osl_createSemaphore(sal_uInt32 initialCount)
163cdf0e10cSrcweir {
164cdf0e10cSrcweir union semun arg;
165cdf0e10cSrcweir
166cdf0e10cSrcweir oslSemaphore Semaphore;
167cdf0e10cSrcweir osl_TSemImpl* pSem;
168cdf0e10cSrcweir
169cdf0e10cSrcweir Semaphore= malloc(sizeof(osl_TSemImpl));
170cdf0e10cSrcweir OSL_POSTCOND(Semaphore, "malloc failed\n"); /* ptr valid? */
171cdf0e10cSrcweir
172cdf0e10cSrcweir pSem= (osl_TSemImpl*)Semaphore;
173cdf0e10cSrcweir
174cdf0e10cSrcweir
175cdf0e10cSrcweir /* unnamed (private) semaphore */
176cdf0e10cSrcweir
177cdf0e10cSrcweir pSem->m_Id= semget(IPC_PRIVATE, 1, 0666 | IPC_CREAT);
178cdf0e10cSrcweir
179cdf0e10cSrcweir
180cdf0e10cSrcweir /* create failed? */
181cdf0e10cSrcweir if (pSem->m_Id < 0)
182cdf0e10cSrcweir {
183cdf0e10cSrcweir OSL_TRACE("osl_createSemaphore failed (semget). Errno: %d; %s\n",
184cdf0e10cSrcweir errno,
185cdf0e10cSrcweir strerror(errno));
186cdf0e10cSrcweir
187cdf0e10cSrcweir free(Semaphore);
188cdf0e10cSrcweir return 0;
189cdf0e10cSrcweir }
190cdf0e10cSrcweir
191cdf0e10cSrcweir /* set initial count */
192cdf0e10cSrcweir
193cdf0e10cSrcweir arg.val= initialCount;
194cdf0e10cSrcweir
195cdf0e10cSrcweir if(semctl(pSem->m_Id, 0, SETVAL, arg) < 0)
196cdf0e10cSrcweir {
197cdf0e10cSrcweir OSL_TRACE("osl_createSemaphore failed (semctl(SETVAL)). Errno: %d; %s\n",
198cdf0e10cSrcweir errno,
199cdf0e10cSrcweir strerror(errno));
200cdf0e10cSrcweir
201cdf0e10cSrcweir if(semctl(pSem->m_Id, 0, IPC_RMID, arg) < 0)
202cdf0e10cSrcweir {
203cdf0e10cSrcweir OSL_TRACE("semctl(IPC_RMID) failed. Errno: %d; %s\n", errno, strerror(errno));
204cdf0e10cSrcweir }
205cdf0e10cSrcweir
206cdf0e10cSrcweir free(Semaphore);
207cdf0e10cSrcweir return 0;
208cdf0e10cSrcweir }
209cdf0e10cSrcweir
210cdf0e10cSrcweir
211cdf0e10cSrcweir return Semaphore;
212cdf0e10cSrcweir }
213cdf0e10cSrcweir
214cdf0e10cSrcweir /*****************************************************************************/
215cdf0e10cSrcweir /* osl_destroySemaphore */
216cdf0e10cSrcweir /*****************************************************************************/
osl_destroySemaphore(oslSemaphore Semaphore)217cdf0e10cSrcweir void SAL_CALL osl_destroySemaphore(oslSemaphore Semaphore) {
218cdf0e10cSrcweir
219cdf0e10cSrcweir if(Semaphore) /* ptr valid? */
220cdf0e10cSrcweir {
221cdf0e10cSrcweir union semun arg;
222cdf0e10cSrcweir
223cdf0e10cSrcweir osl_TSemImpl* pSem= (osl_TSemImpl*)Semaphore;
224cdf0e10cSrcweir
225cdf0e10cSrcweir if(semctl(pSem->m_Id, 0, IPC_RMID, arg) < 0)
226cdf0e10cSrcweir
227cdf0e10cSrcweir {
228cdf0e10cSrcweir OSL_TRACE("osl_destroySemaphore failed. (semctl(IPC_RMID)). Errno: %d; %s\n",
229cdf0e10cSrcweir errno,
230cdf0e10cSrcweir strerror(errno));
231cdf0e10cSrcweir }
232cdf0e10cSrcweir
233cdf0e10cSrcweir free(Semaphore);
234cdf0e10cSrcweir }
235cdf0e10cSrcweir }
236cdf0e10cSrcweir
237cdf0e10cSrcweir /*****************************************************************************/
238cdf0e10cSrcweir /* osl_acquireSemaphore */
239cdf0e10cSrcweir /*****************************************************************************/
osl_acquireSemaphore(oslSemaphore Semaphore)240cdf0e10cSrcweir sal_Bool SAL_CALL osl_acquireSemaphore(oslSemaphore Semaphore) {
241cdf0e10cSrcweir
242cdf0e10cSrcweir /* abort in debug mode */
243cdf0e10cSrcweir OSL_PRECOND(Semaphore != 0, "Semaphore not created\n");
244cdf0e10cSrcweir
245cdf0e10cSrcweir
246cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
247cdf0e10cSrcweir {
248cdf0e10cSrcweir struct sembuf op;
249cdf0e10cSrcweir osl_TSemImpl* pSem= (osl_TSemImpl*)Semaphore;
250cdf0e10cSrcweir
251cdf0e10cSrcweir op.sem_num= 0;
252cdf0e10cSrcweir op.sem_op= -1;
253cdf0e10cSrcweir op.sem_flg= SEM_UNDO;
254cdf0e10cSrcweir
255cdf0e10cSrcweir return semop(pSem->m_Id, &op, 1) >= 0;
256cdf0e10cSrcweir
257cdf0e10cSrcweir }
258cdf0e10cSrcweir
259cdf0e10cSrcweir return sal_False;
260cdf0e10cSrcweir }
261cdf0e10cSrcweir
262cdf0e10cSrcweir /*****************************************************************************/
263cdf0e10cSrcweir /* osl_tryToAcquireSemaphore */
264cdf0e10cSrcweir /*****************************************************************************/
osl_tryToAcquireSemaphore(oslSemaphore Semaphore)265cdf0e10cSrcweir sal_Bool SAL_CALL osl_tryToAcquireSemaphore(oslSemaphore Semaphore) {
266cdf0e10cSrcweir
267cdf0e10cSrcweir /* abort in debug mode */
268cdf0e10cSrcweir OSL_PRECOND(Semaphore != 0, "Semaphore not created\n");
269cdf0e10cSrcweir
270cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
271cdf0e10cSrcweir {
272cdf0e10cSrcweir struct sembuf op;
273cdf0e10cSrcweir osl_TSemImpl* pSem= (osl_TSemImpl*)Semaphore;
274cdf0e10cSrcweir
275cdf0e10cSrcweir op.sem_num= 0;
276cdf0e10cSrcweir op.sem_op= -1;
277cdf0e10cSrcweir op.sem_flg= SEM_UNDO | IPC_NOWAIT;
278cdf0e10cSrcweir
279cdf0e10cSrcweir return semop(pSem->m_Id, &op, 1) >= 0;
280cdf0e10cSrcweir }
281cdf0e10cSrcweir
282cdf0e10cSrcweir return sal_False;
283cdf0e10cSrcweir }
284cdf0e10cSrcweir
285cdf0e10cSrcweir /*****************************************************************************/
286cdf0e10cSrcweir /* osl_releaseSemaphore */
287cdf0e10cSrcweir /*****************************************************************************/
osl_releaseSemaphore(oslSemaphore Semaphore)288cdf0e10cSrcweir sal_Bool SAL_CALL osl_releaseSemaphore(oslSemaphore Semaphore)
289cdf0e10cSrcweir {
290cdf0e10cSrcweir
291cdf0e10cSrcweir /* abort in debug mode */
292cdf0e10cSrcweir OSL_PRECOND(Semaphore != 0, "Semaphore not created\n");
293cdf0e10cSrcweir
294cdf0e10cSrcweir if (Semaphore != 0) /* be tolerant in release mode */
295cdf0e10cSrcweir {
296cdf0e10cSrcweir struct sembuf op;
297cdf0e10cSrcweir osl_TSemImpl* pSem= (osl_TSemImpl*)Semaphore;
298cdf0e10cSrcweir
299cdf0e10cSrcweir op.sem_num= 0;
300cdf0e10cSrcweir op.sem_op= 1;
301cdf0e10cSrcweir op.sem_flg= SEM_UNDO;
302cdf0e10cSrcweir
303cdf0e10cSrcweir return semop(pSem->m_Id, &op, 1) >= 0;
304cdf0e10cSrcweir }
305cdf0e10cSrcweir
306cdf0e10cSrcweir return sal_False;
307cdf0e10cSrcweir }
308cdf0e10cSrcweir
309cdf0e10cSrcweir #endif /* OSL_USE_SYS_V_SEMAPHORE */
310cdf0e10cSrcweir
311