It is ok if we get more messages

fair-acc · Jan 31, 2024 · 38fde91 · 38fde91
1 parent a3e79a9
commit 38fde91
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/core/test/qa_Messages.cpp b/core/test/qa_Messages.cpp
@@ -44,7 +44,8 @@ messageProcessorCounter(std::atomic_size_t &countdown, std::atomic_size_t &total
                     continue;
                 }
 
-                countdown--;
+                fmt::print("Got a message, countdown was {}\n", countdown.load());
+                if (countdown > 0) countdown--;
                 totalCounter++;
 
                 if (!replyMessage.empty()) _this->emitMessage(_this->msgOut, std::move(replyMessage));
@@ -189,8 +190,9 @@ const boost::ut::suite MessagesTests = [] {
         scheduler.runAndWait();
         messenger.join();
 
-        expect(sourceMessagesCountdown == 1);
-        expect(sinkMessagesCountdown == 0);
+        expect(eq(sourceMessagesCountdown.load(), 1UZ));
+        fmt::print("This is the sinkMessagesCountdown {}\n", sinkMessagesCountdown.load());
+        expect(eq(sinkMessagesCountdown.load(), 0UZ));
     };
 
     // Testing if settings messages work