diff options
Diffstat (limited to 'benchmark')
| -rw-r--r-- | benchmark/bench_queue.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/benchmark/bench_queue.cpp b/benchmark/bench_queue.cpp index 5eb1f898a..c28554c75 100644 --- a/benchmark/bench_queue.cpp +++ b/benchmark/bench_queue.cpp @@ -859,8 +859,8 @@ static void test_queue() { for (size_t i = 0; i < THREAD_COUNT; i++) { threads.emplace_back([&q = queues[i]] { while (true) { - auto got = q.reader_wait_nonblock(); - while (got-- > 0) { + auto ready_count = q.reader_wait_nonblock(); + while (ready_count-- > 0) { q.reader_get_unsafe(); } q.reader_get_event_fd().wait(1000); |
