diff options
author | Matthias Schiffer <mschiffer@universe-factory.net> | 2021-02-05 20:15:11 +0100 |
---|---|---|
committer | Matthias Schiffer <mschiffer@universe-factory.net> | 2021-02-05 20:15:11 +0100 |
commit | e78e29eae4a0cf2e3f46c6a117e1fe86219efe96 (patch) | |
tree | 29b4b4c2bbd47329d2c11b5ca7fbc7629401d662 /src/executor.rs | |
parent | da9fa7d1ad81528c60607f488f84155a3ecc3ee6 (diff) | |
download | rebel-e78e29eae4a0cf2e3f46c6a117e1fe86219efe96.tar rebel-e78e29eae4a0cf2e3f46c6a117e1fe86219efe96.zip |
IPC setup
Diffstat (limited to 'src/executor.rs')
-rw-r--r-- | src/executor.rs | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/executor.rs b/src/executor.rs index 814aa79..1340f83 100644 --- a/src/executor.rs +++ b/src/executor.rs @@ -50,7 +50,7 @@ impl<'a> Executor<'a> { fn run_one(&mut self, runner: &impl runner::Runner) -> runner::Result<()> { let task = self.tasks_runnable.pop().expect("No runnable tasks left"); - runner.run(&task)?; + runner.run(self.tasks, &task)?; let rdeps = self.rdeps.get(&task); @@ -69,10 +69,9 @@ impl<'a> Executor<'a> { Ok(()) } - pub fn run(&mut self) -> runner::Result<()> { - let runner = runner::runc::RuncRunner::new(self.tasks); + pub fn run(&mut self, runner: &impl runner::Runner) -> runner::Result<()> { while !self.tasks_runnable.is_empty() { - self.run_one(&runner)?; + self.run_one(runner)?; } assert!(self.tasks_blocked.is_empty(), "No runnable tasks left"); |