version 1.1.1.1, 2011/08/05 15:52:00
|
version 1.1.1.1.2.4, 2011/08/13 17:28:17
|
Line 85 sched_SetErr(int eno, char *estr, ...)
|
Line 85 sched_SetErr(int eno, char *estr, ...)
|
/* Init and prepare scheduler functions */ |
/* Init and prepare scheduler functions */ |
|
|
/* |
/* |
|
* schedRegisterHooks() - Register IO handles and bind tasks to it |
|
* @root = root task |
|
* return: -1 error or 0 ok |
|
*/ |
|
int |
|
schedRegisterHooks(sched_root_task_t * __restrict root) |
|
{ |
|
if (!root || (root->root_data.iov_base && root->root_data.iov_len)) |
|
return -1; |
|
|
|
if (root->root_hooks.hook_root.fini) |
|
root->root_hooks.hook_root.fini(root, NULL); |
|
memset(&root->root_hooks, 0, sizeof root->root_hooks); |
|
|
|
root->root_hooks.hook_add.read = sched_hook_read; |
|
root->root_hooks.hook_add.write = sched_hook_write; |
|
|
|
root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
|
root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
|
|
|
root->root_hooks.hook_root.init = sched_hook_init; |
|
root->root_hooks.hook_root.fini = sched_hook_fini; |
|
return 0; |
|
} |
|
|
|
/* |
* schedInit() - Init scheduler |
* schedInit() - Init scheduler |
* @data = optional data if !=NULL |
* @data = optional data if !=NULL |
* @datlen = data len if data is set |
* @datlen = data len if data is set |
Line 97 schedInit(void ** __restrict data, size_t datlen)
|
Line 123 schedInit(void ** __restrict data, size_t datlen)
|
int (*func)(sched_root_task_t *); |
int (*func)(sched_root_task_t *); |
|
|
root = malloc(sizeof(sched_root_task_t)); |
root = malloc(sizeof(sched_root_task_t)); |
if (!root) | if (!root) { |
LOGERR | LOGERR; |
else { | } else { |
memset(root, 0, sizeof(sched_root_task_t)); |
memset(root, 0, sizeof(sched_root_task_t)); |
|
TAILQ_INIT(&root->root_read); |
|
TAILQ_INIT(&root->root_write); |
|
TAILQ_INIT(&root->root_timer); |
|
TAILQ_INIT(&root->root_event); |
|
TAILQ_INIT(&root->root_eventlo); |
|
TAILQ_INIT(&root->root_ready); |
|
TAILQ_INIT(&root->root_unuse); |
|
|
if (data && *data) { |
if (data && *data) { |
if (datlen) { |
if (datlen) { |
root->root_data.iov_base = *data; |
root->root_data.iov_base = *data; |
root->root_data.iov_len = datlen; |
root->root_data.iov_len = datlen; |
} else { |
} else { |
func = *data; | func = (int(*)(sched_root_task_t*)) data; |
func(root); |
func(root); |
} |
} |
} |
} |
|
|
|
if (root->root_hooks.hook_root.init) |
|
root->root_hooks.hook_root.init(root, NULL); |
} |
} |
|
|
if (root->root_hooks.hook_root.init) |
|
root->root_hooks.hook_root.init(root, NULL); |
|
return root; |
return root; |
} |
|
|
|
/* |
|
* schedRegisterIO() - Register IO handles and bind tasks to it |
|
* @root = root task |
|
* return: -1 error or 0 ok |
|
*/ |
|
int |
|
schedRegisterIO(sched_root_task_t * __restrict root) |
|
{ |
|
if (!root || (root->root_data.iov_base && root->root_data.iov_len)) |
|
return -1; |
|
|
|
if (root->root_hooks.hook_root.fini) |
|
root->root_hooks.hook_root.fini(root, NULL); |
|
memset(&root->root_hooks, 0, sizeof root->root_hooks); |
|
|
|
root->root_hooks.hook_add.read = sched_hook_read; |
|
root->root_hooks.hook_add.write = sched_hook_write; |
|
|
|
root->root_hooks.hook_exec.cancel = sched_hook_cancel; |
|
root->root_hooks.hook_exec.fetch = sched_hook_fetch; |
|
|
|
root->root_hooks.hook_root.init = sched_hook_init; |
|
root->root_hooks.hook_root.fini = sched_hook_fini; |
|
|
|
if (root->root_hooks.hook_root.init) |
|
root->root_hooks.hook_root.init(root, NULL); |
|
return 0; |
|
} |
} |
|
|
/* |
/* |