File tree 1 file changed +3
-6
lines changed
1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -100,6 +100,7 @@ rust_sched_loop::kill_all_tasks() {
100
100
101
101
size_t
102
102
rust_sched_loop::number_of_live_tasks () {
103
+ lock.must_have_lock ();
103
104
return running_tasks.length () + blocked_tasks.length ();
104
105
}
105
106
@@ -148,14 +149,10 @@ rust_sched_loop::release_task(rust_task *task) {
148
149
rust_task *
149
150
rust_sched_loop::schedule_task () {
150
151
lock.must_have_lock ();
151
- assert (this );
152
152
if (running_tasks.length () > 0 ) {
153
153
size_t k = isaac_rand (&rctx);
154
- // Look around for a runnable task, starting at k.
155
- for (size_t j = 0 ; j < running_tasks.length (); ++j) {
156
- size_t i = (j + k) % running_tasks.length ();
157
- return (rust_task *)running_tasks[i];
158
- }
154
+ size_t i = k % running_tasks.length ();
155
+ return (rust_task *)running_tasks[i];
159
156
}
160
157
return NULL ;
161
158
}
You can’t perform that action at this time.
0 commit comments