aboutsummaryrefslogtreecommitdiffhomepage
path: root/benchmark/bench_queue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'benchmark/bench_queue.cpp')
-rw-r--r--benchmark/bench_queue.cpp4
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);