t_join.c revision 1.5 1 1.5 joerg /* $NetBSD: t_join.c,v 1.5 2010/11/30 18:38:54 joerg Exp $ */
2 1.1 jruoho
3 1.1 jruoho /*-
4 1.1 jruoho * Copyright (c) 2010 The NetBSD Foundation, Inc.
5 1.1 jruoho * All rights reserved.
6 1.1 jruoho *
7 1.1 jruoho * This code is derived from software contributed to The NetBSD Foundation
8 1.1 jruoho * by Jukka Ruohonen.
9 1.1 jruoho *
10 1.1 jruoho * Redistribution and use in source and binary forms, with or without
11 1.1 jruoho * modification, are permitted provided that the following conditions
12 1.1 jruoho * are met:
13 1.1 jruoho * 1. Redistributions of source code must retain the above copyright
14 1.1 jruoho * notice, this list of conditions and the following disclaimer.
15 1.1 jruoho * 2. Redistributions in binary form must reproduce the above copyright
16 1.1 jruoho * notice, this list of conditions and the following disclaimer in the
17 1.1 jruoho * documentation and/or other materials provided with the distribution.
18 1.1 jruoho *
19 1.1 jruoho * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
20 1.1 jruoho * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
21 1.1 jruoho * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
22 1.1 jruoho * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
23 1.1 jruoho * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 1.1 jruoho * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
25 1.1 jruoho * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
26 1.1 jruoho * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
27 1.1 jruoho * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
28 1.1 jruoho * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 1.1 jruoho * POSSIBILITY OF SUCH DAMAGE.
30 1.1 jruoho */
31 1.1 jruoho #include <sys/cdefs.h>
32 1.5 joerg __RCSID("$NetBSD: t_join.c,v 1.5 2010/11/30 18:38:54 joerg Exp $");
33 1.1 jruoho
34 1.1 jruoho #include <errno.h>
35 1.1 jruoho #include <pthread.h>
36 1.1 jruoho
37 1.1 jruoho #include <atf-c.h>
38 1.1 jruoho
39 1.1 jruoho #include "h_common.h"
40 1.1 jruoho
41 1.5 joerg #ifdef CHECK_STACK_ALIGNMENT
42 1.5 joerg extern int check_stack_alignment(void);
43 1.5 joerg #endif
44 1.5 joerg
45 1.1 jruoho static bool error;
46 1.1 jruoho
47 1.1 jruoho static void *threadfunc1(void *);
48 1.1 jruoho static void *threadfunc2(void *);
49 1.1 jruoho
50 1.1 jruoho ATF_TC(pthread_join);
51 1.1 jruoho ATF_TC_HEAD(pthread_join, tc)
52 1.1 jruoho {
53 1.1 jruoho
54 1.1 jruoho atf_tc_set_md_var(tc, "descr",
55 1.1 jruoho "Checks basic error conditions in pthread_join(3)");
56 1.1 jruoho }
57 1.1 jruoho
58 1.1 jruoho ATF_TC_BODY(pthread_join, tc)
59 1.1 jruoho {
60 1.1 jruoho pthread_t thread;
61 1.1 jruoho
62 1.1 jruoho PTHREAD_REQUIRE(pthread_create(&thread, NULL, threadfunc1, NULL));
63 1.1 jruoho PTHREAD_REQUIRE(pthread_join(thread, NULL));
64 1.1 jruoho }
65 1.1 jruoho
66 1.1 jruoho static void *
67 1.1 jruoho threadfunc1(void *arg)
68 1.1 jruoho {
69 1.1 jruoho pthread_t thread[25];
70 1.1 jruoho pthread_t caller;
71 1.4 hans void *val = NULL;
72 1.4 hans uintptr_t i;
73 1.1 jruoho int rv;
74 1.1 jruoho
75 1.1 jruoho caller = pthread_self();
76 1.1 jruoho
77 1.5 joerg #ifdef CHECK_STACK_ALIGNMENT
78 1.5 joerg /*
79 1.5 joerg * Check alignment of thread stack, if supported.
80 1.5 joerg */
81 1.5 joerg ATF_REQUIRE(check_stack_alignment());
82 1.5 joerg #endif
83 1.5 joerg
84 1.1 jruoho /*
85 1.1 jruoho * The behavior is undefined, but should error
86 1.1 jruoho * out, if we try to join the calling thread.
87 1.1 jruoho */
88 1.1 jruoho rv = pthread_join(caller, NULL);
89 1.1 jruoho
90 1.1 jruoho /*
91 1.1 jruoho * The specification recommends EDEADLK.
92 1.1 jruoho */
93 1.1 jruoho ATF_REQUIRE(rv != 0);
94 1.1 jruoho ATF_REQUIRE_EQ(rv, EDEADLK);
95 1.1 jruoho
96 1.1 jruoho for (i = 0; i < __arraycount(thread); i++) {
97 1.1 jruoho
98 1.1 jruoho error = true;
99 1.1 jruoho
100 1.4 hans rv = pthread_create(&thread[i], NULL, threadfunc2, (void *)i);
101 1.1 jruoho
102 1.1 jruoho ATF_REQUIRE_EQ(rv, 0);
103 1.1 jruoho
104 1.1 jruoho /*
105 1.1 jruoho * Try to join an invalid thread.
106 1.1 jruoho */
107 1.1 jruoho rv = pthread_join(thread[i + 1], NULL);
108 1.1 jruoho
109 1.1 jruoho ATF_REQUIRE_EQ(rv, ESRCH);
110 1.1 jruoho
111 1.1 jruoho /*
112 1.1 jruoho * Check join and exit condition.
113 1.1 jruoho */
114 1.1 jruoho PTHREAD_REQUIRE(pthread_join(thread[i], &val));
115 1.1 jruoho
116 1.1 jruoho ATF_REQUIRE_EQ(error, false);
117 1.1 jruoho
118 1.4 hans ATF_REQUIRE(val != NULL);
119 1.4 hans ATF_REQUIRE(val == (void *)(i + 1));
120 1.4 hans
121 1.1 jruoho /*
122 1.1 jruoho * Once the thread has returned, ESRCH should
123 1.1 jruoho * again follow if we try to join it again.
124 1.1 jruoho */
125 1.1 jruoho rv = pthread_join(thread[i], NULL);
126 1.1 jruoho
127 1.1 jruoho ATF_REQUIRE_EQ(rv, ESRCH);
128 1.1 jruoho
129 1.1 jruoho /*
130 1.1 jruoho * Try to detach the exited thread.
131 1.1 jruoho */
132 1.1 jruoho rv = pthread_detach(thread[i]);
133 1.1 jruoho
134 1.1 jruoho ATF_REQUIRE(rv != 0);
135 1.1 jruoho }
136 1.1 jruoho
137 1.1 jruoho pthread_exit(NULL);
138 1.1 jruoho
139 1.1 jruoho return NULL;
140 1.1 jruoho }
141 1.1 jruoho
142 1.1 jruoho static void *
143 1.1 jruoho threadfunc2(void *arg)
144 1.1 jruoho {
145 1.4 hans static uintptr_t i = 0;
146 1.4 hans uintptr_t j;
147 1.1 jruoho
148 1.4 hans j = (uintptr_t)arg;
149 1.1 jruoho
150 1.1 jruoho if (i++ == j)
151 1.1 jruoho error = false;
152 1.1 jruoho
153 1.4 hans pthread_exit((void *)i);
154 1.1 jruoho
155 1.1 jruoho return NULL;
156 1.1 jruoho }
157 1.1 jruoho
158 1.1 jruoho ATF_TP_ADD_TCS(tp)
159 1.1 jruoho {
160 1.1 jruoho
161 1.1 jruoho ATF_TP_ADD_TC(tp, pthread_join);
162 1.1 jruoho
163 1.1 jruoho return atf_no_error();
164 1.1 jruoho }
165