Skip to content

Commit

Permalink
Fixed an issue where the app would not stop
Browse files Browse the repository at this point in the history
  • Loading branch information
getroot committed Oct 2, 2024
1 parent ac83406 commit de85a75
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/projects/modules/managed_queue/managed_queue.h
Original file line number Diff line number Diff line change
Expand Up @@ -188,9 +188,14 @@ namespace ov
std::chrono::system_clock::time_point expire = (timeout == Infinite) ? std::chrono::system_clock::time_point::max() : std::chrono::system_clock::now() + std::chrono::milliseconds(timeout);

auto result = _condition.wait_until(unique_lock, expire, [this]() -> bool {
if (_stop)
{
return true;
}

if (_buffering_delay == 0)
{
return ((_size != 0 ) || _stop);
return (_size != 0);
}
else
{
Expand Down

0 comments on commit de85a75

Please sign in to comment.