--- libaitsched/src/aitsched.c 2012/08/01 12:49:26 1.11.2.2 +++ libaitsched/src/aitsched.c 2012/08/02 13:45:02 1.11.2.3 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitsched.c,v 1.11.2.2 2012/08/01 12:49:26 misho Exp $ +* $Id: aitsched.c,v 1.11.2.3 2012/08/02 13:45:02 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -165,6 +165,7 @@ schedInit(void ** __restrict data, size_t datlen) TAILQ_INIT(&root->root_proc); TAILQ_INIT(&root->root_signal); TAILQ_INIT(&root->root_aio); + TAILQ_INIT(&root->root_lio); TAILQ_INIT(&root->root_user); TAILQ_INIT(&root->root_event); TAILQ_INIT(&root->root_eventlo); @@ -228,6 +229,8 @@ schedEnd(sched_root_task_t ** __restrict root) schedCancel(task); TAILQ_FOREACH_SAFE(task, &(*root)->root_aio, task_node, tmp) schedCancel(task); + TAILQ_FOREACH_SAFE(task, &(*root)->root_lio, task_node, tmp) + schedCancel(task); TAILQ_FOREACH_SAFE(task, &(*root)->root_user, task_node, tmp) schedCancel(task); TAILQ_FOREACH_SAFE(task, &(*root)->root_event, task_node, tmp) @@ -384,6 +387,9 @@ schedCancel(sched_task_t * __restrict task) case taskAIO: queue = &TASK_ROOT(task)->root_aio; break; + case taskLIO: + queue = &TASK_ROOT(task)->root_lio; + break; case taskUSER: queue = &TASK_ROOT(task)->root_user; break; @@ -456,6 +462,8 @@ schedCancelby(sched_root_task_t * __restrict root, sch return -2; if (schedCancelby(root, taskAIO, criteria, param, hook)) return -2; + if (schedCancelby(root, taskLIO, criteria, param, hook)) + return -2; if (schedCancelby(root, taskUSER, criteria, param, hook)) return -2; if (schedCancelby(root, taskEVENT, criteria, param, hook)) @@ -493,6 +501,9 @@ schedCancelby(sched_root_task_t * __restrict root, sch break; case taskAIO: queue = &root->root_aio; + break; + case taskLIO: + queue = &root->root_lio; break; case taskUSER: queue = &root->root_user;