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();