Blame |
Last modification |
View Log
| RSS feed
/*
* Project: HARTIK (HA-rd R-eal TI-me K-ernel)
*
* Coordinators: Giorgio Buttazzo <giorgio@sssup.it>
* Gerardo Lamastra <gerardo@sssup.it>
*
* Authors : Paolo Gai <pj@hartik.sssup.it>
* (see authors.txt for full list of hartik's authors)
*
* ReTiS Lab (Scuola Superiore S.Anna - Pisa - Italy)
*
* http://www.sssup.it
* http://retis.sssup.it
* http://hartik.sssup.it
*/
/**
------------
CVS : $Id: testq.c,v 1.1.1.1 2002-09-02 09:37:48 pj Exp $
File: $File$
Revision: $Revision: 1.1.1.1 $
Last update: $Date: 2002-09-02 09:37:48 $
------------
Test Number 26 (Q):
This test verify the correctness of the task_join primitive.
There are 4 taks, J1, J2, J3, are created as joinable, J4 as detached
(the standard with hartik...)
The main task:
Creates J1 and J2, locks m1 (a PI mitex), creates C3.
at t=0.8 sec it calls a task_join on J3 (that returns EDEADLK),
it unlocks m1, then it makes task_join on J3 another time.
Next it creates J4 as detached and finally it does a task_join on J4
(that returns EINVAL).
J1:
at t=0.2 sec it calls task_join on J2, the it ends.
J2:
it simply waits t=0.4 sec and it ends.
J3:
First, it calls task_join on J1.
Then, at t=0.6 sec it locks m1, then unlocks it
J4:
it simply waits t=1 sec and it ends.
**/
/*
* Copyright (C) 2000 Paolo Gai
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*/
#include "kernel/kern.h"
#include "drivers/keyb.h"
#include <modules//srp.h>
PID j0, j1, j2, j3, j4;
mutex_t m1;
void fine(KEY_EVT *e)
{
sys_end();
}
TASK J1()
{
int err;
void *ret;
kern_printf("J1: started, waiting 0.2 sec\n");
while (sys_gettime(NULL) < 200000);
kern_printf("J1: 0.2 sec reached, joining J2\n");
err = task_join(j2, &ret);
kern_printf("J1: join J2 returns %d error %d, exiting\n",
(int)ret,err);
return (void *)11;
}
TASK J2()
{
kern_printf("J2: started, waiting 0.4 sec\n");
while (sys_gettime(NULL) < 400000);
kern_printf("J2: 0.4 sec reached, exiting\n");
return (void *)22;
}
TASK J3()
{
int err;
void *ret;
kern_printf("J3: started, joining J1\n");
err = task_join(j1, &ret);
kern_printf("J3: join J1 returns %d error %d, waiting 0.6sec\n", (int)ret, err);
while (sys_gettime(NULL) < 600000);
kern_printf("J1: 0.6 sec reached, locking m1\n");
mutex_lock(&m1);
kern_printf("J3: locked m1, unlocking m1\n");
mutex_unlock(&m1);
kern_printf("J3: unlocked m1, exiting\n");
return (void *)33;
}
TASK J4()
{
kern_printf("J4: started, waiting 1 sec\n");
while (sys_gettime(NULL) < 1000000);
kern_printf("J4: 1 sec reached, exiting\n");
return (void *)44;
}
int main(int argc, char **argv)
{
NRT_TASK_MODEL m;
PI_mutexattr_t a;
KEY_EVT emerg;
int err;
void *ret;
//keyb_set_map(itaMap);
emerg.ascii = 'x';
emerg.scan = KEY_X;
emerg.flag = ALTL_BIT;
keyb_hook(emerg,fine);
j0 = exec_shadow;
nrt_task_default_model(m);
nrt_task_def_joinable(m);
/* ---------------------------------------------------------------------
Mutex creation
--------------------------------------------------------------------- */
PI_mutexattr_default(a);
mutex_init(&m1,&a);
/* ---------------------------------------------------------------------
Let's go !!!!
--------------------------------------------------------------------- */
kern_printf("main: creating J1,J2,J3, locking m1\n");
j1 = task_create("J1", J1, &m, NULL);
if (j1 == NIL) { kern_printf("Can't create J1 task...\n"); return 1; }
task_activate(j1);
j2 = task_create("J2", J2, &m, NULL);
if (j2 == NIL) { kern_printf("Can't create J2 task...\n"); return 1; }
task_activate(j2);
mutex_lock(&m1);
j3 = task_create("J3", J3, &m, NULL);
if (j3 == NIL) { kern_printf("Can't create J3 task...\n"); return 1; }
task_activate(j3);
kern_printf("main: waiting t=0.8 sec\n");
while (sys_gettime(NULL) < 800000);
err = task_join(j3, NULL);
kern_printf("main: join J3 error %d, unlocking m1\n",err);
mutex_unlock(&m1);
err = task_join(j3, &ret);
kern_printf("main: join J3 returns %d error %d, unlocked m1, creating J4\n",
(int)ret,err);
nrt_task_def_unjoinable(m);
j4 = task_create("J4", J4, &m, NULL);
if (j4 == NIL) { kern_printf("Can't create J4 task...\n"); return 1; }
task_activate(j4);
err = task_join(j4,&ret);
kern_printf("main: join J4 returns %d error %d, exiting\n", (int)ret, err);
return 0;
}