TupleBufferImpl.hpp File Reference

#include <Identifiers/Identifiers.hpp>
#include <Runtime/TaggedPointer.hpp>
#include <atomic>
#include <functional>
#include <sstream>
#include <vector>

Include dependency graph for TupleBufferImpl.hpp:

This graph shows which files directly or indirectly include this file:

Classes
class	NES::Runtime::detail::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	NES::Runtime::detail::MemorySegment
	The MemorySegment is a wrapper around a pointer to allocated memory of size bytes and a control block (. More...

Namespaces
	NES
	This exception represents a network error.
	NES::Runtime
	Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.
	NES::Runtime::detail

Macros
#define	PLACEHOLDER_LIKELY(cond)   (cond) [[likely]]
#define	PLACEHOLDER_UNLIKELY(cond)   (cond) [[unlikely]]

Functions
constexpr uint32_t	NES::Runtime::alignBufferSize (uint32_t bufferSize, uint32_t withAlignment)
	Computes aligned buffer size based on original buffer size and alignment. More...
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*) More...

Macro Definition Documentation

PLACEHOLDER_LIKELY

#define PLACEHOLDER_LIKELY

(

cond

)

(cond) [[likely]]

PLACEHOLDER_UNLIKELY

#define PLACEHOLDER_UNLIKELY

(

cond

)

(cond) [[unlikely]]