Ecosystem/gupaxx
1
0
Fork 0
mirror of https://github.com/Cyrix126/gupaxx.git synced 2024-11-16 23:37:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix: hide statusfromgupaxx command in p2pool also in lower verbosity

Browse source
This commit is contained in:
Cyrix126 2024-11-02 18:22:12 +01:00
parent 1d582809da
commit 35378c39ae
1 changed files with 22 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
src/helper/p2pool.rs
View file

@ -49,22 +49,35 @@ impl Helper {
// Run a ANSI escape sequence filter for the first few lines.
let mut i = 0;
let mut status_output = false;
while let Some(Ok(line)) = stdout.next() {
let line = strip_ansi_escapes::strip_str(line);
if let Err(e) = writeln!(output_parse.lock().unwrap(), "{}", line) {
error!("P2Pool PTY Parse | Output error: {}", e);
// status could be present before 20 lines with a low verbosity value
if contains_statuscommand(&line) {
status_output = true;
continue;
}
if let Err(e) = writeln!(output_pub.lock().unwrap(), "{}", line) {
error!("P2Pool PTY Pub | Output error: {}", e);
}
if i > 20 {
break;
if status_output {
if contains_end_status(&line) {
// end of status
status_output = false;
continue;
}
} else {
i += 1;
if let Err(e) = writeln!(output_parse.lock().unwrap(), "{}", line) {
error!("P2Pool PTY Parse | Output error: {}", e);
}
if let Err(e) = writeln!(output_pub.lock().unwrap(), "{}", line) {
error!("P2Pool PTY Pub | Output error: {}", e);
}
if i > 20 {
break;
} else {
i += 1;
}
}
}
let mut status_output = false;
while let Some(Ok(line)) = stdout.next() {
// if command status is sent by gupaxx process and not the user, forward it only to update_from_status method.
// 25 lines after the command are the result of status, with last line finishing by update.