diff options
| author | Scott Lawrence <bytbox@gmail.com> | 2014-01-26 22:42:26 -0500 |
|---|---|---|
| committer | Scott Lawrence <bytbox@gmail.com> | 2014-01-29 09:15:41 -0500 |
| commit | 25e7e7f8076d879f824f013faa6f7470e69c818b (patch) | |
| tree | 9acb92473ae0a0f1463901fe97e222e07da55b6b /src/libstd/io/net | |
| parent | af218d68e4b4916440ef2b4fc076a7bd8dead892 (diff) | |
| download | rust-25e7e7f8076d879f824f013faa6f7470e69c818b.tar.gz rust-25e7e7f8076d879f824f013faa6f7470e69c818b.zip | |
Removing do keyword from libstd and librustc
Diffstat (limited to 'src/libstd/io/net')
| -rw-r--r-- | src/libstd/io/net/tcp.rs | 100 | ||||
| -rw-r--r-- | src/libstd/io/net/udp.rs | 16 | ||||
| -rw-r--r-- | src/libstd/io/net/unix.rs | 8 |
3 files changed, 62 insertions, 62 deletions
diff --git a/src/libstd/io/net/tcp.rs b/src/libstd/io/net/tcp.rs index 92efc4e9306..2d074df4919 100644 --- a/src/libstd/io/net/tcp.rs +++ b/src/libstd/io/net/tcp.rs @@ -167,11 +167,11 @@ mod test { let addr = next_test_ip4(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let mut stream = TcpStream::connect(addr); stream.write([99]); - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -185,11 +185,11 @@ mod test { let addr = next_test_ip6(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let mut stream = TcpStream::connect(addr); stream.write([99]); - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -203,11 +203,11 @@ mod test { let addr = next_test_ip4(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -221,11 +221,11 @@ mod test { let addr = next_test_ip6(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -239,11 +239,11 @@ mod test { let addr = next_test_ip4(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -267,11 +267,11 @@ mod test { let addr = next_test_ip6(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -295,11 +295,11 @@ mod test { let addr = next_test_ip4(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -326,11 +326,11 @@ mod test { let addr = next_test_ip6(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let _stream = TcpStream::connect(addr); // Close - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -358,13 +358,13 @@ mod test { let max = 10; let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); max.times(|| { let mut stream = TcpStream::connect(addr); stream.write([99]); }); - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -380,13 +380,13 @@ mod test { let max = 10; let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); max.times(|| { let mut stream = TcpStream::connect(addr); stream.write([99]); }); - } + }); let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); @@ -402,20 +402,20 @@ mod test { static MAX: int = 10; let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); for (i, stream) in acceptor.incoming().enumerate().take(MAX as uint) { // Start another task to handle the connection - do spawn { + spawn(proc() { let mut stream = stream; let mut buf = [0]; stream.read(buf); assert!(buf[0] == i as u8); debug!("read"); - } + }); } - } + }); port.recv(); connect(0, addr); @@ -423,14 +423,14 @@ mod test { fn connect(i: int, addr: SocketAddr) { if i == MAX { return } - do spawn { + spawn(proc() { debug!("connecting"); let mut stream = TcpStream::connect(addr); // Connect again before writing connect(i + 1, addr); debug!("writing"); stream.write([i as u8]); - } + }); } }) @@ -439,20 +439,20 @@ mod test { static MAX: int = 10; let (port, chan) = Chan::<()>::new(); - do spawn { + spawn(proc() { let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); for (i, stream) in acceptor.incoming().enumerate().take(MAX as uint) { // Start another task to handle the connection - do spawn { + spawn(proc() { let mut stream = stream; let mut buf = [0]; stream.read(buf); assert!(buf[0] == i as u8); debug!("read"); - } + }); } - } + }); port.recv(); connect(0, addr); @@ -460,14 +460,14 @@ mod test { fn connect(i: int, addr: SocketAddr) { if i == MAX { return } - do spawn { + spawn(proc() { debug!("connecting"); let mut stream = TcpStream::connect(addr); // Connect again before writing connect(i + 1, addr); debug!("writing"); stream.write([i as u8]); - } + }); } }) @@ -476,20 +476,20 @@ mod test { static MAX: int = 10; let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); for stream in acceptor.incoming().take(MAX as uint) { // Start another task to handle the connection - do spawn { + spawn(proc() { let mut stream = stream; let mut buf = [0]; stream.read(buf); assert!(buf[0] == 99); debug!("read"); - } + }); } - } + }); port.recv(); connect(0, addr); @@ -497,14 +497,14 @@ mod test { fn connect(i: int, addr: SocketAddr) { if i == MAX { return } - do spawn { + spawn(proc() { debug!("connecting"); let mut stream = TcpStream::connect(addr); // Connect again before writing connect(i + 1, addr); debug!("writing"); stream.write([99]); - } + }); } }) @@ -513,20 +513,20 @@ mod test { static MAX: int = 10; let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); for stream in acceptor.incoming().take(MAX as uint) { // Start another task to handle the connection - do spawn { + spawn(proc() { let mut stream = stream; let mut buf = [0]; stream.read(buf); assert!(buf[0] == 99); debug!("read"); - } + }); } - } + }); port.recv(); connect(0, addr); @@ -534,14 +534,14 @@ mod test { fn connect(i: int, addr: SocketAddr) { if i == MAX { return } - do spawn { + spawn(proc() { debug!("connecting"); let mut stream = TcpStream::connect(addr); // Connect again before writing connect(i + 1, addr); debug!("writing"); stream.write([99]); - } + }); } }) @@ -558,11 +558,11 @@ mod test { pub fn peer_name(addr: SocketAddr) { let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { let mut acceptor = TcpListener::bind(addr).listen(); chan.send(()); acceptor.accept(); - } + }); port.recv(); let stream = TcpStream::connect(addr); @@ -592,7 +592,7 @@ mod test { iotest!(fn partial_read() { let addr = next_test_ip4(); let (p, c) = Chan::new(); - do spawn { + spawn(proc() { let mut srv = TcpListener::bind(addr).listen(); c.send(()); let mut cl = srv.accept().unwrap(); @@ -600,7 +600,7 @@ mod test { let mut b = [0]; cl.read(b); c.send(()); - } + }); p.recv(); let mut c = TcpStream::connect(addr).unwrap(); @@ -630,12 +630,12 @@ mod test { let addr = next_test_ip4(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); let stream = TcpStream::connect(addr); // Close port.recv(); - } + }); { let mut acceptor = TcpListener::bind(addr).listen(); diff --git a/src/libstd/io/net/udp.rs b/src/libstd/io/net/udp.rs index 952ca7f730e..1cf30d469f7 100644 --- a/src/libstd/io/net/udp.rs +++ b/src/libstd/io/net/udp.rs @@ -119,7 +119,7 @@ mod test { let (port, chan) = Chan::new(); let (port2, chan2) = Chan::new(); - do spawn { + spawn(proc() { match UdpSocket::bind(client_ip) { Some(ref mut client) => { port.recv(); @@ -128,7 +128,7 @@ mod test { None => fail!() } chan2.send(()); - } + }); match UdpSocket::bind(server_ip) { Some(ref mut server) => { @@ -153,7 +153,7 @@ mod test { let client_ip = next_test_ip6(); let (port, chan) = Chan::<()>::new(); - do spawn { + spawn(proc() { match UdpSocket::bind(client_ip) { Some(ref mut client) => { port.recv(); @@ -161,7 +161,7 @@ mod test { } None => fail!() } - } + }); match UdpSocket::bind(server_ip) { Some(ref mut server) => { @@ -186,7 +186,7 @@ mod test { let (port, chan) = Chan::new(); let (port2, chan2) = Chan::new(); - do spawn { + spawn(proc() { match UdpSocket::bind(client_ip) { Some(client) => { let client = ~client; @@ -197,7 +197,7 @@ mod test { None => fail!() } chan2.send(()); - } + }); match UdpSocket::bind(server_ip) { Some(server) => { @@ -224,7 +224,7 @@ mod test { let (port, chan) = Chan::new(); let (port2, chan2) = Chan::new(); - do spawn { + spawn(proc() { match UdpSocket::bind(client_ip) { Some(client) => { let client = ~client; @@ -235,7 +235,7 @@ mod test { None => fail!() } chan2.send(()); - } + }); match UdpSocket::bind(server_ip) { Some(server) => { diff --git a/src/libstd/io/net/unix.rs b/src/libstd/io/net/unix.rs index 232ca670597..dcf6d2ad203 100644 --- a/src/libstd/io/net/unix.rs +++ b/src/libstd/io/net/unix.rs @@ -147,10 +147,10 @@ mod tests { let path2 = path1.clone(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); client(UnixStream::connect(&path2).unwrap()); - } + }); let mut acceptor = UnixListener::bind(&path1).listen(); chan.send(()); @@ -232,13 +232,13 @@ mod tests { let path2 = path1.clone(); let (port, chan) = Chan::new(); - do spawn { + spawn(proc() { port.recv(); times.times(|| { let mut stream = UnixStream::connect(&path2); stream.write([100]); }) - } + }); let mut acceptor = UnixListener::bind(&path1).listen(); chan.send(()); |
