user0/rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

core: Add new weak task API

Browse source
This commit is contained in:
Brian Anderson 2013-01-15 19:53:35 -08:00
parent 1bf8e57943
commit 8852279a9e
7 changed files with 233 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/rt/rust_kernel.cpp
View file

@ -377,17 +377,12 @@ rust_kernel::weaken_task(rust_port_id chan) {
KLOG_("Weakening task with channel %" PRIdPTR, chan);
weak_task_chans.push_back(chan);
}
uintptr_t new_non_weak_tasks = sync::decrement(non_weak_tasks);
KLOG_("New non-weak tasks %" PRIdPTR, new_non_weak_tasks);
if (new_non_weak_tasks == 0) {
begin_shutdown();
}
inc_weak_task_count();
}
void
rust_kernel::unweaken_task(rust_port_id chan) {
uintptr_t new_non_weak_tasks = sync::increment(non_weak_tasks);
KLOG_("New non-weak tasks %" PRIdPTR, new_non_weak_tasks);
dec_weak_task_count();
{
scoped_lock with(weak_task_lock);
KLOG_("Unweakening task with channel %" PRIdPTR, chan);
@ -399,6 +394,21 @@ rust_kernel::unweaken_task(rust_port_id chan) {
}
}
void
rust_kernel::inc_weak_task_count() {
uintptr_t new_non_weak_tasks = sync::decrement(non_weak_tasks);
KLOG_("New non-weak tasks %" PRIdPTR, new_non_weak_tasks);
if (new_non_weak_tasks == 0) {
begin_shutdown();
}
}
void
rust_kernel::dec_weak_task_count() {
uintptr_t new_non_weak_tasks = sync::increment(non_weak_tasks);
KLOG_("New non-weak tasks %" PRIdPTR, new_non_weak_tasks);
}
void
rust_kernel::end_weak_tasks() {
std::vector<rust_port_id> chancopies;