diff options
| author | Nick Desaulniers <ndesaulniers@mozilla.com> | 2013-06-01 18:19:16 -0700 |
|---|---|---|
| committer | Nick Desaulniers <ndesaulniers@mozilla.com> | 2013-06-01 18:19:16 -0700 |
| commit | ecd08b989ae006660929bce6b719d9f7bc34a7fe (patch) | |
| tree | 73d8e00e2406a00c0a73efb4b4f0816d517f66e0 /src/libstd | |
| parent | 24e85ac82d000a71276eb4cf2090bd176a3638bf (diff) | |
| download | rust-ecd08b989ae006660929bce6b719d9f7bc34a7fe.tar.gz rust-ecd08b989ae006660929bce6b719d9f7bc34a7fe.zip | |
Swap return value of pipes::init Fixes #4501
Diffstat (limited to 'src/libstd')
| -rw-r--r-- | src/libstd/comm.rs | 12 | ||||
| -rw-r--r-- | src/libstd/pipes.rs | 8 |
2 files changed, 10 insertions, 10 deletions
diff --git a/src/libstd/comm.rs b/src/libstd/comm.rs index a376a715976..f0c353c8d62 100644 --- a/src/libstd/comm.rs +++ b/src/libstd/comm.rs @@ -376,7 +376,7 @@ mod pipesy { priv use core::kinds::Owned; use ptr::to_mut_unsafe_ptr; - pub fn init<T: Owned>() -> (client::Oneshot<T>, server::Oneshot<T>) { + pub fn init<T: Owned>() -> (server::Oneshot<T>, client::Oneshot<T>) { pub use core::pipes::HasBuffer; let buffer = ~::core::pipes::Buffer { @@ -466,7 +466,7 @@ mod pipesy { /// Initialiase a (send-endpoint, recv-endpoint) oneshot pipe pair. pub fn oneshot<T: Owned>() -> (PortOne<T>, ChanOne<T>) { - let (chan, port) = oneshot::init(); + let (port, chan) = oneshot::init(); (PortOne::new(port), ChanOne::new(chan)) } @@ -550,7 +550,7 @@ mod pipesy { pub mod streamp { priv use core::kinds::Owned; - pub fn init<T: Owned>() -> (client::Open<T>, server::Open<T>) { + pub fn init<T: Owned>() -> (server::Open<T>, client::Open<T>) { pub use core::pipes::HasBuffer; ::core::pipes::entangle() } @@ -567,7 +567,7 @@ mod pipesy { ::core::option::Option<Open<T>> { { use super::data; - let (c, s) = ::core::pipes::entangle(); + let (s, c) = ::core::pipes::entangle(); let message = data(x_0, s); if ::core::pipes::send(pipe, message) { ::core::pipes::rt::make_some(c) @@ -579,7 +579,7 @@ mod pipesy { pub fn data<T: Owned>(pipe: Open<T>, x_0: T) -> Open<T> { { use super::data; - let (c, s) = ::core::pipes::entangle(); + let (s, c) = ::core::pipes::entangle(); let message = data(x_0, s); ::core::pipes::send(pipe, message); c @@ -615,7 +615,7 @@ mod pipesy { */ pub fn stream<T:Owned>() -> (Port<T>, Chan<T>) { - let (c, s) = streamp::init(); + let (s, c) = streamp::init(); (Port { endp: Some(s) diff --git a/src/libstd/pipes.rs b/src/libstd/pipes.rs index 9607d395151..365e192da66 100644 --- a/src/libstd/pipes.rs +++ b/src/libstd/pipes.rs @@ -237,11 +237,11 @@ pub fn packet<T>() -> *mut Packet<T> { pub fn entangle_buffer<T:Owned,Tstart:Owned>( mut buffer: ~Buffer<T>, init: &fn(*libc::c_void, x: &mut T) -> *mut Packet<Tstart>) - -> (SendPacketBuffered<Tstart, T>, RecvPacketBuffered<Tstart, T>) { + -> (RecvPacketBuffered<Tstart, T>, SendPacketBuffered<Tstart, T>) { unsafe { let p = init(transmute_copy(&buffer), &mut buffer.data); forget(buffer); - (SendPacketBuffered(p), RecvPacketBuffered(p)) + (RecvPacketBuffered(p), SendPacketBuffered(p)) } } @@ -775,9 +775,9 @@ pub fn RecvPacketBuffered<T,Tbuffer>(p: *mut Packet<T>) } } -pub fn entangle<T>() -> (SendPacket<T>, RecvPacket<T>) { +pub fn entangle<T>() -> (RecvPacket<T>, SendPacket<T>) { let p = packet(); - (SendPacket(p), RecvPacket(p)) + (RecvPacket(p), SendPacket(p)) } /** Receives a message from one of two endpoints. |
