diff --git a/vuinputd/src/container/inject_in_container_job.rs b/vuinputd/src/container/inject_in_container_job.rs index 4d30262..53e6fcc 100644 --- a/vuinputd/src/container/inject_in_container_job.rs +++ b/vuinputd/src/container/inject_in_container_job.rs @@ -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(); } }; diff --git a/vuinputd/src/container/remove_from_container_job.rs b/vuinputd/src/container/remove_from_container_job.rs index 130974b..1f7989b 100644 --- a/vuinputd/src/container/remove_from_container_job.rs +++ b/vuinputd/src/container/remove_from_container_job.rs @@ -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(); } };