10 struct list_head pre_select_list;
11 struct list_head post_select_list;
13 static struct timeval now_struct;
14 struct timeval *now = &now_struct;
16 static void sched_preselect(struct sched *s)
20 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
22 // PARA_INFO_LOG("%s \n", t->status);
25 if (!t->event_handler)
32 static void sched_post_select(struct sched *s)
36 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
38 // PARA_INFO_LOG("%s: %d\n", t->status, t->ret);
39 if (t->ret > 0 || !t->event_handler)
45 int sched(struct sched *s)
48 gettimeofday(now, NULL);
52 s->timeout = s->default_timeout;
55 s->select_ret = para_select(s->max_fileno + 1, &s->rfds,
56 &s->wfds, &s->timeout);
57 if (s->select_ret < 0)
59 gettimeofday(now, NULL);
61 if (list_empty(&pre_select_list) && list_empty(&post_select_list))
66 void *register_task(struct task *t)
68 PARA_INFO_LOG("registering %s (%p)\n", t->status, t);
70 PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select);
71 list_add(&t->pre_select_node, &pre_select_list);
74 PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
75 list_add(&t->post_select_node, &post_select_list);
80 void unregister_task(struct task *t)
82 PARA_INFO_LOG("unregistering %s (%p)\n", t->status, t);
84 list_del(&t->pre_select_node);
86 list_del(&t->post_select_node);
91 INIT_LIST_HEAD(&pre_select_list);
92 INIT_LIST_HEAD(&post_select_list);
95 void sched_shutdown(void)
99 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node)
101 /* remove tasks which do not have a pre_select hook */
102 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node)
106 char *get_task_list(void)
108 struct task *t, *tmp;
110 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
112 tmp_msg = make_message("%s%p\tpre\t%s\n", msg? msg : "", t, t->status);
116 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
118 // if (t->pre_select)
120 tmp_msg = make_message("%s%p\tpost\t%s\n", msg? msg : "", t, t->status);
124 //PARA_DEBUG_LOG("task list:\n%s", msg);
128 int kill_task(char *id)
130 struct task *t, *tmp;
132 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node) {
133 sprintf(buf, "%p", t);
136 t->ret = -E_TASK_KILLED;
137 if (t->event_handler)
141 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
142 sprintf(buf, "%p", t);
145 t->ret = -E_TASK_KILLED;
146 if (t->event_handler)
150 return -E_NO_SUCH_TASK;