diff options
| author | Aaron Turon <aturon@mozilla.com> | 2014-12-06 18:34:37 -0800 |
|---|---|---|
| committer | Aaron Turon <aturon@mozilla.com> | 2014-12-18 23:31:51 -0800 |
| commit | 43ae4b3301cc0605839778ecf59effb32b752e33 (patch) | |
| tree | aa111f5adc1eaa1e996847e1437d1b1b40821ce0 /src/libtest | |
| parent | 14c1a103bc3f78721df1dc860a75a477c8275e3a (diff) | |
| download | rust-43ae4b3301cc0605839778ecf59effb32b752e33.tar.gz rust-43ae4b3301cc0605839778ecf59effb32b752e33.zip | |
Fallout from new thread API
Diffstat (limited to 'src/libtest')
| -rw-r--r-- | src/libtest/lib.rs | 17 |
1 files changed, 8 insertions, 9 deletions
diff --git a/src/libtest/lib.rs b/src/libtest/lib.rs index d786409e895..044a4a173c6 100644 --- a/src/libtest/lib.rs +++ b/src/libtest/lib.rs @@ -69,7 +69,7 @@ use std::num::{Float, FloatMath, Int}; use std::os; use std::str::FromStr; use std::string::String; -use std::task::TaskBuilder; +use std::thread::{mod, Thread}; use std::time::Duration; use std::thunk::{Thunk, Invoke}; @@ -1121,28 +1121,27 @@ pub fn run_test(opts: &TestOpts, monitor_ch: Sender<MonitorMsg>, nocapture: bool, testfn: Thunk) { - spawn(move || { + Thread::spawn(move || { let (tx, rx) = channel(); let mut reader = ChanReader::new(rx); let stdout = ChanWriter::new(tx.clone()); let stderr = ChanWriter::new(tx); - let mut task = TaskBuilder::new().named(match desc.name { + let mut cfg = thread::cfg().name(match desc.name { DynTestName(ref name) => name.clone().to_string(), StaticTestName(name) => name.to_string(), }); if nocapture { drop((stdout, stderr)); } else { - task = task.stdout(box stdout as Box<Writer + Send>); - task = task.stderr(box stderr as Box<Writer + Send>); + cfg = cfg.stdout(box stdout as Box<Writer + Send>); + cfg = cfg.stderr(box stderr as Box<Writer + Send>); } - let result_future = task.try_future(move || testfn.invoke(())); + let result_guard = cfg.with_join(testfn); let stdout = reader.read_to_end().unwrap().into_iter().collect(); - let task_result = result_future.into_inner(); - let test_result = calc_result(&desc, task_result); + let test_result = calc_result(&desc, result_guard.join()); monitor_ch.send((desc.clone(), test_result, stdout)); - }) + }); } match testfn { |
