Skip to content
Snippets Groups Projects
Commit fbc45723 authored by Georgy Moshkin's avatar Georgy Moshkin :speech_balloon:
Browse files

fix(governor): used to loop infinitely sometimes

parent e309ed25
No related branches found
No related tags found
1 merge request!436fix(governor): used to loop infinitely sometimes
Pipeline #14530 failed
......@@ -112,6 +112,11 @@ impl Loop {
.await;
if let Err(e) = res {
tlog!(Warning, ::std::concat!("failed ", $desc, ": {}"), e, $(; $($kv)*)?);
// TODO: better api needed in library
if waker.has_changed() {
// This resolves immediately
_ = waker.changed().await;
}
_ = waker.changed().timeout(Loop::RETRY_TIMEOUT).await;
return Continue;
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment