tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix flaky transaction_queue_multiple unit test (#1077)

Browse Source
This commit is contained in:
Andi 2023-07-19 22:58:02 +02:00 committed by GitHub
parent fae039c215
commit 05eca46267
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/unit/transaction_queue_multiple.cpp
View File

@ -63,11 +63,14 @@ TYPED_TEST_CASE(TransactionQueueMultipleTest, StorageTypes);
// Tests whether admin can see transaction of superadmin
TYPED_TEST(TransactionQueueMultipleTest, TerminateTransaction) {
std::vector<bool> started(NUM_INTERPRETERS, false);
std::vector<std::atomic<bool>> started(NUM_INTERPRETERS);
for (int i = 0; i < NUM_INTERPRETERS; i++) {
started[i].store(false, std::memory_order_release);
}
auto thread_func = [this, &started](int thread_index) {
try {
this->running_interpreters[thread_index]->Interpret("BEGIN");
started[thread_index] = true;
started[thread_index].store(true, std::memory_order_release);
// add try-catch block
for (int j = 0; j < INSERTIONS; ++j) {
this->running_interpreters[thread_index]->Interpret("CREATE (:Person {prop: " + std::to_string(thread_index) +
@ -84,7 +87,8 @@ TYPED_TEST(TransactionQueueMultipleTest, TerminateTransaction) {
running_threads.emplace_back(thread_func, i);
}
while (!std::all_of(started.begin(), started.end(), [](const bool v) { return v; })) {
while (
!std::all_of(started.begin(), started.end(), [](const auto &v) { return v.load(std::memory_order_acquire); })) {
std::this_thread::sleep_for(std::chrono::milliseconds(20));
}