Implement coproc roughly

Author: ryuichiueda

src/core/file_descs.rs

@@ -31,9 +31,8 @@ impl FileDescriptors {
         data
     }
 
-    pub(super) fn dupfd_cloexec(&mut self, from: RawFd,
+    pub fn dupfd_cloexec(&mut self, from: RawFd,
                                 hereafter: RawFd) -> Result<RawFd, ExecError> {
-        //let fd = fcntl::fcntl(from, fcntl::F_DUPFD_CLOEXEC(hereafter))?;
         let fd = unsafe{fcntl(from, F_DUPFD_CLOEXEC, hereafter)};
         self.fds[fd as usize] = Some(unsafe { OwnedFd::from_raw_fd(fd) });
 

src/elements/command/coproc.rs

@@ -36,12 +36,23 @@ impl Command for Coprocess {
 
         let mut prevp = Pipe::new("|".to_string());
         prevp.set(-1, pgid, core);
+        prevp.send = core.fds.dupfd_cloexec(prevp.send, 60).unwrap();
+        prevp.recv = core.fds.dupfd_cloexec(prevp.recv, 60).unwrap();
+
         let mut lastp = Pipe::new("|".to_string());
         lastp.set(prevp.recv, pgid, core);
+        lastp.send = core.fds.dupfd_cloexec(lastp.send, 60).unwrap();
+        lastp.recv = core.fds.dupfd_cloexec(lastp.recv, 60).unwrap();
+
         let pid = com.exec(core, &mut lastp)?.unwrap();
+        let fds = Some(vec![lastp.recv.to_string(), prevp.send.to_string()]);
 
-        let _ = core.db.init_array(&self.name, Some(vec![lastp.recv.to_string(), prevp.send.to_string()]), Some(0), true);
+        let _ = core.db.init_array(&self.name, fds, Some(0), true);
+        let pid_name = format!("{}_PID", &self.name);
+        let _ = core.db.set_param(&pid_name, &pid.to_string(), Some(0));
 
+        core.fds.close(lastp.send);
+        core.fds.close(prevp.recv);
 
         let _ = core.db.set_param("!", &pid.to_string(), None);
         let new_job_id = core.generate_new_job_id();