summaryrefslogtreecommitdiffstats
path: root/src/executor.rs
diff options
context:
space:
mode:
authorMatthias Schiffer <mschiffer@universe-factory.net>2021-02-05 20:15:11 +0100
committerMatthias Schiffer <mschiffer@universe-factory.net>2021-02-05 20:15:11 +0100
commite78e29eae4a0cf2e3f46c6a117e1fe86219efe96 (patch)
tree29b4b4c2bbd47329d2c11b5ca7fbc7629401d662 /src/executor.rs
parentda9fa7d1ad81528c60607f488f84155a3ecc3ee6 (diff)
downloadrebel-e78e29eae4a0cf2e3f46c6a117e1fe86219efe96.tar
rebel-e78e29eae4a0cf2e3f46c6a117e1fe86219efe96.zip
IPC setup
Diffstat (limited to 'src/executor.rs')
-rw-r--r--src/executor.rs7
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");