thrd.c revision 330897 
1/*-
2 * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
3 *
4 * Copyright (c) 2011 Ed Schouten <ed@FreeBSD.org>
5 * All rights reserved.
6 *
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
9 * are met:
10 * 1. Redistributions of source code must retain the above copyright
11 *    notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 *    notice, this list of conditions and the following disclaimer in the
14 *    documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 * SUCH DAMAGE.
27 *
28 * $FreeBSD: stable/11/lib/libstdthreads/thrd.c 330897 2018-03-14 03:19:51Z eadler $
29 */
30
31#include <sys/cdefs.h>
32__FBSDID("$FreeBSD: stable/11/lib/libstdthreads/thrd.c 330897 2018-03-14 03:19:51Z eadler $");
33
34#include <pthread.h>
35#include <stdint.h>
36#include <stdlib.h>
37
38#include "threads.h"
39
40struct thrd_param {
41	thrd_start_t	 func;
42	void		*arg;
43};
44
45static void *
46thrd_entry(void *arg)
47{
48	struct thrd_param tp;
49
50	tp = *(struct thrd_param *)arg;
51	free(arg);
52	return ((void *)(intptr_t)tp.func(tp.arg));
53}
54
55int
56thrd_create(thrd_t *thr, thrd_start_t func, void *arg)
57{
58	struct thrd_param *tp;
59
60	/*
61	 * Work around return type inconsistency.  Wrap execution using
62	 * a function conforming to pthread_create()'s start_routine.
63	 */
64	tp = malloc(sizeof(*tp));
65	if (tp == NULL)
66		return (thrd_nomem);
67	tp->func = func;
68	tp->arg = arg;
69	if (pthread_create(thr, NULL, thrd_entry, tp) != 0) {
70		free(tp);
71		return (thrd_error);
72	}
73	return (thrd_success);
74}
75
76thrd_t
77thrd_current(void)
78{
79
80	return (pthread_self());
81}
82
83int
84thrd_detach(thrd_t thr)
85{
86
87	if (pthread_detach(thr) != 0)
88		return (thrd_error);
89	return (thrd_success);
90}
91
92int
93thrd_equal(thrd_t thr0, thrd_t thr1)
94{
95
96	return (pthread_equal(thr0, thr1));
97}
98
99_Noreturn void
100thrd_exit(int res)
101{
102
103	pthread_exit((void *)(intptr_t)res);
104}
105
106int
107thrd_join(thrd_t thr, int *res)
108{
109	void *value_ptr;
110
111	if (pthread_join(thr, &value_ptr) != 0)
112		return (thrd_error);
113	if (res != NULL)
114		*res = (intptr_t)value_ptr;
115	return (thrd_success);
116}
117
118int
119thrd_sleep(const struct timespec *duration, struct timespec *remaining)
120{
121
122	return (nanosleep(duration, remaining));
123}
124
125void
126thrd_yield(void)
127{
128
129	pthread_yield();
130}
131