about summary refs log tree commit diff
path: root/src/test/stdtest
diff options
context:
space:
mode:
authorEric Holk <eholk@mozilla.com>2011-08-25 11:20:43 -0700
committerEric Holk <eholk@mozilla.com>2011-08-25 11:21:25 -0700
commit2f7c583bc12c0bddb28e43ea79b593a014811b09 (patch)
treedff43b4686d290723f689b6605449fabf19b3622 /src/test/stdtest
parentb31815f8a0b98445d2a82888a290b9543ad4400f (diff)
downloadrust-2f7c583bc12c0bddb28e43ea79b593a014811b09.tar.gz
rust-2f7c583bc12c0bddb28e43ea79b593a014811b09.zip
Cleaning up task and comm exports, updating all the test cases.
Diffstat (limited to 'src/test/stdtest')
-rw-r--r--src/test/stdtest/comm.rs15
-rw-r--r--src/test/stdtest/task.rs34
2 files changed, 11 insertions, 38 deletions
diff --git a/src/test/stdtest/comm.rs b/src/test/stdtest/comm.rs
index 744b6f2d293..1fafd1a0375 100644
--- a/src/test/stdtest/comm.rs
+++ b/src/test/stdtest/comm.rs
@@ -3,19 +3,8 @@ import std::comm;
 
 #[test]
 fn create_port_and_chan() {
-    let p = comm::mk_port::<int>();
-    p.mk_chan();
-}
-
-#[test]
-fn send_recv() {
-    let p = comm::mk_port::<int>();
-    let c = p.mk_chan();
-
-    comm::send(c, 42);
-    let v = p.recv();
-    log_err v;
-    assert (42 == v);
+    let p = comm::port::<int>();
+    comm::chan(p);
 }
 
 #[test]
diff --git a/src/test/stdtest/task.rs b/src/test/stdtest/task.rs
index d30d6addd0b..c9fb71f8794 100644
--- a/src/test/stdtest/task.rs
+++ b/src/test/stdtest/task.rs
@@ -9,46 +9,30 @@ fn test_sleep() { task::sleep(1000000u); }
 fn test_unsupervise() {
     fn f() { task::unsupervise(); fail; }
     let foo = f;
-    task::_spawn(foo);
-}
-
-#[test]
-#[ignore]
-fn test_join() {
-    fn winner() { }
-
-    let wintask = task::_spawn(bind winner());
-
-    assert (task::join_id(wintask) == task::tr_success);
-
-    fn failer() { task::unsupervise(); fail; }
-
-    let failtask = task::_spawn(bind failer());
-
-    assert (task::join_id(failtask) == task::tr_failure);
+    task::spawn(foo);
 }
 
 #[test]
 fn test_lib_spawn() {
     fn foo() { log_err "Hello, World!"; }
     let f = foo;
-    task::_spawn(f);
+    task::spawn(f);
 }
 
 #[test]
 fn test_lib_spawn2() {
     fn foo(x: int) { assert (x == 42); }
-    task::_spawn(bind foo(42));
+    task::spawn(bind foo(42));
 }
 
 #[test]
 fn test_join_chan() {
     fn winner() { }
 
-    let p = comm::mk_port::<task::task_notification>();
+    let p = comm::port();
     let f = winner;
-    task::spawn_notify(f, p.mk_chan());
-    let s = p.recv();
+    task::spawn_notify(f, comm::chan(p));
+    let s = comm::recv(p);
     log_err "received task status message";
     log_err s;
     alt s {
@@ -61,10 +45,10 @@ fn test_join_chan() {
 fn test_join_chan_fail() {
     fn failer() { task::unsupervise(); fail }
 
-    let p = comm::mk_port::<task::task_notification>();
+    let p = comm::port();
     let f = failer;
-    task::spawn_notify(f, p.mk_chan());
-    let s = p.recv();
+    task::spawn_notify(f, comm::chan(p));
+    let s = comm::recv(p);
     log_err "received task status message";
     log_err s;
     alt s {