diff options
| author | toddaaro <github@opprobrio.us> | 2013-07-29 13:34:08 -0700 |
|---|---|---|
| committer | toddaaro <github@opprobrio.us> | 2013-08-01 15:17:19 -0700 |
| commit | a5f55b3ead06886190d905cfc826bf1d072ff675 (patch) | |
| tree | 53ad775357b36c7634033971067ef38be31ffa38 /src/libstd/rt/io | |
| parent | 997719c13d449821691fcae927d3b94960b5bc03 (diff) | |
minor tweaks - unboxed the coroutine so that it is no longer a ~ pointer inside the task struct, and also added an assert to verify that send is never called inside scheduler context as it is undefined (BROKEN) if that happens
Diffstat (limited to 'src/libstd/rt/io')
| -rw-r--r-- | src/libstd/rt/io/net/tcp.rs | 6 | ||||
| -rw-r--r-- | src/libstd/rt/io/net/udp.rs | 2 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/libstd/rt/io/net/tcp.rs b/src/libstd/rt/io/net/tcp.rs index edfd3a92b5f..449df8cddea 100644 --- a/src/libstd/rt/io/net/tcp.rs +++ b/src/libstd/rt/io/net/tcp.rs @@ -571,7 +571,7 @@ mod test { #[cfg(test)] fn socket_name(addr: IpAddr) { do run_in_newsched_task { - do spawntask_immediately { + do spawntask { let listener = TcpListener::bind(addr); assert!(listener.is_some()); @@ -590,13 +590,13 @@ mod test { #[cfg(test)] fn peer_name(addr: IpAddr) { do run_in_newsched_task { - do spawntask_immediately { + do spawntask { let mut listener = TcpListener::bind(addr); listener.accept(); } - do spawntask_immediately { + do spawntask { let stream = TcpStream::connect(addr); assert!(stream.is_some()); diff --git a/src/libstd/rt/io/net/udp.rs b/src/libstd/rt/io/net/udp.rs index 76200d6f86e..c04abfa899b 100644 --- a/src/libstd/rt/io/net/udp.rs +++ b/src/libstd/rt/io/net/udp.rs @@ -267,7 +267,7 @@ mod test { #[cfg(test)] fn socket_name(addr: IpAddr) { do run_in_newsched_task { - do spawntask_immediately { + do spawntask { let server = UdpSocket::bind(addr); assert!(server.is_some()); |
