1*b819cea2SGordon Ross /*
2*b819cea2SGordon Ross  * This file and its contents are supplied under the terms of the
3*b819cea2SGordon Ross  * Common Development and Distribution License ("CDDL"), version 1.0.
4*b819cea2SGordon Ross  * You may only use this file in accordance with the terms of version
5*b819cea2SGordon Ross  * 1.0 of the CDDL.
6*b819cea2SGordon Ross  *
7*b819cea2SGordon Ross  * A full copy of the text of the CDDL should have accompanied this
8*b819cea2SGordon Ross  * source.  A copy of the CDDL is also available via the Internet at
9*b819cea2SGordon Ross  * http://www.illumos.org/license/CDDL.
10*b819cea2SGordon Ross  */
11*b819cea2SGordon Ross 
12*b819cea2SGordon Ross /*
13*b819cea2SGordon Ross  * Copyright 2013 Nexenta Systems, Inc.  All rights reserved.
14*b819cea2SGordon Ross  */
15*b819cea2SGordon Ross 
16*b819cea2SGordon Ross /*
17*b819cea2SGordon Ross  * semaphore(9f)
18*b819cea2SGordon Ross  */
19*b819cea2SGordon Ross 
20*b819cea2SGordon Ross /* This is the API we're emulating */
21*b819cea2SGordon Ross #include <sys/semaphore.h>
22*b819cea2SGordon Ross 
23*b819cea2SGordon Ross #include <sys/errno.h>
24*b819cea2SGordon Ross #include <sys/debug.h>
25*b819cea2SGordon Ross 
26*b819cea2SGordon Ross /* <synch.h> */
27*b819cea2SGordon Ross int	_lwp_sema_init(lwp_sema_t *, int);
28*b819cea2SGordon Ross int	_lwp_sema_wait(lwp_sema_t *);
29*b819cea2SGordon Ross int	_lwp_sema_trywait(lwp_sema_t *);
30*b819cea2SGordon Ross int	_lwp_sema_post(lwp_sema_t *);
31*b819cea2SGordon Ross 
32*b819cea2SGordon Ross 
33*b819cea2SGordon Ross /* ARGSUSED */
34*b819cea2SGordon Ross void
ksema_init(ksema_t * sem,uint32_t val,char * name,ksema_type_t st,void * arg)35*b819cea2SGordon Ross ksema_init(ksema_t *sem, uint32_t val,
36*b819cea2SGordon Ross 	char *name, ksema_type_t st, void *arg)
37*b819cea2SGordon Ross {
38*b819cea2SGordon Ross 	(void) _lwp_sema_init(sem, val);
39*b819cea2SGordon Ross }
40*b819cea2SGordon Ross 
41*b819cea2SGordon Ross /* ARGSUSED */
42*b819cea2SGordon Ross void
ksema_destroy(ksema_t * sem)43*b819cea2SGordon Ross ksema_destroy(ksema_t *sem)
44*b819cea2SGordon Ross {
45*b819cea2SGordon Ross }
46*b819cea2SGordon Ross 
47*b819cea2SGordon Ross void
sema_p(ksema_t * sem)48*b819cea2SGordon Ross sema_p(ksema_t *sem)
49*b819cea2SGordon Ross {
50*b819cea2SGordon Ross 	int rv;
51*b819cea2SGordon Ross 	do {
52*b819cea2SGordon Ross 		rv = _lwp_sema_wait(sem);
53*b819cea2SGordon Ross 	} while (rv == EINTR);
54*b819cea2SGordon Ross }
55*b819cea2SGordon Ross 
56*b819cea2SGordon Ross void
sema_v(ksema_t * sem)57*b819cea2SGordon Ross sema_v(ksema_t *sem)
58*b819cea2SGordon Ross {
59*b819cea2SGordon Ross 	(void) _lwp_sema_post(sem);
60*b819cea2SGordon Ross }
61*b819cea2SGordon Ross 
62*b819cea2SGordon Ross /*
63*b819cea2SGordon Ross  * Return values:
64*b819cea2SGordon Ross  * 1: interrupted
65*b819cea2SGordon Ross  * 0: success
66*b819cea2SGordon Ross  */
67*b819cea2SGordon Ross int
sema_p_sig(ksema_t * sem)68*b819cea2SGordon Ross sema_p_sig(ksema_t *sem)
69*b819cea2SGordon Ross {
70*b819cea2SGordon Ross 	int rv;
71*b819cea2SGordon Ross 	rv = _lwp_sema_wait(sem);
72*b819cea2SGordon Ross 	switch (rv) {
73*b819cea2SGordon Ross 	case 0:
74*b819cea2SGordon Ross 		/* rv = 0 ; success */
75*b819cea2SGordon Ross 		break;
76*b819cea2SGordon Ross 	case EINTR:
77*b819cea2SGordon Ross 	default:
78*b819cea2SGordon Ross 		rv = 1; /* interrrupted */
79*b819cea2SGordon Ross 		break;
80*b819cea2SGordon Ross 	}
81*b819cea2SGordon Ross 
82*b819cea2SGordon Ross 	return (rv);
83*b819cea2SGordon Ross }
84*b819cea2SGordon Ross 
85*b819cea2SGordon Ross /*
86*b819cea2SGordon Ross  * Return values:
87*b819cea2SGordon Ross  * 0: could not get semaphore
88*b819cea2SGordon Ross  * 1: successful (backwards from sema_p_sig!)
89*b819cea2SGordon Ross  */
90*b819cea2SGordon Ross int
sema_tryp(ksema_t * sem)91*b819cea2SGordon Ross sema_tryp(ksema_t *sem)
92*b819cea2SGordon Ross {
93*b819cea2SGordon Ross 	int rv;
94*b819cea2SGordon Ross 	rv = _lwp_sema_trywait(sem);
95*b819cea2SGordon Ross 
96*b819cea2SGordon Ross 	switch (rv) {
97*b819cea2SGordon Ross 	case 0:
98*b819cea2SGordon Ross 		rv = 1; /* success */
99*b819cea2SGordon Ross 		break;
100*b819cea2SGordon Ross 	case EBUSY:
101*b819cea2SGordon Ross 	default:
102*b819cea2SGordon Ross 		rv = 0; /* failed */
103*b819cea2SGordon Ross 		break;
104*b819cea2SGordon Ross 	}
105*b819cea2SGordon Ross 
106*b819cea2SGordon Ross 	return (rv);
107*b819cea2SGordon Ross }
108