---

yaml
---
r: 10989
b: refs/heads/master
c: 5c3c8d4
h: refs/heads/master
i:
  10987: 5eb2881
v: v3

Author: brson

[refs]

@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 5449b886d34c1ddbba60986d56d6896543a6b87f
+refs/heads/master: 5c3c8d454d58b3bb4a79d36b76582f1f7761bc75
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
 refs/heads/try: 2898dcc5d97da9427ac367542382b6239d9c0bbf

trunk/src/rt/rust_kernel.cpp

@@ -191,7 +191,9 @@ rust_kernel::release_task_id(rust_task_id id) {
 
 void rust_kernel::wakeup_schedulers() {
     for(size_t i = 0; i < num_threads; ++i) {
-        threads[i]->lock.signal_all();
+        rust_scheduler *sched = threads[i];
+        scoped_lock with(sched->lock);
+        sched->lock.signal_all();
     }
 }
 

trunk/src/rt/rust_task.cpp

@@ -394,7 +394,6 @@ rust_task::start(spawn_fn spawnee_fn,
 void rust_task::start()
 {
     transition(&sched->newborn_tasks, &sched->running_tasks);
-    sched->lock.signal();
 }
 
 // Only run this on the rust stack
@@ -429,8 +428,6 @@ rust_task::kill() {
     // Unblock the task so it can unwind.
     unblock();
 
-    sched->lock.signal();
-
     LOG(this, task, "preparing to unwind task: 0x%" PRIxPTR, this);
     // run_on_resume(rust_unwind_glue);
 }
@@ -551,6 +548,7 @@ rust_task::transition(rust_task_list *src, rust_task_list *dst) {
     src->remove(this);
     dst->append(this);
     state = dst;
+    sched->lock.signal();
     if(unlock)
         sched->lock.unlock();
 }
@@ -578,20 +576,16 @@ rust_task::wakeup(rust_cond *from) {
                         (uintptr_t) cond, (uintptr_t) from);
     A(sched, cond == from, "Cannot wake up blocked task on wrong condition.");
 
-    transition(&sched->blocked_tasks, &sched->running_tasks);
-    I(sched, cond == from);
     cond = NULL;
     cond_name = "none";
-
-    sched->lock.signal();
+    transition(&sched->blocked_tasks, &sched->running_tasks);
 }
 
 void
 rust_task::die() {
     I(sched, !lock.lock_held_by_current_thread());
     scoped_lock with(lock);
     transition(&sched->running_tasks, &sched->dead_tasks);
-    sched->lock.signal();
 }
 
 void