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
RevLine 
[70d28e8]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
[62273d1]49 TPRINTF("11 match\n");
[70d28e8]50
51 task_wait_set(&wait, TASK_WAIT_EXIT);
52 rc = dummy_task_spawn(&tid, &wait, STR_FAIL);
53 TASSERT(rc == EOK);
54
[62273d1]55 TPRINTF("waiting...");
[d4ec49e]56 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]57 rc = task_wait(&wait, &texit, &retval);
[62273d1]58 TPRINTF("done.\n");
[70d28e8]59 TASSERT(rc == EOK);
[d4ec49e]60 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]61 TASSERT(texit == TASK_EXIT_UNEXPECTED);
[62273d1]62 TPRINTF("OK\n");
[70d28e8]63 /* ---- */
64
[62273d1]65 TPRINTF("12 lost wait\n");
[70d28e8]66
67 task_wait_set(&wait, TASK_WAIT_RETVAL);
68 rc = dummy_task_spawn(&tid, &wait, STR_FAIL);
69 TASSERT(rc == EOK);
70
[62273d1]71 TPRINTF("waiting...");
[d4ec49e]72 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]73 rc = task_wait(&wait, &texit, &retval);
[62273d1]74 TPRINTF("done.\n");
[012dd8e]75 TASSERT(rc == EINTR);
[d4ec49e]76 TASSERT(task_wait_get(&wait) == 0);
[62273d1]77 TPRINTF("OK\n");
[70d28e8]78 /* ---- */
79
[62273d1]80 TPRINTF("13 partial match\n");
[70d28e8]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
[62273d1]86 TPRINTF("waiting...");
[d4ec49e]87 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]88 rc = task_wait(&wait, &texit, &retval);
[62273d1]89 TPRINTF("done.\n");
[70d28e8]90 TASSERT(rc == EOK);
[d4ec49e]91 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]92 TASSERT(texit == TASK_EXIT_UNEXPECTED);
93 /* retval is undefined */
[62273d1]94 TPRINTF("OK\n");
[70d28e8]95 /* ---- */
96
[d4ec49e]97 TPRINTF("21 ignore retval and still wait for exit\n");
[70d28e8]98
99 task_wait_set(&wait, TASK_WAIT_EXIT);
[d4ec49e]100 /* STR_JOB_OK to emulate daemon that eventually terminates */
[70d28e8]101 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
102 TASSERT(rc == EOK);
103
[62273d1]104 TPRINTF("waiting...");
[d4ec49e]105 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]106 rc = task_wait(&wait, &texit, &retval);
[62273d1]107 TPRINTF("done.\n");
[70d28e8]108 TASSERT(rc == EOK);
[d4ec49e]109 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]110 TASSERT(texit == TASK_EXIT_NORMAL);
111 /* retval is unknown */
[62273d1]112 TPRINTF("OK\n");
[70d28e8]113 /* ---- */
114
[62273d1]115 TPRINTF("22 good match\n");
[70d28e8]116
117 task_wait_set(&wait, TASK_WAIT_RETVAL);
118 rc = dummy_task_spawn(&tid, &wait, STR_DAEMON);
119 TASSERT(rc == EOK);
120
[62273d1]121 TPRINTF("waiting...");
[d4ec49e]122 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]123 rc = task_wait(&wait, &texit, &retval);
[62273d1]124 TPRINTF("done.\n");
[70d28e8]125 TASSERT(rc == EOK);
[d4ec49e]126 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]127 /* exit is not expected */
128 TASSERT(retval == EOK);
129 task_kill(tid); /* Terminate daemon */
[62273d1]130 TPRINTF("OK\n");
[70d28e8]131 /* ---- */
132
[62273d1]133 TPRINTF("23 partial match (non-exited task)\n");
[70d28e8]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
[62273d1]139 TPRINTF("waiting...");
[d4ec49e]140 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]141 rc = task_wait(&wait, &texit, &retval);
[62273d1]142 TPRINTF("done.\n");
[70d28e8]143 TASSERT(rc == EOK);
[d4ec49e]144 TASSERT(task_wait_get(&wait) == TASK_WAIT_EXIT);
[70d28e8]145 /* exit is not expected */
146 TASSERT(retval == EOK);
147 task_kill(tid); /* Terminate daemon */
[62273d1]148 TPRINTF("OK\n");
[70d28e8]149 /* ---- */
150
[62273d1]151 TPRINTF("31 on exit return\n");
[70d28e8]152
153 task_wait_set(&wait, TASK_WAIT_EXIT);
154 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
155 TASSERT(rc == EOK);
156
[62273d1]157 TPRINTF("waiting...");
[d4ec49e]158 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]159 rc = task_wait(&wait, &texit, &retval);
[62273d1]160 TPRINTF("done.\n");
[70d28e8]161 TASSERT(rc == EOK);
[d4ec49e]162 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]163 TASSERT(texit == TASK_EXIT_NORMAL);
164 /* retval is unknown */
[62273d1]165 TPRINTF("OK\n");
[70d28e8]166 /* ---- */
167
168
[62273d1]169 TPRINTF("32 keep retval until exit\n");
[70d28e8]170
171 task_wait_set(&wait, TASK_WAIT_RETVAL);
172 rc = dummy_task_spawn(&tid, &wait, STR_JOB_OK);
173 TASSERT(rc == EOK);
174
[62273d1]175 TPRINTF("waiting...");
[d4ec49e]176 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]177 rc = task_wait(&wait, &texit, &retval);
[62273d1]178 TPRINTF("done.\n");
[70d28e8]179 TASSERT(rc == EOK);
[d4ec49e]180 /* Job atomically exited, so there's nothing more to wait for. */
181 TASSERT(task_wait_get(&wait) == 0);
[70d28e8]182 /* exit is unknown */
183 TASSERT(retval == EOK);
184 /* check task already exited */
185 rc = task_kill(tid);
186 TASSERT(rc == ENOENT);
[62273d1]187 TPRINTF("OK\n");
[70d28e8]188 /* ---- */
189
[62273d1]190 TPRINTF("33 double good match\n");
[70d28e8]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
[62273d1]196 TPRINTF("waiting...");
[d4ec49e]197 texit = TASK_EXIT_RUNNING; retval = 255;
[70d28e8]198 rc = task_wait(&wait, &texit, &retval);
[62273d1]199 TPRINTF("done.\n");
[70d28e8]200 TASSERT(rc == EOK);
[d4ec49e]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");
[012dd8e]217 TASSERT(rc == EINTR);
[d4ec49e]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);
[5cd2290]244 TASSERT(texit == TASK_EXIT_UNEXPECTED);
[d4ec49e]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);
[70d28e8]260 TASSERT(texit == TASK_EXIT_NORMAL);
261 TASSERT(retval == EOK);
[62273d1]262 TPRINTF("OK\n");
[70d28e8]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.