10 struct list_head pre_select_list;
11 struct list_head post_select_list;
13 static void sched_preselect(struct sched *s)
17 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
19 // PARA_INFO_LOG("%s \n", t->status);
22 if (!t->event_handler)
29 static void sched_post_select(struct sched *s)
33 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
35 // PARA_INFO_LOG("%s: %d\n", t->status, t->ret);
36 if (t->ret > 0 || !t->event_handler)
42 int sched(struct sched *s)
45 gettimeofday(&s->now, NULL);
49 s->timeout = s->default_timeout;
52 s->select_ret = para_select(s->max_fileno + 1, &s->rfds,
53 &s->wfds, &s->timeout);
54 if (s->select_ret < 0)
56 gettimeofday(&s->now, NULL);
58 if (list_empty(&pre_select_list) && list_empty(&post_select_list))
63 void *register_task(struct task *t)
65 PARA_INFO_LOG("registering %s (%p)\n", t->status, t);
67 PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select);
68 list_add(&t->pre_select_node, &pre_select_list);
71 PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
72 list_add(&t->post_select_node, &post_select_list);
77 void unregister_task(struct task *t)
79 PARA_INFO_LOG("unregistering %s (%p)\n", t->status, t);
81 list_del(&t->pre_select_node);
83 list_del(&t->post_select_node);
88 INIT_LIST_HEAD(&pre_select_list);
89 INIT_LIST_HEAD(&post_select_list);
92 void sched_shutdown(void)
96 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node)
98 /* remove tasks which do not have a pre_select hook */
99 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node)
103 char *get_task_list(void)
105 struct task *t, *tmp;
107 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
109 tmp_msg = make_message("%s%p\tpre\t%s\n", msg? msg : "", t, t->status);
113 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
115 // if (t->pre_select)
117 tmp_msg = make_message("%s%p\tpost\t%s\n", msg? msg : "", t, t->status);
121 //PARA_DEBUG_LOG("task list:\n%s", msg);
125 int kill_task(char *id)
127 struct task *t, *tmp;
129 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
130 sprintf(buf, "%p", t);
133 t->ret = -E_TASK_KILLED;
134 if (t->event_handler)
138 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
139 sprintf(buf, "%p", t);
142 t->ret = -E_TASK_KILLED;
143 if (t->event_handler)
147 return -E_NO_SUCH_TASK;