---

yaml
---
r: 6264
b: refs/heads/master
c: f619d5e
h: refs/heads/master
v: v3

Author: brson

[refs]

@@ -1,2 +1,2 @@
 ---
-refs/heads/master: 58e923de6ef89f252f350d0d89f7b13798b517bd
+refs/heads/master: f619d5e9e2461c1ef3fb53cbbff325cfb04fb181

trunk/src/rt/rust_port.cpp

@@ -22,8 +22,7 @@ rust_port::~rust_port() {
 }
 
 void rust_port::send(void *sptr) {
-    // FIXME: Is this lock really necessary? Why do we send with the lock
-    // but not receive with the lock?
+    I(task->sched, !lock.lock_held_by_current_thread());
     scoped_lock with(lock);
 
     buffer.enqueue(sptr);
@@ -40,6 +39,7 @@ void rust_port::send(void *sptr) {
 }
 
 bool rust_port::receive(void *dptr) {
+    I(task->sched, lock.lock_held_by_current_thread());
     if (buffer.is_empty() == false) {
         buffer.dequeue(dptr);
         LOG(task, comm, "<=== read data ===");
@@ -49,6 +49,7 @@ bool rust_port::receive(void *dptr) {
 }
 
 size_t rust_port::size() {
+    I(task->sched, !lock.lock_held_by_current_thread());
     scoped_lock with(lock);
     return buffer.size();
 }