@@ -112,7 +112,7 @@ rust_scheduler::number_of_live_tasks() {
112
112
* Delete any dead tasks.
113
113
*/
114
114
void
115
- rust_scheduler::reap_dead_tasks (int id ) {
115
+ rust_scheduler::reap_dead_tasks () {
116
116
I (this , lock.lock_held_by_current_thread ());
117
117
if (dead_tasks.length () == 0 ) {
118
118
return ;
@@ -157,7 +157,7 @@ rust_scheduler::reap_dead_tasks(int id) {
157
157
* Returns NULL if no tasks can be scheduled.
158
158
*/
159
159
rust_task *
160
- rust_scheduler::schedule_task (int id ) {
160
+ rust_scheduler::schedule_task () {
161
161
I (this , this );
162
162
// FIXME: in the face of failing tasks, this is not always right.
163
163
// I(this, n_live_tasks() > 0);
@@ -222,15 +222,15 @@ rust_scheduler::start_main_loop() {
222
222
DLOG (this , dom, " worker %d, number_of_live_tasks = %d, total = %d" ,
223
223
id, number_of_live_tasks (), kernel->live_tasks );
224
224
225
- rust_task *scheduled_task = schedule_task (id );
225
+ rust_task *scheduled_task = schedule_task ();
226
226
227
227
if (scheduled_task == NULL ) {
228
228
log_state ();
229
229
DLOG (this , task,
230
230
" all tasks are blocked, scheduler id %d yielding ..." ,
231
231
id);
232
232
lock.timed_wait (10 );
233
- reap_dead_tasks (id );
233
+ reap_dead_tasks ();
234
234
DLOG (this , task,
235
235
" scheduler %d resuming ..." , id);
236
236
continue ;
@@ -263,7 +263,7 @@ rust_scheduler::start_main_loop() {
263
263
scheduled_task->user .rust_sp ,
264
264
id);
265
265
266
- reap_dead_tasks (id );
266
+ reap_dead_tasks ();
267
267
}
268
268
269
269
A (this , newborn_tasks.is_empty (), " Should have no newborn tasks" );
0 commit comments