uqbar-dao/nectar
1
1
Fork 0
mirror of https://github.com/uqbar-dao/nectar.git synced 2024-12-21 07:31:34 +03:00
Code Issues Packages Projects Releases Wiki Activity

terminal: add process_verbosity: HashMap<ProcessId, u8> that overrides verbose_mode when populated

Browse Source
This commit is contained in:
hosted-fornet 2024-12-03 10:49:20 -08:00
parent fdc1b440c8
commit 70a2d68830
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
kinode/src/terminal/mod.rs
View File

@ -9,9 +9,10 @@ use crossterm::{
use futures::{future::FutureExt, StreamExt}; use futures::{future::FutureExt, StreamExt};
use lib::types::core::{ use lib::types::core::{
DebugCommand, DebugSender, Identity, KernelMessage, Message, MessageSender, PrintReceiver, DebugCommand, DebugSender, Identity, KernelMessage, Message, MessageSender, PrintReceiver,
PrintSender, Printout, Request, TERMINAL_PROCESS_ID, PrintSender, Printout, ProcessId, Request, TERMINAL_PROCESS_ID,
}; };
use std::{ use std::{
collections::HashMap,
fs::{read_to_string, OpenOptions}, fs::{read_to_string, OpenOptions},
io::BufWriter, io::BufWriter,
path::PathBuf, path::PathBuf,
@ -44,6 +45,8 @@ struct State {
pub logging_mode: bool, pub logging_mode: bool,
/// verbosity mode (increased by CTRL+V) /// verbosity mode (increased by CTRL+V)
pub verbose_mode: u8, pub verbose_mode: u8,
/// process-level verbosities: override verbose_mode when populated
pub process_verbosity: HashMap<ProcessId, u8>,
} }
impl State { impl State {
@ -238,6 +241,7 @@ pub async fn terminal(
search_depth, search_depth,
logging_mode, logging_mode,
verbose_mode, verbose_mode,
process_verbosity: HashMap::new(),
}; };
// use to trigger cleanup if receive signal to kill process // use to trigger cleanup if receive signal to kill process
@ -342,7 +346,10 @@ fn handle_printout(printout: Printout, state: &mut State) -> anyhow::Result<()>
} }
// skip writing print to terminal if it's of a greater // skip writing print to terminal if it's of a greater
// verbosity level than our current mode // verbosity level than our current mode
if printout.verbosity > state.verbose_mode { let current_verbosity = state.process_verbosity
.get(&printout.source)
.unwrap_or_else(|| &state.verbose_mode);
if &printout.verbosity > current_verbosity {
return Ok(()); return Ok(());
} }
let now = Local::now(); let now = Local::now();