diff options
| author | Determinant <[email protected]> | 2019-04-14 21:56:10 -0400 |
|---|---|---|
| committer | Determinant <[email protected]> | 2019-04-14 21:56:10 -0400 |
| commit | 9ec5a371f5c05fda8ddeac3470be6fc5c67d44e9 (patch) | |
| tree | 13716360121929cdb65f60c0c6431e387dbaa649 /test/test_queue.cpp | |
| parent | 03e96c4ee3dcf14873a1cdad12509683006a3329 (diff) | |
fix item skipping bug in lock-free queue
Diffstat (limited to 'test/test_queue.cpp')
| -rw-r--r-- | test/test_queue.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_queue.cpp b/test/test_queue.cpp index 11699c1..5c32dac 100644 --- a/test/test_queue.cpp +++ b/test/test_queue.cpp @@ -69,7 +69,7 @@ void test_mpmc(int nproducers, int nconsumers, int nops, size_t burst_size) { std::vector<salticidae::EventContext> ecs; std::atomic<size_t> collected(0); ecs.resize(nconsumers); - q.set_capacity(65536 * nproducers); + q.set_capacity(65536); for (int i = 0; i < nconsumers; i++) { q.reg_handler(ecs[i], [&collected, burst_size](queue_t &q) { |