Fix for get_awaiter_for_state

This commit is contained in:
Johannes Leupolz 2025-11-22 09:47:39 +00:00
parent 32431b73d3
commit 8950288b09
2 changed files with 2 additions and 2 deletions

View file

@ -56,7 +56,7 @@ impl InjectInContainerJob {
let awaiter = move | state: &State| {
let (lock, cvar) = &*sync_state;
let mut current_state = lock.lock().unwrap();
while *state <= *current_state {
while *current_state < *state {
current_state = cvar.wait(current_state).unwrap();
}
};

View file

@ -57,7 +57,7 @@ impl RemoveFromContainerJob {
let awaiter = move | state: &State| {
let (lock, cvar) = &*sync_state;
let mut current_state = lock.lock().unwrap();
while *state <= *current_state {
while *current_state < *state {
current_state = cvar.wait(current_state).unwrap();
}
};