Add support for non-unix and non-windows platforms

src/lib.rs

@@ -254,13 +254,16 @@ impl Client {
     /// On Unix and Windows this will clobber the `CARGO_MAKEFLAGS` environment
     /// variables for the child process, and on Unix this will also allow the
     /// two file descriptors for this client to be inherited to the child.
+    ///
+    /// On platforms other than Unix and Windows this does nothing.
     pub fn configure(&self, cmd: &mut Command) {
-        let arg = self.inner.string_arg();
-        // Older implementations of make use `--jobserver-fds` and newer
-        // implementations use `--jobserver-auth`, pass both to try to catch
-        // both implementations.
-        let value = format!("--jobserver-fds={0} --jobserver-auth={0}", arg);
-        cmd.env("CARGO_MAKEFLAGS", &value);
+        if let Some(arg) = self.inner.string_arg() {
+            // Older implementations of make use `--jobserver-fds` and newer
+            // implementations use `--jobserver-auth`, pass both to try to catch
+            // both implementations.
+            let value = format!("--jobserver-fds={0} --jobserver-auth={0}", arg);
+            cmd.env("CARGO_MAKEFLAGS", &value);
+        }
         self.inner.configure(cmd);
     }
 
@@ -573,8 +576,8 @@ mod imp {
             }
         }
 
-        pub fn string_arg(&self) -> String {
-            format!("{},{} -j", self.read.as_raw_fd(), self.write.as_raw_fd())
+        pub fn string_arg(&self) -> Option<String> {
+            Some(format!("{},{} -j", self.read.as_raw_fd(), self.write.as_raw_fd()))
         }
 
         pub fn configure(&self, cmd: &mut Command) {
@@ -881,8 +884,8 @@ mod imp {
             }
         }
 
-        pub fn string_arg(&self) -> String {
-            self.name.clone()
+        pub fn string_arg(&self) -> Option<String> {
+            Some(self.name.clone())
         }
 
         pub fn configure(&self, _cmd: &mut Command) {
@@ -961,3 +964,121 @@ mod imp {
         }
     }
 }
+
+#[cfg(not(any(unix, windows)))]
+mod imp {
+    use std::io;
+    use std::sync::{Arc, Mutex};
+    use std::sync::atomic::{AtomicBool, Ordering};
+    use std::sync::mpsc::{self, SyncSender, Receiver, RecvTimeoutError};
+    use std::thread::{self, Builder, JoinHandle};
+    use std::time::Duration;
+    use std::process::Command;
+
+    #[derive(Debug)]
+    pub struct Client {
+        tx: SyncSender<()>,
+        rx: Mutex<Receiver<()>>,
+    }
+
+    #[derive(Debug)]
+    pub struct Acquired(());
+
+    impl Client {
+        pub fn new(limit: usize) -> io::Result<Client> {
+            let (tx, rx) = mpsc::sync_channel(limit);
+            for _ in 0..limit {
+                tx.send(()).unwrap();
+            }
+            Ok(Client {
+                tx,
+                rx: Mutex::new(rx),
+            })
+        }
+
+        pub unsafe fn open(_s: &str) -> Option<Client> {
+            None
+        }
+
+        pub fn acquire(&self) -> io::Result<Acquired> {
+            self.rx.lock().unwrap().recv().unwrap();
+            Ok(Acquired(()))
+        }
+
+        pub fn release(&self, _data: Option<&Acquired>) -> io::Result<()> {
+            self.tx.send(()).unwrap();
+            Ok(())
+        }
+
+        pub fn string_arg(&self) -> Option<String> {
+            None
+        }
+
+        pub fn configure(&self, _cmd: &mut Command) {}
+    }
+
+    #[derive(Debug)]
+    pub struct Helper {
+        thread: JoinHandle<()>,
+        quitting: Arc<AtomicBool>,
+        rx_done: Receiver<()>,
+    }
+
+    pub fn spawn_helper(client: ::Client,
+                        rx: Receiver<()>,
+                        mut f: Box<FnMut(io::Result<::Acquired>) + Send>)
+        -> io::Result<Helper>
+    {
+        let quitting = Arc::new(AtomicBool::new(false));
+        let quitting2 = quitting.clone();
+        let (tx_done, rx_done) = mpsc::channel();
+        let thread = Builder::new().spawn(move || {
+            'outer:
+            for () in rx {
+                loop {
+                    let res = client.acquire();
+                    if let Err(ref e) = res {
+                        if e.kind() == io::ErrorKind::Interrupted {
+                            if quitting2.load(Ordering::SeqCst) {
+                                break 'outer
+                            } else {
+                                continue
+                            }
+                        }
+                    }
+                    f(res);
+                    break
+                }
+            }
+            tx_done.send(()).unwrap();
+        })?;
+
+        Ok(Helper {
+            thread: thread,
+            quitting: quitting,
+            rx_done: rx_done,
+        })
+    }
+
+    impl Helper {
+        pub fn join(self) {
+            self.quitting.store(true, Ordering::SeqCst);
+            let dur = Duration::from_millis(10);
+            let mut done = false;
+            for _ in 0..100 {
+                match self.rx_done.recv_timeout(dur) {
+                    Ok(()) |
+                    Err(RecvTimeoutError::Disconnected) => {
+                        done = true;
+                        break
+                    }
+                    Err(RecvTimeoutError::Timeout) => {}
+                }
+                thread::yield_now();
+            }
+            if done {
+                drop(self.thread.join());
+            }
+        }
+    }
+}