Robot
/
watchexec
mirror of https://github.com/watchexec/watchexec.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add some logging to Process

This commit is contained in:
Félix Saparelli 2021-08-23 02:34:44 +12:00
parent 60ed6bba25
commit cc5b1c988e
No known key found for this signature in database
GPG Key ID: B948C4BAE44FC474
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
lib/src/command.rs
View File

@ -4,7 +4,7 @@ use std::process::ExitStatus;
use command_group::{AsyncGroupChild, Signal};
use tokio::process::{Child, Command};
use tracing::debug;
use tracing::{debug, trace};
use crate::error::RuntimeError;
@ -170,16 +170,20 @@ impl Process {
match self {
Self::None | Self::Done(_) => Ok(false),
Self::Grouped(c) => c.try_wait().map(|status| {
if let Some(s) = status {
*self = Self::Done(s);
trace!("try-waiting on process group");
if let Some(status) = status {
trace!(?status, "converting to ::Done");
*self = Self::Done(status);
true
} else {
false
}
}),
Self::Ungrouped(c) => c.try_wait().map(|status| {
if let Some(s) = status {
*self = Self::Done(s);
trace!("try-waiting on process");
if let Some(status) = status {
trace!(?status, "converting to ::Done");
*self = Self::Done(status);
true
} else {
false
@ -194,12 +198,16 @@ impl Process {
Self::None => Ok(None),
Self::Done(status) => Ok(Some(*status)),
Self::Grouped(c) => {
trace!("waiting on process group");
let status = c.wait().await?;
trace!(?status, "converting to ::Done");
*self = Self::Done(status);
Ok(Some(status))
}
Self::Ungrouped(c) => {
trace!("waiting on process");
let status = c.wait().await?;
trace!(?status, "converting to ::Done");
*self = Self::Done(status);
Ok(Some(status))
}