NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
BufferManagerTest.cpp File Reference
#include <map>
#include <vector>
#include <BaseIntegrationTest.hpp>
#include <Runtime/BufferManager.hpp>
#include <Runtime/HardwareManager.hpp>
#include <Runtime/LocalBufferPool.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Runtime/TupleBuffer.hpp>
#include <Util/Logger/Logger.hpp>
#include <cstdlib>
#include <deque>
#include <future>
#include <gtest/gtest.h>
#include <iostream>
#include <thread>
Include dependency graph for BufferManagerTest.cpp:

Classes

class  NES::BufferManagerTest
 

Namespaces

 NES
 This exception represents a network error.
 

Functions

 NES::TEST_F (BufferManagerTest, initializedBufferManager)
 
 NES::TEST_F (BufferManagerTest, initializedBufferManagerAlignment64)
 
 NES::TEST_F (BufferManagerTest, singleThreadedBufferRecycling)
 
 NES::TEST_F (BufferManagerTest, singleThreadedBufferRecyclingUnpooled)
 
 NES::TEST_F (BufferManagerTest, singleThreadedManyBufferRecyclingUnpooled)
 
 NES::TEST_F (BufferManagerTest, allocateSingleByteUnpooledBuffer)
 
 NES::TEST_F (BufferManagerTest, getBufferAfterRelease)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtAccess)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtProducerConsumer)
 
TupleBuffer NES::getBufferTimeout (const std::shared_ptr< Runtime::BufferManager > &bufferManager, std::chrono::milliseconds &&timeout)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtProducerConsumerTimeout)
 
std::optional< TupleBuffer > NES::getBufferNoBlocking (Runtime::BufferManager &bufferManager)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtProducerConsumerNoblocking)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtProducerConsumerLocalPool)
 
 NES::TEST_F (BufferManagerTest, bufferManagerMtProducerConsumerLocalPoolWithExtraAllocation)
 
 NES::TEST_F (BufferManagerTest, singleThreadedBufferRecyclingWithChildren)
 

Variables

const size_t NES::buffers_managed = 1024
 
const size_t NES::buffer_size = 32 * 1024