---

yaml
---
r: 23178
b: refs/heads/master
c: 2ac2883
h: refs/heads/master
v: v3

Author: bblum

[refs]

@@ -1,5 +1,5 @@
 ---
-refs/heads/master: 4ec1dd991405404725b5cc448295dc0be9cd17e5
+refs/heads/master: 2ac288383d22e8c4a18561293cfddd64a48e7b38
 refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
 refs/heads/snap-stage3: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
 refs/heads/try: ffbe0e0e00374358b789b0037bcb3a577cd218be

trunk/src/libcore/pipes.rs

@@ -1144,16 +1144,22 @@ proto! oneshot {
     }
 }
 
-/// Receive a message from a oneshot pipe.
+/// Initialiase a (send-endpoint, recv-endpoint) oneshot pipe pair.
+fn oneshot<T: send>() -> (oneshot::client::oneshot<T>,
+                          oneshot::server::oneshot<T>) {
+    oneshot::init()
+}
+
+/**
+ * Receive a message from a oneshot pipe, failing if the connection was
+ * closed.
+ */
 fn recv_one<T: send>(+port: oneshot::server::oneshot<T>) -> T {
     let oneshot::send(message) = recv(port);
     message
 }
 
-/** Receive a message from a oneshot pipe, or fail if the connection
-is closed.
-
-*/
+/// Receive a message from a oneshot pipe unless the connection was closed.
 fn try_recv_one<T: send> (+port: oneshot::server::oneshot<T>) -> option<T> {
     let message = try_recv(port);
 
@@ -1164,6 +1170,20 @@ fn try_recv_one<T: send> (+port: oneshot::server::oneshot<T>) -> option<T> {
     }
 }
 
+/// Send a message on a oneshot pipe, failing if the connection was closed.
+fn send_one<T: send>(+chan: oneshot::client::oneshot<T>, +data: T) {
+    oneshot::client::send(chan, data);
+}
+
+/**
+ * Send a message on a oneshot pipe, or return false if the connection was
+ * closed.
+ */
+fn try_send_one<T: send>(+chan: oneshot::client::oneshot<T>, +data: T)
+        -> bool {
+    oneshot::client::try_send(chan, data).is_some()
+}
+
 #[cfg(test)]
 mod test {
     #[test]