1 fc6f0665SEd Schouten /*-
2 4d846d26SWarner Losh * SPDX-License-Identifier: BSD-2-Clause
3 5e53a4f9SPedro F. Giffuni *
4 fc6f0665SEd Schouten * Copyright (c) 2011 Ed Schouten <ed@FreeBSD.org>
5 fc6f0665SEd Schouten * All rights reserved.
6 fc6f0665SEd Schouten *
7 fc6f0665SEd Schouten * Redistribution and use in source and binary forms, with or without
8 fc6f0665SEd Schouten * modification, are permitted provided that the following conditions
9 fc6f0665SEd Schouten * are met:
10 fc6f0665SEd Schouten * 1. Redistributions of source code must retain the above copyright
11 fc6f0665SEd Schouten * notice, this list of conditions and the following disclaimer.
12 fc6f0665SEd Schouten * 2. Redistributions in binary form must reproduce the above copyright
13 fc6f0665SEd Schouten * notice, this list of conditions and the following disclaimer in the
14 fc6f0665SEd Schouten * documentation and/or other materials provided with the distribution.
15 fc6f0665SEd Schouten *
16 fc6f0665SEd Schouten * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 fc6f0665SEd Schouten * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 fc6f0665SEd Schouten * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 fc6f0665SEd Schouten * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 fc6f0665SEd Schouten * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 fc6f0665SEd Schouten * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 fc6f0665SEd Schouten * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 fc6f0665SEd Schouten * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 fc6f0665SEd Schouten * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 fc6f0665SEd Schouten * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 fc6f0665SEd Schouten * SUCH DAMAGE.
27 fc6f0665SEd Schouten */
28 fc6f0665SEd Schouten
29 fc6f0665SEd Schouten #include <sys/cdefs.h>
30 fc6f0665SEd Schouten #include <errno.h>
31 fc6f0665SEd Schouten #include <pthread.h>
32 fc6f0665SEd Schouten
33 fc6f0665SEd Schouten #include "threads.h"
34 fc6f0665SEd Schouten
35 fc6f0665SEd Schouten void
mtx_destroy(mtx_t * mtx)36 fc6f0665SEd Schouten mtx_destroy(mtx_t *mtx)
37 fc6f0665SEd Schouten {
38 fc6f0665SEd Schouten
39 fc6f0665SEd Schouten (void)pthread_mutex_destroy(mtx);
40 fc6f0665SEd Schouten }
41 fc6f0665SEd Schouten
42 fc6f0665SEd Schouten int
mtx_init(mtx_t * mtx,int type)43 fc6f0665SEd Schouten mtx_init(mtx_t *mtx, int type)
44 fc6f0665SEd Schouten {
45 fc6f0665SEd Schouten pthread_mutexattr_t attr;
46 *a03f7686SHodong int mt, res;
47 fc6f0665SEd Schouten
48 fc6f0665SEd Schouten switch (type) {
49 fc6f0665SEd Schouten case mtx_plain:
50 fc6f0665SEd Schouten case mtx_timed:
51 fc6f0665SEd Schouten mt = PTHREAD_MUTEX_NORMAL;
52 fc6f0665SEd Schouten break;
53 fc6f0665SEd Schouten case mtx_plain | mtx_recursive:
54 fc6f0665SEd Schouten case mtx_timed | mtx_recursive:
55 fc6f0665SEd Schouten mt = PTHREAD_MUTEX_RECURSIVE;
56 fc6f0665SEd Schouten break;
57 fc6f0665SEd Schouten default:
58 fc6f0665SEd Schouten return (thrd_error);
59 fc6f0665SEd Schouten }
60 fc6f0665SEd Schouten
61 fc6f0665SEd Schouten if (pthread_mutexattr_init(&attr) != 0)
62 fc6f0665SEd Schouten return (thrd_error);
63 *a03f7686SHodong res = thrd_success;
64 *a03f7686SHodong if (pthread_mutexattr_settype(&attr, mt) != 0 ||
65 *a03f7686SHodong pthread_mutex_init(mtx, &attr) != 0)
66 *a03f7686SHodong res = thrd_error;
67 *a03f7686SHodong pthread_mutexattr_destroy(&attr);
68 *a03f7686SHodong return (res);
69 fc6f0665SEd Schouten }
70 fc6f0665SEd Schouten
71 fc6f0665SEd Schouten int
mtx_lock(mtx_t * mtx)72 fc6f0665SEd Schouten mtx_lock(mtx_t *mtx)
73 fc6f0665SEd Schouten {
74 fc6f0665SEd Schouten
75 fc6f0665SEd Schouten if (pthread_mutex_lock(mtx) != 0)
76 fc6f0665SEd Schouten return (thrd_error);
77 fc6f0665SEd Schouten return (thrd_success);
78 fc6f0665SEd Schouten }
79 fc6f0665SEd Schouten
80 fc6f0665SEd Schouten int
mtx_timedlock(mtx_t * restrict mtx,const struct timespec * restrict ts)81 fc6f0665SEd Schouten mtx_timedlock(mtx_t *restrict mtx, const struct timespec *restrict ts)
82 fc6f0665SEd Schouten {
83 fc6f0665SEd Schouten
84 fc6f0665SEd Schouten switch (pthread_mutex_timedlock(mtx, ts)) {
85 fc6f0665SEd Schouten case 0:
86 fc6f0665SEd Schouten return (thrd_success);
87 fc6f0665SEd Schouten case ETIMEDOUT:
88 fc6f0665SEd Schouten return (thrd_timedout);
89 fc6f0665SEd Schouten default:
90 fc6f0665SEd Schouten return (thrd_error);
91 fc6f0665SEd Schouten }
92 fc6f0665SEd Schouten }
93 fc6f0665SEd Schouten
94 fc6f0665SEd Schouten int
mtx_trylock(mtx_t * mtx)95 fc6f0665SEd Schouten mtx_trylock(mtx_t *mtx)
96 fc6f0665SEd Schouten {
97 fc6f0665SEd Schouten
98 85e7eba6SKonstantin Belousov switch (pthread_mutex_trylock(mtx)) {
99 fc6f0665SEd Schouten case 0:
100 fc6f0665SEd Schouten return (thrd_success);
101 fc6f0665SEd Schouten case EBUSY:
102 fc6f0665SEd Schouten return (thrd_busy);
103 fc6f0665SEd Schouten default:
104 fc6f0665SEd Schouten return (thrd_error);
105 fc6f0665SEd Schouten }
106 fc6f0665SEd Schouten }
107 fc6f0665SEd Schouten
108 fc6f0665SEd Schouten int
mtx_unlock(mtx_t * mtx)109 fc6f0665SEd Schouten mtx_unlock(mtx_t *mtx)
110 fc6f0665SEd Schouten {
111 fc6f0665SEd Schouten
112 fc6f0665SEd Schouten if (pthread_mutex_unlock(mtx) != 0)
113 fc6f0665SEd Schouten return (thrd_error);
114 fc6f0665SEd Schouten return (thrd_success);
115 fc6f0665SEd Schouten }
116