version 1.29, 2022/10/17 22:45:06
|
version 1.29.8.1, 2023/01/18 22:25:54
|
Line 12 terms:
|
Line 12 terms:
|
All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
|
|
Copyright 2004 - 2022 | Copyright 2004 - 2023 |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
|
|
Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
Line 560 schedQuery(sched_task_t * __restrict task)
|
Line 560 schedQuery(sched_task_t * __restrict task)
|
* [ CRITERIA_ANY|CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL| |
* [ CRITERIA_ANY|CRITERIA_CALL|CRITERIA_ARG|CRITERIA_FD|CRITERIA_VAL| |
* CRITERIA_ID|CRITERIA_TS|CRITERIA_DATA|CRITERIA_DATLEN ] |
* CRITERIA_ID|CRITERIA_TS|CRITERIA_DATA|CRITERIA_DATLEN ] |
* @param = search parameter |
* @param = search parameter |
* return: -1 error, 0 found or 1 not found | * return: NULL not found or !=NULL task |
*/ |
*/ |
int | sched_task_t * |
schedQueryby(sched_root_task_t * __restrict root, sched_task_type_t type, |
schedQueryby(sched_root_task_t * __restrict root, sched_task_type_t type, |
u_char criteria, void *param) |
u_char criteria, void *param) |
{ |
{ |
sched_task_t *task; |
sched_task_t *task; |
sched_queue_t *queue; |
sched_queue_t *queue; |
register int flg = 0; |
|
|
|
if (!root) |
if (!root) |
return -1; | return NULL; |
/* if type == taskMAX check in all queues */ |
/* if type == taskMAX check in all queues */ |
if (type == taskMAX) { |
if (type == taskMAX) { |
if ((flg = schedQueryby(root, taskREAD, criteria, param)) < 1) | if ((task = schedQueryby(root, taskREAD, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskWRITE, criteria, param)) < 1) | if ((task = schedQueryby(root, taskWRITE, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskTIMER, criteria, param)) < 1) | if ((task = schedQueryby(root, taskTIMER, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskALARM, criteria, param)) < 1) | if ((task = schedQueryby(root, taskALARM, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskRTC, criteria, param)) < 1) | if ((task = schedQueryby(root, taskRTC, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskNODE, criteria, param)) < 1) | if ((task = schedQueryby(root, taskNODE, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskPROC, criteria, param)) < 1) | if ((task = schedQueryby(root, taskPROC, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskSIGNAL, criteria, param)) < 1) | if ((task = schedQueryby(root, taskSIGNAL, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskAIO, criteria, param)) < 1) | if ((task = schedQueryby(root, taskAIO, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskLIO, criteria, param)) < 1) | if ((task = schedQueryby(root, taskLIO, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskUSER, criteria, param)) < 1) | if ((task = schedQueryby(root, taskUSER, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskEVENT, criteria, param)) < 1) | if ((task = schedQueryby(root, taskEVENT, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskTASK, criteria, param)) < 1) | if ((task = schedQueryby(root, taskTASK, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskSUSPEND, criteria, param)) < 1) | if ((task = schedQueryby(root, taskSUSPEND, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskREADY, criteria, param)) < 1) | if ((task = schedQueryby(root, taskREADY, criteria, param))) |
return flg; | return task; |
if ((flg = schedQueryby(root, taskTHREAD, criteria, param)) < 1) | if ((task = schedQueryby(root, taskTHREAD, criteria, param))) |
return flg; | return task; |
return 1; /* not found */ | return NULL; /* not found */ |
} |
} |
/* choosen queue */ |
/* choosen queue */ |
switch (type) { |
switch (type) { |
Line 659 schedQueryby(sched_root_task_t * __restrict root, sche
|
Line 658 schedQueryby(sched_root_task_t * __restrict root, sche
|
queue = &root->root_thread; |
queue = &root->root_thread; |
break; |
break; |
default: |
default: |
return 1; /* not found */ | return NULL; /* not found */ |
} |
} |
|
|
TAILQ_FOREACH(task, queue, task_node) { |
TAILQ_FOREACH(task, queue, task_node) { |
switch (criteria) { |
switch (criteria) { |
case CRITERIA_ANY: |
case CRITERIA_ANY: |
return 0; /* found */ | return task; /* found */ |
case CRITERIA_CALL: |
case CRITERIA_CALL: |
if (TASK_FUNC(task) == (sched_task_func_t) param) |
if (TASK_FUNC(task) == (sched_task_func_t) param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_ARG: |
case CRITERIA_ARG: |
if (TASK_ARG(task) == param) |
if (TASK_ARG(task) == param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_FD: |
case CRITERIA_FD: |
if (TASK_FD(task) == (intptr_t) param) |
if (TASK_FD(task) == (intptr_t) param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_ID: |
case CRITERIA_ID: |
case CRITERIA_VAL: |
case CRITERIA_VAL: |
if (TASK_VAL(task) == (u_long) param) |
if (TASK_VAL(task) == (u_long) param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_TS: |
case CRITERIA_TS: |
if (!sched_timespeccmp(&TASK_TS(task), |
if (!sched_timespeccmp(&TASK_TS(task), |
(struct timespec*) param, -)) |
(struct timespec*) param, -)) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_DATA: |
case CRITERIA_DATA: |
if (TASK_DATA(task) == param) |
if (TASK_DATA(task) == param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
case CRITERIA_DATLEN: |
case CRITERIA_DATLEN: |
if (TASK_DATLEN(task) == (size_t) param) |
if (TASK_DATLEN(task) == (size_t) param) |
return 0; /* found */ | return task; /* found */ |
break; |
break; |
default: |
default: |
sched_SetErr(EINVAL, "Invalid parameter criteria %d", |
sched_SetErr(EINVAL, "Invalid parameter criteria %d", |
criteria); |
criteria); |
return 1; /* not found */ | return NULL; /* not found */ |
} |
} |
} |
} |
|
|
return 1; /* not found */ | return NULL; /* not found */ |
} |
} |
|
|
/* |
/* |