version 1.12, 2012/08/02 13:56:19
|
version 1.13, 2012/08/08 08:25:39
|
Line 85 typedef enum {
|
Line 85 typedef enum {
|
taskLIO, |
taskLIO, |
taskUSER, |
taskUSER, |
taskEVENT, |
taskEVENT, |
taskEVENTLO, | taskTASK, |
taskSUSPEND, |
taskSUSPEND, |
taskREADY, |
taskREADY, |
taskUNUSE, |
taskUNUSE, |
Line 118 struct sched_HooksTask {
|
Line 118 struct sched_HooksTask {
|
sched_hook_func_t user; |
sched_hook_func_t user; |
/* event(sched_task_t *task, NULL) -> int */ |
/* event(sched_task_t *task, NULL) -> int */ |
sched_hook_func_t event; |
sched_hook_func_t event; |
/* eventlo(sched_task_t *task, NULL) -> int */ | /* task(sched_task_t *task, NULL) -> int */ |
sched_hook_func_t eventlo; | sched_hook_func_t task; |
/* suspend(sched_task_t *task, NULL) -> int */ |
/* suspend(sched_task_t *task, NULL) -> int */ |
sched_hook_func_t suspend; |
sched_hook_func_t suspend; |
} hook_add; |
} hook_add; |
Line 197 typedef TAILQ_HEAD(, sched_Task) sched_queue_t;
|
Line 197 typedef TAILQ_HEAD(, sched_Task) sched_queue_t;
|
/* root task */ |
/* root task */ |
struct sched_RootTask { |
struct sched_RootTask { |
int root_kq; |
int root_kq; |
|
unsigned int root_miss; |
|
unsigned int root_task_miss; |
struct timespec root_wait; |
struct timespec root_wait; |
struct timespec root_poll; |
struct timespec root_poll; |
intptr_t root_cond; |
intptr_t root_cond; |
Line 215 struct sched_RootTask {
|
Line 217 struct sched_RootTask {
|
sched_queue_t root_lio; |
sched_queue_t root_lio; |
sched_queue_t root_user; |
sched_queue_t root_user; |
sched_queue_t root_event; |
sched_queue_t root_event; |
sched_queue_t root_eventlo; | sched_queue_t root_task; |
sched_queue_t root_suspend; |
sched_queue_t root_suspend; |
sched_queue_t root_ready; |
sched_queue_t root_ready; |
sched_queue_t root_unuse; |
sched_queue_t root_unuse; |
int root_eventlo_miss; |
|
|
|
hooks_task_t root_hooks; |
hooks_task_t root_hooks; |
struct iovec root_data; |
struct iovec root_data; |
Line 272 inline int schedPolling(sched_root_task_t * __restrict
|
Line 273 inline int schedPolling(sched_root_task_t * __restrict
|
* |
* |
* @root = root task |
* @root = root task |
* @condValue = condition value, kill schedRun() if condValue == killState |
* @condValue = condition value, kill schedRun() if condValue == killState |
* return: -1 error ok 0 ok | * return: -1 error or 0 ok |
*/ |
*/ |
inline int schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue); |
inline int schedTermCondition(sched_root_task_t * __restrict root, intptr_t condValue); |
/* |
/* |
|
* schedMissEvents() - Set new miss events rate for regular tasks |
|
* |
|
* @root = root task |
|
* @missEvents = maximum number of missed events before firing tasks |
|
* return: -1 error or 0 ok |
|
*/ |
|
inline int schedMissEvents(sched_root_task_t * __restrict root, u_int missEvents); |
|
/* |
* schedCall() - Call task execution function |
* schedCall() - Call task execution function |
* |
* |
* @task = current task |
* @task = current task |
Line 550 sched_task_t *schedEvent(sched_root_task_t * __restric
|
Line 559 sched_task_t *schedEvent(sched_root_task_t * __restric
|
#define schedEventSelf(x) schedEvent(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
#define schedEventSelf(x) schedEvent(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
/* |
/* |
* schedEventLo() - Add EVENT_Lo task to scheduler queue | * schedTask() - Add regular task to scheduler queue |
* |
* |
* @root = root task |
* @root = root task |
* @func = task execution function |
* @func = task execution function |
* @arg = 1st func argument |
* @arg = 1st func argument |
* @val = additional func argument | * @prio = regular task priority, 0 is hi priority for regular tasks |
* @opt_data = Optional data |
* @opt_data = Optional data |
* @opt_dlen = Optional data length |
* @opt_dlen = Optional data length |
* return: NULL error or !=NULL new queued task |
* return: NULL error or !=NULL new queued task |
*/ |
*/ |
sched_task_t *schedEventLo(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, | sched_task_t *schedTask(sched_root_task_t * __restrict root, sched_task_func_t func, void *arg, |
unsigned long val, void *opt_data, size_t opt_dlen); | unsigned long prio, void *opt_data, size_t opt_dlen); |
#define schedEventLoSelf(x) schedEventLo(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ | #define schedTaskSelf(x) schedTask(TASK_ROOT((x)), TASK_FUNC((x)), TASK_ARG((x)), \ |
TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
TASK_VAL((x)), TASK_DATA((x)), TASK_DATLEN((x))) |
/* |
/* |
* schedSuspend() - Add Suspended task to scheduler queue |
* schedSuspend() - Add Suspended task to scheduler queue |