1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
use std::{
io::BufRead,
ffi::CString,
};
use nix::sys::wait::WaitStatus;
use crate::{
process::{ProcessGroup, Process},
program::{Runtime, Result, Error},
};
#[derive(Debug)]
pub struct Program(Vec<Command>);
impl super::Program for Program {
type Command = Command;
fn parse<R: BufRead>(mut reader: R) -> Result<Self> {
let mut command = String::new();
if reader.read_to_string(&mut command).is_err() {
return Err(Error::Read);
}
Ok(Program(vec![Command(command)]))
}
fn commands(&self) -> &[Self::Command] {
&self.0[..]
}
}
#[derive(Debug)]
pub struct Command(String);
impl super::Command for Command {}
impl super::Run for Command {
fn run(&self, runtime: &mut Runtime) -> Result<WaitStatus> {
let mut job = Process::new(self.0.split_whitespace().map(|a| {
CString::new(a).expect("error reading argument")
}).collect());
let status = if runtime.background {
let status = job.fork(runtime.io);
runtime.jobs.borrow_mut().push(("???".into(), ProcessGroup(job)));
status
} else {
job.fork_and_wait(runtime.io)
};
match status {
Ok(WaitStatus::Exited(p, c)) if c == 0 => {
Ok(WaitStatus::Exited(p, c))
},
_ => Err(Error::Runtime),
}
}
}