RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-01 07:52:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

test/cls_2pc_queue: fix multi-threaded access to non-atomic variables

Browse Source 
Fixes: https://tracker.ceph.com/issues/63786

Signed-off-by: Yuval Lifshitz <ylifshit@ibm.com>
This commit is contained in:
Yuval Lifshitz 2024-07-22 16:10:55 +00:00
parent c361a35d3f
commit 6f9f52033b
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/test/cls_2pc_queue/test_cls_2pc_queue.cc
View File

@ -803,7 +803,7 @@ TEST_F(TestCls2PCQueue, MultiProducer)
cls_2pc_queue_init(op, queue_name, max_size);
ASSERT_EQ(0, ioctx.operate(queue_name, &op));
auto producer_count = max_producer_count;
std::atomic<int> producer_count = max_producer_count;
std::vector<std::thread> producers(max_producer_count);
for (auto& p : producers) {
@ -925,9 +925,9 @@ TEST_F(TestCls2PCQueue, MultiProducerConsumer)
cls_2pc_queue_init(op, queue_name, max_size);
ASSERT_EQ(0, ioctx.operate(queue_name, &op));
auto producer_count = max_workers;
std::atomic<int> producer_count = max_workers;
auto retry_happened = false;
std::atomic<bool> retry_happened = false;
std::vector<std::thread> producers(max_workers);
for (auto& p : producers) {