1 /* $NetBSD: h_execthr.c,v 1.7 2016/11/24 00:37:29 dholland Exp $ */
4 * Copyright (c) 2011 The NetBSD Foundation, Inc.
7 * Redistribution and use in source and binary forms, with or without
8 * modification, are permitted provided that the following conditions
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.
16 * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND
17 * CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
18 * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
19 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS BE LIABLE FOR ANY
21 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
23 * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
24 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER
25 * IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
26 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN
27 * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
30 #include <sys/types.h>
31 #include <sys/sysctl.h>
42 #include <rump/rumpclient.h>
43 #include <rump/rump_syscalls.h>
48 #define SAY(...) printf(__VA_ARGS__)
53 static int canreturn = 0;
56 * Use a fairly large number of threads so that we have
57 * a better chance catching races. XXX: this is rumpuser's
70 int fd = (uintptr_t)arg;
72 rump_sys_read(fd, &fd, sizeof(fd));
74 errx(1, "should not have returned");
76 errx(1, "got invalid magic");
82 getproc(pid_t mypid, struct kinfo_proc2 *p)
85 size_t len = sizeof(*p);
89 name[2] = KERN_PROC_PID;
94 return rump_sys___sysctl(name, __arraycount(name), p, &len, NULL, 0);
98 main(int argc, char *argv[], char *envp[])
100 struct kinfo_proc2 p;
110 execd = atoi(argv[1]);
113 sprintf(nexec, "%d", execd+1);
114 SAY("execd: %d\n", execd);
116 if (rumpclient_init() == -1) {
118 err(1, "init execd");
122 mypid = rump_sys_getpid();
123 SAY("rumpclient_init finished.\n");
127 errno = pthread_create(&pt, NULL,
128 wrk, (void *)(uintptr_t)P2_0);
130 err(1, "exec pthread_create");
131 SAY("startup pthread_create finished.\n");
134 rump_sys_write(P2_1, &i, sizeof(i));
135 pthread_join(pt, NULL);
136 SAY("startup pthread_join finished.\n");
138 n = rump_sys_read(P1_0, &i, sizeof(i));
139 if (n != -1 || errno != EBADF)
140 errx(1, "post-exec cloexec works");
141 SAY("startup rump_sys_read finished.\n");
144 SAY("startup getproc finished.\n");
146 errx(1, "invalid nlwps: %lld", (long long)p.p_nlwps);
154 rump_sys_close(P2_0);
155 rump_sys_close(P2_1);
158 SAY("making pipes...\n");
160 if (rump_sys_pipe(p1) == -1)
162 if (p1[0] != P1_0 || p1[1] != P1_1)
163 errx(1, "p1 assumptions failed %d %d", p1[0], p1[1]);
164 if (rump_sys_pipe(p2) == -1)
166 if (p2[0] != P2_0 || p2[1] != P2_1)
167 errx(1, "p2 assumptions failed");
168 if (rump_sys_fcntl(p1[0], F_SETFD, FD_CLOEXEC) == -1)
170 if (rump_sys_fcntl(p1[1], F_SETFD, FD_CLOEXEC) == -1)
173 SAY("making threads...\n");
175 for (i = 0; i < NTHR; i++) {
176 errno = pthread_create(&pt, NULL,
177 wrk, (void *)(uintptr_t)p1[0]);
179 err(1, "pthread_create 1 %d", i);
182 for (i = 0; i < NTHR; i++) {
183 errno = pthread_create(&pt, NULL,
184 wrk, (void *)(uintptr_t)p2[0]);
186 err(1, "pthread_create 2 %d", i);
189 SAY("waiting for threads to start...\n");
191 /* wait for all the threads to be enjoying themselves */
194 SAY("getproc finished.\n");
195 if (p.p_nlwps == 2*NTHR + 2)
200 SAY("making some more threads start...\n");
203 * load up one more (big) set. these won't start executing, though,
204 * but we're interested in if they create blockage
206 for (i = 0; i < 3*NTHR; i++) {
207 errno = pthread_create(&pt, NULL,
208 wrk, (void *)(uintptr_t)p1[0]);
210 err(1, "pthread_create 3 %d", i);
213 SAY("calling exec...\n");
216 execarg[0] = argv[0];
219 if (rumpclient_exec(argv[0], execarg, envp) == -1)