Enable to remove coproc variables

Author: ryuichiueda

src/core/builtins/job_commands.rs

@@ -292,8 +292,20 @@ fn print(core: &mut ShellCore, args: &[String]) {
     }
 }
 
+fn remove_coproc(core: &mut ShellCore, pos: usize) {
+    core.job_table[pos].coproc_fds
+        .iter()
+        .for_each(|fd| {core.fds.close(*fd);});
+
+    if let Some(name) = &core.job_table[pos].coproc_name {
+        let _ = core.db.unset(&name, None);
+        let _ = core.db.unset(&(name.to_owned() + "_PID"), None);
+    }
+}
+
 fn remove(core: &mut ShellCore, pos: usize) {
     let job_id = core.job_table[pos].id;
+    remove_coproc(core, pos);
     core.job_table.remove(pos);
     core.job_table_priority.retain(|id| *id != job_id);
 }
@@ -570,6 +582,7 @@ pub fn disown(core: &mut ShellCore, args: &[String]) -> i32 {
         let ids = jobspec_to_array_poss(core, "%%");
 
         if ids.len() == 1 {
+            remove_coproc(core, ids[0]);
             core.job_table.remove(ids[0]);
             core.job_table_priority.remove(0);
             return 0;

src/core/jobtable.rs

@@ -243,11 +243,15 @@ impl ShellCore {
                 stopped.push(i);
             }
 
-            if table.display_status == "Done" 
-            || table.display_status == "Killed" {
+            if  table.coproc_name.is_some() 
+            && (table.display_status == "Done" || table.display_status == "Killed") {
                 table.coproc_fds
                      .iter()
                      .for_each(|fd| {self.fds.close(*fd);});
+
+                let name = table.coproc_name.clone().unwrap();
+                let _ = self.db.unset(&name, None);
+                let _ = self.db.unset(&(name + "_PID"), None);
             }
         }
 

src/elements/command/coproc.rs

@@ -58,7 +58,10 @@ impl Command for Coprocess {
 
         let _ = core.db.set_param("!", &pid.to_string(), None);
         let new_job_id = core.generate_new_job_id();
-        eprintln!("[{}] {}", &new_job_id, &pid);
+
+        if core.db.flags.contains('i') {
+            eprintln!("[{}] {}", &new_job_id, &pid);
+        }
         core.job_table_priority.insert(0, new_job_id);
         let mut entry = JobEntry::new(
             vec![Some(pid)],