Fallout from new termination semantics

Author: aturon

src/librustrt/local.rs

@@ -52,17 +52,15 @@ impl Local<local_ptr::Borrowed<Task>> for Task {
 
 #[cfg(test)]
 mod test {
-    extern crate rustrt;
-
     use std::prelude::*;
-    use rustrt::thread::Thread;
+    use thread::Thread;
     use super::*;
     use task::Task;
 
     #[test]
     fn thread_local_task_smoke_test() {
         Thread::start(proc() {
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
             let task: Box<Task> = Local::take();
             cleanup_task(task);
@@ -72,11 +70,11 @@ mod test {
     #[test]
     fn thread_local_task_two_instances() {
         Thread::start(proc() {
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
             let task: Box<Task> = Local::take();
             cleanup_task(task);
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
             let task: Box<Task> = Local::take();
             cleanup_task(task);
@@ -86,7 +84,7 @@ mod test {
     #[test]
     fn borrow_smoke_test() {
         Thread::start(proc() {
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
 
             unsafe {
@@ -100,7 +98,7 @@ mod test {
     #[test]
     fn borrow_with_return() {
         Thread::start(proc() {
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
 
             {
@@ -115,7 +113,7 @@ mod test {
     #[test]
     fn try_take() {
         Thread::start(proc() {
-            let task = box Task::new();
+            let task = box Task::new(None, None);
             Local::put(task);
 
             let t: Box<Task> = Local::try_take().unwrap();

src/librustrt/mutex.rs

@@ -649,13 +649,11 @@ mod imp {
 
 #[cfg(test)]
 mod test {
-    extern crate rustrt;
-
     use std::prelude::*;
 
     use std::mem::drop;
     use super::{StaticNativeMutex, NATIVE_MUTEX_INIT};
-    use rustrt::thread::Thread;
+    use thread::Thread;
 
     #[test]
     fn smoke_lock() {

src/librustrt/task.rs

@@ -544,11 +544,10 @@ impl Death {
 
 #[cfg(test)]
 mod test {
-    extern crate rustrt;
-
     use super::*;
     use std::prelude::*;
     use std::task;
+    use unwind;
 
     #[test]
     fn tls() {
@@ -594,20 +593,20 @@ mod test {
     #[test]
     #[should_fail]
     fn test_begin_unwind() {
-        use rustrt::unwind::begin_unwind;
+        use unwind::begin_unwind;
         begin_unwind("cause", &(file!(), line!()))
     }
 
     #[test]
     fn drop_new_task_ok() {
-        drop(Task::new());
+        drop(Task::new(None, None));
     }
 
     // Task blocking tests
 
     #[test]
     fn block_and_wake() {
-        let task = box Task::new();
+        let task = box Task::new(None, None);
         let task = BlockedTask::block(task).wake().unwrap();
         task.drop();
     }

src/test/run-pass/out-of-stack-new-thread-no-split.rs

@@ -36,9 +36,12 @@ fn main() {
     let args = os::args();
     let args = args.as_slice();
     if args.len() > 1 && args[1].as_slice() == "recurse" {
+        let (tx, rx) = channel();
         spawn(proc() {
             recurse();
+            tx.send(());
         });
+        rx.recv();
     } else {
         let recurse = Command::new(args[0].as_slice()).arg("recurse").output().unwrap();
         assert!(!recurse.status.success());

src/test/run-pass/process-spawn-with-unicode-params.rs

@@ -16,8 +16,6 @@
 // non-ASCII characters.  The child process ensures all the strings are
 // intact.
 
-extern crate native;
-
 use std::io;
 use std::io::fs;
 use std::io::Command;