---

yaml
---
r: 39799
b: refs/heads/incoming
c: 1b1700f
h: refs/heads/master
i:
  39797: 8691448
  39795: 2c5cc63
  39791: 52ef08f
v: v3

Author: brson

[refs]

@@ -6,7 +6,7 @@ refs/heads/try: 3d5418789064fdb463e872a4e651af1c628a3650
 refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
 refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b
 refs/heads/try2: a810c03263670238bccd64cabb12a23a46e3a278
-refs/heads/incoming: 4c441e95d69909265e69cffd3439f890914e02b3
+refs/heads/incoming: 1b1700f44b88225bc3557e1ca497644b9852e268
 refs/heads/dist-snap: 22efa39382d41b084fde1719df7ae8ce5697d8c9
 refs/tags/release-0.2: c870d2dffb391e14efb05aa27898f1f6333a9596
 refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503

branches/incoming/src/libcore/private.rs

@@ -37,6 +37,9 @@ extern mod rustrt {
     unsafe fn rust_destroy_little_lock(lock: rust_little_lock);
     unsafe fn rust_lock_little_lock(lock: rust_little_lock);
     unsafe fn rust_unlock_little_lock(lock: rust_little_lock);
+
+    unsafe fn rust_raw_thread_start(f: &fn()) -> *raw_thread;
+    unsafe fn rust_raw_thread_join_delete(thread: *raw_thread);
 }
 
 #[abi = "rust-intrinsic"]
@@ -46,6 +49,37 @@ extern mod rusti {
     fn atomic_xsub(dst: &mut int, src: int) -> int;
 }
 
+#[allow(non_camel_case_types)] // runtime type
+type raw_thread = libc::c_void;
+
+/**
+Start a new thread outside of the current runtime context and wait for it to terminate.
+
+The executing thread has no access to a task pointer and will be using a normal large stack.
+*/
+pub unsafe fn run_in_bare_thread(f: ~fn()) {
+    let (port, chan) = pipes::stream();
+    // XXX Unfortunate that this creates an extra scheduler but it's necessary
+    // since rust_raw_thread_join_delete is blocking
+    do task::spawn_sched(task::SingleThreaded) unsafe {
+        let closure: &fn() = || {
+            f()
+        };
+        let thread = rustrt::rust_raw_thread_start(closure);
+        rustrt::rust_raw_thread_join_delete(thread);
+        chan.send(());
+    }
+    port.recv();
+}
+
+#[test]
+fn test_run_in_bare_thread() unsafe {
+    let i = 100;
+    do run_in_bare_thread {
+        assert i == 100;
+    }
+}
+
 #[allow(non_camel_case_types)] // runtime type
 type rust_port_id = uint;
 

branches/incoming/src/rt/rust_builtin.cpp

@@ -15,6 +15,7 @@
 #include "rust_util.h"
 #include "rust_scheduler.h"
 #include "sync/timer.h"
+#include "sync/rust_thread.h"
 #include "rust_abi.h"
 #include "rust_port.h"
 
@@ -972,6 +973,36 @@ rust_log_str(uint32_t level, const char *str, size_t size) {
     task->sched_loop->get_log().log(task, level, "%.*s", (int)size, str);
 }
 
+extern "C" CDECL void      record_sp_limit(void *limit);
+
+class raw_thread: public rust_thread {
+public:
+    fn_env_pair *fn;
+
+    raw_thread(fn_env_pair *fn) : fn(fn) { }
+
+    virtual void run() {
+        record_sp_limit(0);
+        fn->f(NULL, fn->env, NULL);
+    }
+};
+
+extern "C" raw_thread*
+rust_raw_thread_start(fn_env_pair *fn) {
+    assert(fn);
+    raw_thread *thread = new raw_thread(fn);
+    thread->start();
+    return thread;
+}
+
+extern "C" void
+rust_raw_thread_join_delete(raw_thread *thread) {
+    assert(thread);
+    thread->join();
+    delete thread;
+}
+
+
 //
 // Local Variables:
 // mode: C++

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

@@ -208,3 +208,5 @@ linenoiseHistoryAdd
 linenoiseHistorySetMaxLen
 linenoiseHistorySave
 linenoiseHistoryLoad
+rust_raw_thread_start
+rust_raw_thread_join_delete