---

yaml
---
r: 14151
b: refs/heads/try
c: d756b01
h: refs/heads/master
i:
  14149: ea2c821
  14147: 2163b32
  14143: f7dc0af
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: e0d5b92b84424b5b1dbd2dec7d32e92e1550832b
+refs/heads/try: d756b01619444bbbaa27d1f43ca4000c976c8bee
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105

branches/try/src/rt/rust_builtin.cpp

@@ -481,6 +481,16 @@ drop_task(rust_task *target) {
     }
 }
 
+extern "C" CDECL void
+rust_task_config_notify(rust_task_id task_id, chan_handle *chan) {
+    rust_task *task = rust_task_thread::get_task();
+    rust_task *target = task->kernel->get_task_by_id(task_id);
+    A(task->thread, target != NULL,
+      "This function should only be called when we know the task exists");
+    target->config_notify(*chan);
+    target->deref();
+}
+
 extern "C" CDECL rust_task *
 get_task_pointer(rust_task_id id) {
     rust_task *task = rust_task_thread::get_task();

branches/try/src/rt/rust_task.cpp

@@ -713,6 +713,12 @@ rust_task::check_stack_canary() {
     ::check_stack_canary(stk);
 }
 
+void
+rust_task::config_notify(chan_handle chan) {
+    user.notify_enabled = true;
+    user.notify_chan = chan;
+}
+
 //
 // Local Variables:
 // mode: C++

branches/try/src/rt/rust_task.h

@@ -181,6 +181,8 @@ rust_task : public kernel_owned<rust_task>, rust_cond
     void reset_stack_limit();
     bool on_rust_stack();
     void check_stack_canary();
+
+    void config_notify(chan_handle chan);
 };
 
 //

branches/try/src/rt/rustrt.def.in

@@ -49,6 +49,7 @@ rust_env_pairs
 rust_task_yield
 rust_task_is_unwinding
 rust_get_task
+rust_task_config_notify
 sched_threads
 shape_log_str
 squareroot