We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eccd5da commit 944a3deCopy full SHA for 944a3de
src/auto_splitting/mod.rs
@@ -862,6 +862,7 @@ async fn watchdog(
862
interrupt_receiver: watch::Receiver<Option<InterruptHandle>>,
863
) {
864
const TIMEOUT: Duration = Duration::from_secs(5);
865
+ let mut has_timed_out = false;
866
867
loop {
868
let instant = *timeout_receiver.borrow();
@@ -876,6 +877,10 @@ async fn watchdog(
876
877
Ok(Err(_)) => return,
878
Err(_) => {
879
if let Some(handle) = &*interrupt_receiver.borrow() {
880
+ if !has_timed_out {
881
+ log::error!(target: "Auto Splitter", "timeout, no update in {} seconds", TIMEOUT.as_secs_f32());
882
+ has_timed_out = true;
883
+ }
884
handle.interrupt();
885
}
886
0 commit comments