Restore aysncappender check that every message is delivered

apache · Jul 23, 2024 · 4565ac0 · 4565ac0
1 parent 478b5fb
commit 4565ac0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/test/cpp/asyncappendertestcase.cpp b/src/test/cpp/asyncappendertestcase.cpp
@@ -267,18 +267,22 @@ class AsyncAppenderTestCase : public AppenderSkeletonTestCase
 			const std::vector<spi::LoggingEventPtr>& v = vectorAppender->getVector();
 			LOGUNIT_ASSERT_EQUAL(LEN*threadCount, (int)v.size());
 			std::map<LogString, int> perThreadCount;
+			std::vector<int> msgCount(LEN, 0);
 			for (auto m : v)
 			{
 				auto i = StringHelper::toInt(m->getMessage().substr(7));
 				LOGUNIT_ASSERT(0 <= i);
 				LOGUNIT_ASSERT(i < LEN);
+				++msgCount[i];
 				++perThreadCount[m->getThreadName()];
 			}
 			LOGUNIT_ASSERT_EQUAL(threadCount, (int)perThreadCount.size());
 			for (auto& item : perThreadCount)
 			{
 				LOGUNIT_ASSERT_EQUAL(item.second, LEN);
 			}
+			for (size_t i = 0; i < LEN; i++)
+				LOGUNIT_ASSERT_EQUAL(msgCount[i], threadCount);
 		}
 
 		/**