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)
25 if (!(t->flags & PRE_EOF_IS_ERROR))
33 static void sched_post_select(struct sched *s)
37 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node) {
39 if (t->ret > 0 || !t->error_handler)
45 if (!(t->flags & POST_EOF_IS_ERROR))
52 int sched(struct sched *s)
55 gettimeofday(&s->now, NULL);
59 s->timeout = s->default_timeout;
62 s->select_ret = para_select(s->max_fileno + 1, &s->rfds,
63 &s->wfds, &s->timeout);
64 if (s->select_ret < 0)
66 gettimeofday(&s->now, NULL);
68 if (list_empty(&pre_select_list) && list_empty(&post_select_list))
73 void *register_task(struct task *t)
75 PARA_INFO_LOG("registering task %p\n", t);
77 PARA_DEBUG_LOG("pre_select: %p\n", &t->pre_select);
78 if (t->flags & PRE_ADD_TAIL)
79 list_add_tail(&t->pre_select_node, &pre_select_list);
81 list_add(&t->pre_select_node, &pre_select_list);
84 PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
85 if (t->flags & POST_ADD_TAIL)
86 list_add_tail(&t->post_select_node, &post_select_list);
88 list_add(&t->post_select_node, &post_select_list);
93 void unregister_task(struct task *t)
95 PARA_INFO_LOG("unregistering task %p\n", t);
97 list_del(&t->pre_select_node);
99 list_del(&t->post_select_node);
102 void init_sched(void)
104 INIT_LIST_HEAD(&pre_select_list);
105 INIT_LIST_HEAD(&post_select_list);
108 void sched_shutdown(void)
110 struct task *t, *tmp;
112 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node)
114 /* remove tasks which do not have a pre_select hook */
115 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node)
120 //char *get_tast_list();