diff options
Diffstat (limited to 'src/rt/rust_task.cpp')
| -rw-r--r-- | src/rt/rust_task.cpp | 15 |
1 files changed, 0 insertions, 15 deletions
diff --git a/src/rt/rust_task.cpp b/src/rt/rust_task.cpp index 14a32ac2c63..19e9e1e14e1 100644 --- a/src/rt/rust_task.cpp +++ b/src/rt/rust_task.cpp @@ -197,7 +197,6 @@ void task_start_wrapper(spawn_args *a) #endif } else { task->lock.lock(); - task->notify_tasks_waiting_to_join(); task->lock.unlock(); task->yield(1); } @@ -324,7 +323,6 @@ rust_task::conclude_failure() { unblock(); fail_parent(); failed = true; - notify_tasks_waiting_to_join(); yield(4); } @@ -356,19 +354,6 @@ rust_task::unsupervise() propagate_failure = false; } -void -rust_task::notify_tasks_waiting_to_join() { - while (tasks_waiting_to_join.is_empty() == false) { - LOG(this, task, "notify_tasks_waiting_to_join: %d", - tasks_waiting_to_join.size()); - rust_task *waiting_task = 0; - tasks_waiting_to_join.pop(&waiting_task); - if (waiting_task->blocked() == true) { - waiting_task->wakeup(this); - } - } -} - frame_glue_fns* rust_task::get_frame_glue_fns(uintptr_t fp) { fp -= sizeof(uintptr_t); |
