source: mainline/uspace/app/tester/proc/task_wait.c@ 012dd8e

Last change on this file since 012dd8e was 012dd8e, checked in by Matthieu Riolo <matthieu.riolo@…>, 6 years ago

taskman: Handle INIT_TASKS as tasks spawned by loader

  • everyone is connected to its spawner, except for INIT_TASKS, they are connected to taskman (first binary)
  • taskman is now aware even of INIT_TASKS and taskman itself
  • refactored taskman handshake — NS session is created lazily
  • refactored async.c with usage of create_session
  • changed EINVAL to EINTR on lost waits
  • removed TODOs from taskman and related libc TODOs

Conflicts:

abi/include/abi/ipc/methods.h
boot/Makefile.common
uspace/lib/c/generic/async.c
uspace/lib/c/generic/libc.c
uspace/lib/c/generic/loader.c
uspace/lib/c/generic/ns.c
uspace/lib/c/generic/private/async.h
uspace/lib/c/generic/private/taskman.h
uspace/lib/c/generic/task.c
uspace/lib/c/include/async.h
uspace/lib/c/include/task.h
uspace/srv/loader/main.c
uspace/srv/ns/ns.c
  • Property mode set to 100644
File size: 7.3 KB
Line 
1/*
2 * Copyright (c) 2015 Michal Koutny
3 * All rights reserved.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions
7 * are met:
8 *
9 * - Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 * - Redistributions in binary form must reproduce the above copyright
12 * notice, this list of conditions and the following disclaimer in the
13 * documentation and/or other materials provided with the distribution.
14 * - The name of the author may not be used to endorse or promote products
15 * derived from this software without specific prior written permission.
16 *
17 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 */
28
29#include <async.h>
30#include <errno.h>
31#include <stdio.h>
32#include <stdlib.h>
33#include <task.h>
34
35#include "../tester.h"
36#include "common.h"
37
38
39const char *test_proc_task_wait(void)
40{
41 const char *err = NULL;
42
43 int rc;
44 task_id_t tid;
45 task_wait_t wait;
46 int retval;
47 task_exit_t texit;
48
49 TPRINTF("11 match\n");
50
51 task_wait_set(&wait, TASK_WAIT_EXIT);
52 rc = dummy_task_spawn(&tid, &wait, STR_FAIL);
53 TASSERT(rc == EOK);
54
55 TPRINTF("waiting...");
56 texit = TASK_EXIT_RUNNING; retval = 255;
57 rc = task_wait(&wait, &texit, &retval);
58 TPRINTF("done.\n");
59 TASSERT(rc == EOK);
60 TASSERT(task_wait_get(&wait) == 0);
61 TASSERT(texit == TASK_EXIT_UNEXPECTED);
62 TPRINTF("OK\n");
63 /* ---- */
64
65 TPRINTF("12 lost wait\n");
66
67 task_wait_set(&wait, TASK_WAIT_RETVAL);
68 rc = dummy_task_spawn(&tid, &wait, STR_FAIL);
69 TASSERT(rc == EOK);
70
71 TPRINTF("waiting...");
72 texit = TASK_EXIT_RUNNING; retval = 255;
73 rc = task_wait(&wait, &texit, &retval);
74 TPRINTF("done.\n");
75 TASSERT(rc == EINTR);
76 TASSERT(task_wait_get(&wait) == 0);
77 TPRINTF("OK\n");
78 /* ---- */
79
80 TPRINTF("13 partial match\n");
81
82 task_wait_set(&wait, TASK_WAIT_RETVAL | TASK_WAIT_EXIT);
83 rc = dummy_task_spawn(&tid, &wait, STR_BYPASS);
84 TASSERT(rc == EOK);
85
86 TPRINTF("waiting...");
87 texit = TASK_EXIT_RUNNING; retval = 255;
88 rc = task_wait(&wait, &texit, &retval);
89 TPRINTF("done.\n");
90 TASSERT(rc == EOK);
91 TASSERT(task_wait_get(&wait) == 0);
92 TASSERT(texit == TASK_EXIT_UNEXPECTED);
93 /* retval is undefined */
94 TPRINTF("OK\n");
95 /* ---- */
96
97 TPRINTF("21 ignore retval and still wait for exit\n");
98
99 task_wait_set(&wait, TASK_WAIT_EXIT);
100 /* STR_JOB_OK to emulate daemon that eventually terminates */
101 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
102 TASSERT(rc == EOK);
103
104 TPRINTF("waiting...");
105 texit = TASK_EXIT_RUNNING; retval = 255;
106 rc = task_wait(&wait, &texit, &retval);
107 TPRINTF("done.\n");
108 TASSERT(rc == EOK);
109 TASSERT(task_wait_get(&wait) == 0);
110 TASSERT(texit == TASK_EXIT_NORMAL);
111 /* retval is unknown */
112 TPRINTF("OK\n");
113 /* ---- */
114
115 TPRINTF("22 good match\n");
116
117 task_wait_set(&wait, TASK_WAIT_RETVAL);
118 rc = dummy_task_spawn(&tid, &wait, STR_DAEMON);
119 TASSERT(rc == EOK);
120
121 TPRINTF("waiting...");
122 texit = TASK_EXIT_RUNNING; retval = 255;
123 rc = task_wait(&wait, &texit, &retval);
124 TPRINTF("done.\n");
125 TASSERT(rc == EOK);
126 TASSERT(task_wait_get(&wait) == 0);
127 /* exit is not expected */
128 TASSERT(retval == EOK);
129 task_kill(tid); /* Terminate daemon */
130 TPRINTF("OK\n");
131 /* ---- */
132
133 TPRINTF("23 partial match (non-exited task)\n");
134
135 task_wait_set(&wait, TASK_WAIT_RETVAL | TASK_WAIT_EXIT);
136 rc = dummy_task_spawn(&tid, &wait, STR_DAEMON);
137 TASSERT(rc == EOK);
138
139 TPRINTF("waiting...");
140 texit = TASK_EXIT_RUNNING; retval = 255;
141 rc = task_wait(&wait, &texit, &retval);
142 TPRINTF("done.\n");
143 TASSERT(rc == EOK);
144 TASSERT(task_wait_get(&wait) == TASK_WAIT_EXIT);
145 /* exit is not expected */
146 TASSERT(retval == EOK);
147 task_kill(tid); /* Terminate daemon */
148 TPRINTF("OK\n");
149 /* ---- */
150
151 TPRINTF("31 on exit return\n");
152
153 task_wait_set(&wait, TASK_WAIT_EXIT);
154 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
155 TASSERT(rc == EOK);
156
157 TPRINTF("waiting...");
158 texit = TASK_EXIT_RUNNING; retval = 255;
159 rc = task_wait(&wait, &texit, &retval);
160 TPRINTF("done.\n");
161 TASSERT(rc == EOK);
162 TASSERT(task_wait_get(&wait) == 0);
163 TASSERT(texit == TASK_EXIT_NORMAL);
164 /* retval is unknown */
165 TPRINTF("OK\n");
166 /* ---- */
167
168
169 TPRINTF("32 keep retval until exit\n");
170
171 task_wait_set(&wait, TASK_WAIT_RETVAL);
172 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
173 TASSERT(rc == EOK);
174
175 TPRINTF("waiting...");
176 texit = TASK_EXIT_RUNNING; retval = 255;
177 rc = task_wait(&wait, &texit, &retval);
178 TPRINTF("done.\n");
179 TASSERT(rc == EOK);
180 /* Job atomically exited, so there's nothing more to wait for. */
181 TASSERT(task_wait_get(&wait) == 0);
182 /* exit is unknown */
183 TASSERT(retval == EOK);
184 /* check task already exited */
185 rc = task_kill(tid);
186 TASSERT(rc == ENOENT);
187 TPRINTF("OK\n");
188 /* ---- */
189
190 TPRINTF("33 double good match\n");
191
192 task_wait_set(&wait, TASK_WAIT_RETVAL | TASK_WAIT_EXIT);
193 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
194 TASSERT(rc == EOK);
195
196 TPRINTF("waiting...");
197 texit = TASK_EXIT_RUNNING; retval = 255;
198 rc = task_wait(&wait, &texit, &retval);
199 TPRINTF("done.\n");
200 TASSERT(rc == EOK);
201 TASSERT(task_wait_get(&wait) == 0);
202 TASSERT(texit == TASK_EXIT_NORMAL);
203 TASSERT(retval == EOK);
204 TPRINTF("OK\n");
205 /* ---- */
206
207 TPRINTF("14 partially lost wait\n");
208
209 task_wait_set(&wait, TASK_WAIT_BOTH);
210 rc = dummy_task_spawn(&tid, &wait, STR_FAIL);
211 TASSERT(rc == EOK);
212
213 TPRINTF("waiting...");
214 texit = TASK_EXIT_RUNNING; retval = 255;
215 rc = task_wait(&wait, &texit, &retval);
216 TPRINTF("done.\n");
217 TASSERT(rc == EINTR);
218 TASSERT(task_wait_get(&wait) == 0);
219 TASSERT(texit == TASK_EXIT_UNEXPECTED);
220 /* retval is undefined */
221 TPRINTF("OK\n");
222 /* ---- */
223
224 TPRINTF("24 repeated wait\n");
225
226 task_wait_set(&wait, TASK_WAIT_BOTH);
227 rc = dummy_task_spawn(&tid, &wait, STR_DAEMON);
228 TASSERT(rc == EOK);
229
230 TPRINTF("waiting...");
231 texit = TASK_EXIT_RUNNING; retval = 255;
232 rc = task_wait(&wait, &texit, &retval);
233 TPRINTF("done.\n");
234 TASSERT(rc == EOK);
235 TASSERT(task_wait_get(&wait) == TASK_WAIT_EXIT);
236 TASSERT(retval == EOK);
237 task_kill(tid); /* Terminate daemon */
238 TPRINTF("waiting 2...");
239 texit = TASK_EXIT_RUNNING; retval = 255;
240 rc = task_wait(&wait, &texit, &retval);
241 TPRINTF("done.\n");
242 TASSERT(rc == EOK);
243 TASSERT(task_wait_get(&wait) == 0);
244 TASSERT(texit == TASK_EXIT_UNEXPECTED);
245 TPRINTF("OK\n");
246 /* ---- */
247
248 TPRINTF("34 double wait in one\n");
249
250 task_wait_set(&wait, TASK_WAIT_BOTH);
251 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
252 TASSERT(rc == EOK);
253
254 TPRINTF("waiting...");
255 texit = TASK_EXIT_RUNNING; retval = 255;
256 rc = task_wait(&wait, &texit, &retval);
257 TPRINTF("done.\n");
258 TASSERT(rc == EOK);
259 TASSERT(task_wait_get(&wait) == 0);
260 TASSERT(texit == TASK_EXIT_NORMAL);
261 TASSERT(retval == EOK);
262 TPRINTF("OK\n");
263 /* ---- */
264
265 TPRINTF("All task waiting tests finished");
266
267
268
269 return err;
270}
Note: See TracBrowser for help on using the repository browser.