RGBCube/uutils-coreutils
1
Fork 0
mirror of https://github.com/RGBCube/uutils-coreutils synced 2025-07-27 19:17:43 +00:00
Code Issues Activity

Merge pull request #4199 from cakebaker/tail_remove_unused_var_rename_other_var

Browse source 
tail: remove unused "_event_counter"; rename "_timeout_counter" to "timeout_counter"
This commit is contained in:
Sylvestre Ledru 2023-09-24 14:47:33 +02:00 • committed by GitHub
commit 1c03d1614c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/uu/tail/src/follow/watch.rs
View file

@ -479,8 +479,7 @@ pub fn follow(mut observer: Observer, settings: &Settings) -> UResult<()> {
let mut process = platform::ProcessChecker::new(observer.pid);
let mut _event_counter = 0;
let mut _timeout_counter = 0;
let mut timeout_counter = 0;
// main follow loop
loop {
@ -529,8 +528,7 @@ pub fn follow(mut observer: Observer, settings: &Settings) -> UResult<()> {
.receiver
.recv_timeout(settings.sleep_sec);
if rx_result.is_ok() {
_event_counter += 1;
_timeout_counter = 0;
timeout_counter = 0;
}
let mut paths = vec![]; // Paths worth checking for new content to print
@ -569,7 +567,7 @@ pub fn follow(mut observer: Observer, settings: &Settings) -> UResult<()> {
}
Ok(Err(e)) => return Err(USimpleError::new(1, format!("NotifyError: {e}"))),
Err(mpsc::RecvTimeoutError::Timeout) => {
_timeout_counter += 1;
timeout_counter += 1;
}
Err(e) => return Err(USimpleError::new(1, format!("RecvTimeoutError: {e}"))),
}
@ -586,7 +584,7 @@ pub fn follow(mut observer: Observer, settings: &Settings) -> UResult<()> {
_read_some = observer.files.tail_file(path, settings.verbose)?;
}
if _timeout_counter == settings.max_unchanged_stats {
if timeout_counter == settings.max_unchanged_stats {
/*
TODO: [2021-10; jhscheer] implement timeout_counter for each file.
‘--max-unchanged-stats=n’