Function run_test

tests/fuzztests/fuzztests.cpp:107–630

bool run_test(uint64_t seed, int iterations, test_type& out_type, const char*& out_failReason)
{
	bool result = true;
	RNG_t baseRng((unsigned int)seed);
	
	std::uniform_int_distribution<int> randTest(0, TEST_TYPE_COUNT - 1);
	std::uniform_int_distribution<int> randInitialSize(0, 70);
	
	auto type = static_cast<test_type>(randTest(baseRng));
	out_type = type;
	for (int iteration = 0; iteration != iterations; ++iteration) {
		RNG_t rng(baseRng);
		
		std::atomic<bool> failed(false);
		std::atomic<const char*> failReason;
		failReason = nullptr;
		SystemTime startTime = getSystemTime();
		
		switch (type) {
		case multithread_produce:
		{
			const int countIncrement = std::uniform_int_distribution<int>(1, 1000)(rng);
			int count = std::uniform_int_distribution<int>(0, 500)(rng) * countIncrement;
			int prodCount = std::uniform_int_distribution<int>(0, 6)(rng);
			bool useConsumerToken = static_cast<bool>(std::uniform_int_distribution<int>(0, 1)(rng));
			
			ConcurrentQueue<int, FuzzTraits> q(randInitialSize(rng));
			
			std::vector<SimpleThread> producers(prodCount);
			std::vector<bool> useProducerToken(prodCount);
			for (int i = 0; i != prodCount; ++i) {
				useProducerToken[i] = static_cast<bool>(std::uniform_int_distribution<int>(0, 1)(rng));
				producers[i] = SimpleThread([&](int i) {
					ProducerToken t(q);
					for (int j = 0; j != count && !failed.load(std::memory_order_relaxed); j += countIncrement) {
						if (useProducerToken[i]) {
							for (int k = 0; k != countIncrement; ++k) {
								ASSERT_OR_FAIL_THREAD(q.enqueue(t, (i << 24) | (k + j)));
							}
						}
						else {
							for (int k = 0; k != countIncrement; ++k) {
								ASSERT_OR_FAIL_THREAD(q.enqueue((i << 24) | (k + j)));
							}
						}
						FAIL_IF_THREAD_TIMEOUT();
					}
				}, i);
			}
			
			SimpleThread consumer([&]() {
				int item;
				std::vector<int> lastItems(prodCount);
				ConsumerToken t(q);
				
				for (int i = 0; i != prodCount; ++i) {
					lastItems[i] = -1;
				}