Update the rock-paper-scissors example in the tutorial, and rename some types in core::pipes

11 files changed, 19 insertions, 19 deletions

diff --git a/src/compiletest/procsrv.rs b/src/compiletest/procsrv.rs
index 312c48a2406..bd9f8f4385f 100644
--- a/src/compiletest/procsrv.rs
+++ b/src/compiletest/procsrv.rs
@@ -60,7 +60,7 @@ fn run(lib_path: ~str,
 
 
     writeclose(pipe_in.out, input);
-    let p = pipes::port_set();
+    let p = pipes::PortSet();
     let ch = p.chan();
     do task::spawn_sched(task::SingleThreaded) {
         let errput = readclose(pipe_err.in);
diff --git a/src/libcore/pipes.rs b/src/libcore/pipes.rs
index 62039e4c66f..c440660990c 100644
--- a/src/libcore/pipes.rs
+++ b/src/libcore/pipes.rs
@@ -93,7 +93,7 @@ export atomic_add_acq, atomic_sub_rel;
 export send_packet, recv_packet, send, recv, try_recv, peek;
 export select, select2, selecti, select2i, selectable;
 export spawn_service, spawn_service_recv;
-export stream, port, chan, shared_chan, port_set, channel;
+export stream, port, chan, SharedChan, PortSet, channel;
 export oneshot, chan_one, port_one;
 export recv_one, try_recv_one, send_one, try_send_one;
 
@@ -1020,8 +1020,8 @@ impl<T: send> port<T>: recv<T> {
     }
 }
 
-// Treat a whole bunch of ports as one.
-struct port_set<T: send> : recv<T> {
+/// Treat many ports as one.
+struct PortSet<T: send> : recv<T> {
     let mut ports: ~[pipes::port<T>];
 
     new() { self.ports = ~[]; }
@@ -1096,9 +1096,9 @@ impl<T: send> port<T>: selectable {
 }
 
 /// A channel that can be shared between many senders.
-type shared_chan<T: send> = unsafe::Exclusive<chan<T>>;
+type SharedChan<T: send> = unsafe::Exclusive<chan<T>>;
 
-impl<T: send> shared_chan<T>: channel<T> {
+impl<T: send> SharedChan<T>: channel<T> {
     fn send(+x: T) {
         let mut xx = some(x);
         do self.with |chan| {
@@ -1119,7 +1119,7 @@ impl<T: send> shared_chan<T>: channel<T> {
 }
 
 /// Converts a `chan` into a `shared_chan`.
-fn shared_chan<T:send>(+c: chan<T>) -> shared_chan<T> {
+fn SharedChan<T:send>(+c: chan<T>) -> SharedChan<T> {
     unsafe::exclusive(c)
 }
 
diff --git a/src/libstd/arc.rs b/src/libstd/arc.rs
index d6e59d6149f..51ee4a5178b 100644
--- a/src/libstd/arc.rs
+++ b/src/libstd/arc.rs
@@ -423,7 +423,7 @@ mod tests {
         let (c, p) = pipes::stream();
 
         do task::spawn() {
-            let p = pipes::port_set();
+            let p = pipes::PortSet();
             c.send(p.chan());
 
             let arc_v = p.recv();
diff --git a/src/test/bench/msgsend-pipes-shared.rs b/src/test/bench/msgsend-pipes-shared.rs
index 8b0eeb15cb3..26741f6298f 100644
--- a/src/test/bench/msgsend-pipes-shared.rs
+++ b/src/test/bench/msgsend-pipes-shared.rs
@@ -14,7 +14,7 @@ use std;
 import io::Writer;
 import io::WriterUtil;
 
-import pipes::{port, chan, shared_chan};
+import pipes::{port, chan, SharedChan};
 
 macro_rules! move_out {
     { $x:expr } => { unsafe { let y <- *ptr::addr_of($x); y } }
@@ -48,7 +48,7 @@ fn run(args: &[~str]) {
     let (to_parent, from_child) = pipes::stream();
     let (to_child, from_parent) = pipes::stream();
 
-    let to_child = shared_chan(to_child);
+    let to_child = SharedChan(to_child);
 
     let size = option::get(uint::from_str(args[1]));
     let workers = option::get(uint::from_str(args[2]));
diff --git a/src/test/bench/msgsend-pipes.rs b/src/test/bench/msgsend-pipes.rs
index 06b4213970b..fc041382721 100644
--- a/src/test/bench/msgsend-pipes.rs
+++ b/src/test/bench/msgsend-pipes.rs
@@ -10,7 +10,7 @@ use std;
 import io::Writer;
 import io::WriterUtil;
 
-import pipes::{port, port_set, chan};
+import pipes::{port, PortSet, chan};
 
 macro_rules! move_out {
     { $x:expr } => { unsafe { let y <- *ptr::addr_of($x); y } }
@@ -22,7 +22,7 @@ enum request {
     stop
 }
 
-fn server(requests: port_set<request>, responses: pipes::chan<uint>) {
+fn server(requests: PortSet<request>, responses: pipes::chan<uint>) {
     let mut count = 0u;
     let mut done = false;
     while !done {
@@ -43,7 +43,7 @@ fn server(requests: port_set<request>, responses: pipes::chan<uint>) {
 fn run(args: &[~str]) {
     let (to_parent, from_child) = pipes::stream();
     let (to_child, from_parent_) = pipes::stream();
-    let from_parent = port_set();
+    let from_parent = PortSet();
     from_parent.add(from_parent_);
 
     let size = option::get(uint::from_str(args[1]));
diff --git a/src/test/bench/shootout-pfib.rs b/src/test/bench/shootout-pfib.rs
index 7942392f2b8..225f3d98c0e 100644
--- a/src/test/bench/shootout-pfib.rs
+++ b/src/test/bench/shootout-pfib.rs
@@ -30,7 +30,7 @@ fn fib(n: int) -> int {
         } else if n <= 2 {
             c.send(1);
         } else {
-            let p = pipes::port_set();
+            let p = pipes::PortSet();
             let ch = p.chan();
             task::spawn(|| pfib(ch, n - 1) );
             let ch = p.chan();
diff --git a/src/test/run-pass/task-comm-14.rs b/src/test/run-pass/task-comm-14.rs
index 0e0bf640014..0b7e939ce31 100644
--- a/src/test/run-pass/task-comm-14.rs
+++ b/src/test/run-pass/task-comm-14.rs
@@ -1,7 +1,7 @@
 import task;
 
 fn main() {
-    let po = pipes::port_set();
+    let po = pipes::PortSet();
 
     // Spawn 10 tasks each sending us back one int.
     let mut i = 10;
diff --git a/src/test/run-pass/task-comm-3.rs b/src/test/run-pass/task-comm-3.rs
index a4296df8618..1c116787eaf 100644
--- a/src/test/run-pass/task-comm-3.rs
+++ b/src/test/run-pass/task-comm-3.rs
@@ -24,7 +24,7 @@ fn test00() {
 
     debug!{"Creating tasks"};
 
-    let po = pipes::port_set();
+    let po = pipes::PortSet();
 
     let mut i: int = 0;
 
diff --git a/src/test/run-pass/task-comm-6.rs b/src/test/run-pass/task-comm-6.rs
index 8bc93a78913..1be9fc34833 100644
--- a/src/test/run-pass/task-comm-6.rs
+++ b/src/test/run-pass/task-comm-6.rs
@@ -9,7 +9,7 @@ fn main() { test00(); }
 fn test00() {
     let mut r: int = 0;
     let mut sum: int = 0;
-    let p = pipes::port_set();
+    let p = pipes::PortSet();
     let c0 = p.chan();
     let c1 = p.chan();
     let c2 = p.chan();
diff --git a/src/test/run-pass/task-comm-7.rs b/src/test/run-pass/task-comm-7.rs
index 1df3de6ba1e..3963152257b 100644
--- a/src/test/run-pass/task-comm-7.rs
+++ b/src/test/run-pass/task-comm-7.rs
@@ -11,7 +11,7 @@ fn test00_start(c: pipes::chan<int>, start: int, number_of_messages: int) {
 fn test00() {
     let mut r: int = 0;
     let mut sum: int = 0;
-    let p = pipes::port_set();
+    let p = pipes::PortSet();
     let number_of_messages: int = 10;
 
     let c = p.chan();
diff --git a/src/test/run-pass/task-comm-9.rs b/src/test/run-pass/task-comm-9.rs
index fe0eea34642..4e864865a0b 100644
--- a/src/test/run-pass/task-comm-9.rs
+++ b/src/test/run-pass/task-comm-9.rs
@@ -11,7 +11,7 @@ fn test00_start(c: pipes::chan<int>, number_of_messages: int) {
 fn test00() {
     let r: int = 0;
     let mut sum: int = 0;
-    let p = pipes::port_set();
+    let p = pipes::PortSet();
     let number_of_messages: int = 10;
     let ch = p.chan();