summaryrefslogtreecommitdiffstats
path: root/src/runner/mod.rs
diff options
context:
space:
mode:
authorJesse Luehrs <doy@tozt.net>2022-01-11 00:10:56 -0500
committerJesse Luehrs <doy@tozt.net>2022-01-11 00:37:09 -0500
commit4086fc1f83673554f9b9695e853c44dd895add23 (patch)
tree0ce4aa198f1cce027c726dc90e11c923cd0e4447 /src/runner/mod.rs
parent5bce22093b4b0778f729d8d92e37f42214f78fc5 (diff)
downloadnbsh-4086fc1f83673554f9b9695e853c44dd895add23.tar.gz
nbsh-4086fc1f83673554f9b9695e853c44dd895add23.zip
highlight the specific pipeline that is currently running
Diffstat (limited to 'src/runner/mod.rs')
-rw-r--r--src/runner/mod.rs3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/runner/mod.rs b/src/runner/mod.rs
index 86fb1b4..3e32498 100644
--- a/src/runner/mod.rs
+++ b/src/runner/mod.rs
@@ -9,6 +9,7 @@ const PID0: nix::unistd::Pid = nix::unistd::Pid::from_raw(0);
#[derive(Debug, serde::Serialize, serde::Deserialize)]
pub enum Event {
+ RunPipeline(usize, (usize, usize)),
Suspend(usize),
Exit(Env),
}
@@ -195,6 +196,8 @@ async fn run_pipeline(
env: &mut Env,
shell_write: &async_std::fs::File,
) -> anyhow::Result<()> {
+ write_event(&shell_write, Event::RunPipeline(env.idx(), pipeline.span()))
+ .await?;
// Safety: pipelines are run serially, so only one copy of these will ever
// exist at once. note that reusing a single copy of these at the top
// level would not be safe, because in the case of a command line like