NES::Runtime::detail Namespace Reference

Classes
class	BufferControlBlock
	This class provides a convenient way to track the reference counter as well metadata for its owning MemorySegment/TupleBuffer. In particular, it stores the atomic reference counter that tracks how many live reference exists of the owning MemorySegment/TupleBuffer and it also stores the callback to execute when the reference counter reaches 0. More...
class	MemorySegment
	The MemorySegment is a wrapper around a pointer to allocated memory of size bytes and a control block (. More...
struct	ErrorHandlerLoader
class	ReconfigurationPipelineExecutionContext
class	ReconfigurationEntryPointPipelineStage
class	PoisonPillEntryPointPipelineStage

Functions
template<typename T = void>
T *	allocAligned (size_t size, size_t alignment=16)
	allocates memory that is aligned More...
void	zmqBufferRecyclingCallback (void *ptr, void *hint)
	This is the callback that is called when ZMQ is done with the sending of the buffer with payload in ptr. The hint parameter is the size of the whole buffer (casted as void*) More...
void	nesErrorHandler (int signal)
	called when a signal is intercepted More...
void	nesKillHandler (int signal)
void	nesTerminateHandler ()
	called when std::terminate() is invoked More...
void	nesUnexpectedException ()
	called when an exception is not caught in our code More...
std::string	trim (std::string str)
void	readCpuConfig (uint32_t &numa_nodes_count, uint32_t &num_physical_cpus, std::unordered_map< uint64_t, HardwareManager::NumaDescriptor > &cpuMapping)

Function Documentation

allocAligned()

template<typename T = void>

T* NES::Runtime::detail::allocAligned	(	size_t	size,
		size_t	alignment = 16
	)

allocates memory that is aligned

Template Parameters

T

Parameters

size
alignment

Returns

pointer to allocated memory

References NES_ASSERT2_FMT, and size().

Here is the call graph for this function:

nesErrorHandler()

void NES::Runtime::detail::nesErrorHandler

(

int

signal

)

called when a signal is intercepted

References NES::collectStacktrace(), NES::Logger::getInstance(), NES::getLogLevel(), NES::Exceptions::invokeErrorHandlers(), NES::LOG_DEBUG, and backward::details::move().

Referenced by NES::Runtime::detail::ErrorHandlerLoader::ErrorHandlerLoader().

Here is the call graph for this function:

Here is the caller graph for this function:

nesKillHandler()

void NES::Runtime::detail::nesKillHandler

(

int

signal

)

References NES::Logger::getInstance().

Referenced by NES::Runtime::detail::ErrorHandlerLoader::ErrorHandlerLoader().

Here is the call graph for this function:

Here is the caller graph for this function:

nesTerminateHandler()

void NES::Runtime::detail::nesTerminateHandler

(

)

called when std::terminate() is invoked

References NES::collectStacktrace(), NES::Logger::getInstance(), NES::getLogLevel(), NES::Exceptions::invokeErrorHandlers(), NES::LOG_DEBUG, and backward::details::move().

Referenced by NES::Runtime::detail::ErrorHandlerLoader::ErrorHandlerLoader().

Here is the call graph for this function:

Here is the caller graph for this function:

nesUnexpectedException()

void NES::Runtime::detail::nesUnexpectedException

(

)

called when an exception is not caught in our code

References NES::collectStacktrace(), NES::Logger::getInstance(), NES::getLogLevel(), NES::Exceptions::invokeErrorHandlers(), NES::LOG_DEBUG, and backward::details::move().

Referenced by NES::Runtime::detail::ErrorHandlerLoader::ErrorHandlerLoader().

Here is the call graph for this function:

Here is the caller graph for this function:

readCpuConfig()

void NES::Runtime::detail::readCpuConfig	(	uint32_t &	numa_nodes_count,
		uint32_t &	num_physical_cpus,
		std::unordered_map< uint64_t, HardwareManager::NumaDescriptor > &	cpuMapping
	)

References NES_ASSERT2_FMT, and trim().

Referenced by NES::Runtime::HardwareManager::HardwareManager().

Here is the call graph for this function:

Here is the caller graph for this function:

trim()

std::string NES::Runtime::detail::trim

(

std::string

str

)

Referenced by readCpuConfig().

Here is the caller graph for this function:

zmqBufferRecyclingCallback()

void NES::Runtime::detail::zmqBufferRecyclingCallback	(	void *	ptr,
		void *	hint
	)

This is the callback that is called when ZMQ is done with the sending of the buffer with payload in ptr. The hint parameter is the size of the whole buffer (casted as void*)

References NES_VERIFY, and NES::Runtime::detail::BufferControlBlock::release().

Referenced by NES::Network::detail::NetworkDataSender< BaseChannelType >::sendBuffer(), and NES::Network::detail::NetworkEventSender< BaseChannelType >::sendEvent().

Here is the call graph for this function:

Here is the caller graph for this function: