Commit 1acb9bce authored by Max Kellermann's avatar Max Kellermann

input/buffering: close input if buffered completely

parent 0626e3d2
...@@ -196,8 +196,8 @@ BufferingInputStream::RunThread() noexcept ...@@ -196,8 +196,8 @@ BufferingInputStream::RunThread() noexcept
size_t new_offset = FindFirstHole(); size_t new_offset = FindFirstHole();
if (new_offset == INVALID_OFFSET) { if (new_offset == INVALID_OFFSET) {
/* the file has been read completely */ /* the file has been read completely */
wake_cond.wait(lock); input.reset();
continue; break;
} }
/* seek to the first hole */ /* seek to the first hole */
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment