NonBlockingMonotonicSeqQueueTest.cpp File Reference

#include <BaseUnitTest.hpp>
#include <Sequencing/NonBlockingMonotonicSeqQueue.hpp>
#include <Util/Logger/Logger.hpp>
#include <Util/StdInt.hpp>
#include <algorithm>
#include <atomic>
#include <gtest/gtest.h>
#include <random>
#include <thread>

Include dependency graph for NonBlockingMonotonicSeqQueueTest.cpp:

Classes
struct	NES::ChunkStateTest
class	NES::NonBlockingMonotonicSeqQueueTest

Namespaces
	NES
	This exception represents a network error.

Functions
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, singleThreadSequentialUpdaterTest)
	A single thread test for the lock free watermark processor. We create a sequential list of 10k updates, monotonically increasing from 1 to 10k and push them to the watermark processor. Assumption: As we insert all updates in a sequential fashion we assume that the getCurrentWatermark is equal to the latest processed update. More...
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, singleThreadReversSequentialUpdaterTest)
	A single thread test for the lock free watermark processor. We create a reverse sequential list of 10k updates, monotonically decreasing from 10k to 1 and push them to the watermark processor. Assumption: As we insert all updates in a sequential fashion we assume that the getCurrentWatermark is equal to the latest processed update. More...
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, singleThreadRandomeUpdaterTest)
	A single thread test for the lock free watermark processor. We create a reverse sequential list of 10k updates, monotonically decreasing from 10k to 1 and push them to the watermark processor. Assumption: As we insert all updates in a sequential fashion we assume that the getCurrentWatermark is equal to the latest processed update. More...
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, concurrentLockFreeWatermarkUpdaterTest)
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, concurrentUpdatesWithLostUpdateThreadTest)
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, singleThreadedUpdatesWithChunkNumberInRandomFashionTest)
	We test here to insert sequence and chunks numbers in a "random" fashion and then check, if the correct output is produced. More...
	NES::TEST_F (NonBlockingMonotonicSeqQueueTest, concurrentUpdatesWithChunkNumberInRandomFashionTest)
	We test here to insert sequence and chunks numbers in a "random" fashion and then check, if the correct output is produced. We do this in a concurrent fashion. More...