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 if (t->ret > 0 || !t->error_handler)
26 static void sched_post_select(struct sched *s)
30 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
32 if (t->ret > 0 || !t->error_handler)
38 int sched(struct sched *s)
41 gettimeofday(&s->now, NULL);
45 s->timeout = s->default_timeout;
48 s->select_ret = para_select(s->max_fileno + 1, &s->rfds,
49 &s->wfds, &s->timeout);
50 if (s->select_ret < 0)
52 gettimeofday(&s->now, NULL);
54 if (list_empty(&pre_select_list) && list_empty(&post_select_list))
59 void *register_task(struct task *t)
61 PARA_INFO_LOG("registering %s (%p)\n", t->status, t);
63 PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select);
64 if (t->flags & PRE_ADD_TAIL)
65 list_add_tail(&t->pre_select_node, &pre_select_list);
67 list_add(&t->pre_select_node, &pre_select_list);
70 PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
71 if (t->flags & POST_ADD_TAIL)
72 list_add_tail(&t->post_select_node, &post_select_list);
74 list_add(&t->post_select_node, &post_select_list);
79 void unregister_task(struct task *t)
81 PARA_INFO_LOG("unregistering %s (%p)\n", t->status, t);
83 list_del(&t->pre_select_node);
85 list_del(&t->post_select_node);
90 INIT_LIST_HEAD(&pre_select_list);
91 INIT_LIST_HEAD(&post_select_list);
94 void sched_shutdown(void)
98 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node)
100 /* remove tasks which do not have a pre_select hook */
101 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node)
106 //char *get_tast_list();