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 \n", t->status);
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 if (t->flags & PRE_ADD_TAIL)
69 list_add_tail(&t->pre_select_node, &pre_select_list);
71 list_add(&t->pre_select_node, &pre_select_list);
74 PARA_DEBUG_LOG("post_select: %p\n", &t->pre_select);
75 if (t->flags & POST_ADD_TAIL)
76 list_add_tail(&t->post_select_node, &post_select_list);
78 list_add(&t->post_select_node, &post_select_list);
83 void unregister_task(struct task *t)
85 PARA_INFO_LOG("unregistering %s (%p)\n", t->status, t);
87 list_del(&t->pre_select_node);
89 list_del(&t->post_select_node);
94 INIT_LIST_HEAD(&pre_select_list);
95 INIT_LIST_HEAD(&post_select_list);
98 void sched_shutdown(void)
100 struct task *t, *tmp;
102 list_for_each_entry_safe(t, tmp, &pre_select_list, pre_select_node)
104 /* remove tasks which do not have a pre_select hook */
105 list_for_each_entry_safe(t, tmp, &post_select_list, post_select_node)
110 //char *get_tast_list();