NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
BufferStorageTest.cpp File Reference
#include <BaseIntegrationTest.hpp>
#include <Runtime/BufferManager.hpp>
#include <Runtime/BufferStorage.hpp>
#include <Util/Logger/Logger.hpp>
#include <thread>
Include dependency graph for BufferStorageTest.cpp:

Classes

class  NES::BufferStorageTest
 

Namespaces

 NES
 This exception represents a network error.
 

Functions

 NES::TEST_F (BufferStorageTest, bufferInsertionInBufferStorage)
 test inserts buffers to different queues and checks after every insertion that queue size increased on one. After the insertion is fully done the size of the buffer storage is checked to be buffersInserted More...
 
 NES::TEST_F (BufferStorageTest, sortedInsertionInBufferStorage)
 test inserts buffersInserted amount of buffers into one queue but starts from the biggest watermark. The queue is then checked to be sorted to be exact to have the biggest watermark value at the top. More...
 
 NES::TEST_F (BufferStorageTest, emptyBufferCheck)
 test checks that if trimming is called on an empty buffer it doesn't cause an error More...
 
 NES::TEST_F (BufferStorageTest, trimmingOfNonExistingNesPartition)
 test tries to delete non existing element More...
 
 NES::TEST_F (BufferStorageTest, oneBufferDeletionFromBufferStorage)
 test inserts one buffer and deletes it More...
 
 NES::TEST_F (BufferStorageTest, manyBufferDeletionFromBufferStorage)
 test inserts buffersInserted buffers in different queues and deletes them. More...
 
 NES::TEST_F (BufferStorageTest, smallerBufferDeletionFromBufferStorage)
 test inserts buffersInserted buffers in one queue and leaves only one after trimming. The test checks that the deleted buffers are smaller that passed timestamp. More...
 

Variables

const size_t NES::buffersInserted = 101
 
const size_t NES::emptyBuffer = 0
 
const size_t NES::oneBuffer = 1
 
const size_t NES::numberOfThreads = 5