diff options
| author | bors <bors@rust-lang.org> | 2013-06-01 22:37:35 -0700 |
|---|---|---|
| committer | bors <bors@rust-lang.org> | 2013-06-01 22:37:35 -0700 |
| commit | c354a0c7eb22f7a4bc1c7adf8e2ed34ee96428aa (patch) | |
| tree | 675d25a764043bfaff2360da96bfdf4d5e005bb5 /src/libstd | |
| parent | 14c331053ea9d2661cfd9c81351f4b3815cf5e3d (diff) | |
| parent | ecd08b989ae006660929bce6b719d9f7bc34a7fe (diff) | |
| download | rust-c354a0c7eb22f7a4bc1c7adf8e2ed34ee96428aa.tar.gz rust-c354a0c7eb22f7a4bc1c7adf8e2ed34ee96428aa.zip | |
auto merge of #6896 : nickdesaulniers/rust/issue4501, r=brson
review? @brson
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. |
