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: %d\n", t->status, t->ret);
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 list_add(&t
->pre_select_node
, &pre_select_list
);
71 PARA_DEBUG_LOG("post_select: %p\n", &t
->pre_select
);
72 list_add(&t
->post_select_node
, &post_select_list
);
77 void unregister_task(struct task
*t
)
79 PARA_INFO_LOG("unregistering %s (%p)\n", t
->status
, t
);
81 list_del(&t
->pre_select_node
);
83 list_del(&t
->post_select_node
);
88 INIT_LIST_HEAD(&pre_select_list
);
89 INIT_LIST_HEAD(&post_select_list
);
92 void sched_shutdown(void)
96 list_for_each_entry_safe(t
, tmp
, &pre_select_list
, pre_select_node
)
98 /* remove tasks which do not have a pre_select hook */
99 list_for_each_entry_safe(t
, tmp
, &post_select_list
, post_select_node
)
103 char *get_task_list(void)
105 struct task
*t
, *tmp
;
107 list_for_each_entry_safe(t
, tmp
, &pre_select_list
, pre_select_node
) {
109 tmp_msg
= make_message("%s%p\tpre\t%s\n", msg
? msg
: "", t
, t
->status
);
113 list_for_each_entry_safe(t
, tmp
, &post_select_list
, post_select_node
) {
115 // if (t->pre_select)
117 tmp_msg
= make_message("%s%p\tpost\t%s\n", msg
? msg
: "", t
, t
->status
);
121 //PARA_DEBUG_LOG("task list:\n%s", msg);
125 int kill_task(char *id
)
127 struct task
*t
, *tmp
;
129 list_for_each_entry_safe(t
, tmp
, &pre_select_list
, pre_select_node
) {
130 sprintf(buf
, "%p", t
);
133 t
->ret
= -E_TASK_KILLED
;
134 if (t
->event_handler
)
138 list_for_each_entry_safe(t
, tmp
, &post_select_list
, post_select_node
) {
139 sprintf(buf
, "%p", t
);
142 t
->ret
= -E_TASK_KILLED
;
143 if (t
->event_handler
)
147 return -E_NO_SUCH_TASK
;