---

yaml
---
r: 15253
b: refs/heads/try
c: 2d8ef73
h: refs/heads/master
i:
  15251: a45a141
v: v3

Author: brson

[refs]

@@ -2,5 +2,5 @@
 refs/heads/master: 61b1875c16de39c166b0f4d54bba19f9c6777d1a
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: 4a81779abd786ff22d71434c6d9a5917ea4cdfff
-refs/heads/try: c8dc6fcb4cd29e5fb6c509149871b869b951295d
+refs/heads/try: 2d8ef7387e737ce1d8ea6f6b9a75626529fff234
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/src/rt/rust_sched_loop.cpp

@@ -44,6 +44,7 @@ rust_sched_loop::rust_sched_loop(rust_scheduler *sched,
 
 void
 rust_sched_loop::activate(rust_task *task) {
+    lock.must_have_lock();
     task->ctx.next = &c_context;
     DLOG(this, task, "descheduling...");
     lock.unlock();
@@ -147,6 +148,7 @@ rust_sched_loop::release_task(rust_task *task) {
  */
 rust_task *
 rust_sched_loop::schedule_task() {
+    lock.must_have_lock();
     I(this, this);
     // FIXME: in the face of failing tasks, this is not always right.
     // I(this, n_live_tasks() > 0);