Detailed Description

Definition at line 131 of file multiplexer_header.hpp.

Inheritance diagram for PartitionMultiplexerHeader:

Collaboration diagram for PartitionMultiplexerHeader:

#include <multiplexer_header.hpp>

Public Member Functions
	PartitionMultiplexerHeader ()=default

	PartitionMultiplexerHeader (const PinnedBlock &b)

bool	IsEnd () const
	Indicates if this is the end-of-line block header. More...

void	Serialize (net::BufferBuilder &bb) const
	Serializes the whole block struct into a buffer. More...

Public Member Functions inherited from MultiplexerHeader
	MultiplexerHeader ()=default

	MultiplexerHeader (MagicByte m, const PinnedBlock &b)

Static Public Member Functions
static PartitionMultiplexerHeader	Parse (net::BufferReader &br)
	Reads the stream id and the number of elements in this block. More...

Public Attributes
size_t	partition_set_id = 0

uint32_t	receiver_local_worker = 0

uint32_t	sender_worker = 0

uint32_t	seq = 0
	sequence number in Stream More...

Public Attributes inherited from MultiplexerHeader
uint32_t	first_item: 30

uint32_t	is_last_block: 1
	is last block piggybacked indicator More...

MagicByte	magic = MagicByte::Invalid

uint32_t	num_items = 0

uint32_t	size = 0

uint32_t	typecode_verify: 1
	typecode self verify More...

Additional Inherited Members
Static Public Attributes inherited from MultiplexerHeader
static constexpr size_t	header_size

static constexpr bool	self_verify = common::g_self_verify

static constexpr size_t	total_size

Constructor & Destructor Documentation

◆ PartitionMultiplexerHeader() [1/2]

PartitionMultiplexerHeader ( )

default

◆ PartitionMultiplexerHeader() [2/2]

PartitionMultiplexerHeader ( const PinnedBlock & b )

inlineexplicit

Definition at line 144 of file multiplexer_header.hpp.

Member Function Documentation

◆ IsEnd()

bool IsEnd ( ) const

inline

Indicates if this is the end-of-line block header.

Definition at line 159 of file multiplexer_header.hpp.

References thrill::data::TLX_ATTRIBUTE_PACKED, and MultiplexerHeader::total_size.

◆ Parse()

static PartitionMultiplexerHeader Parse ( net::BufferReader & br )

inlinestatic

Reads the stream id and the number of elements in this block.

Definition at line 154 of file multiplexer_header.hpp.

References BufferReader::Get().

◆ Serialize()

void Serialize ( net::BufferBuilder & bb ) const

inline

Serializes the whole block struct into a buffer.

Definition at line 148 of file multiplexer_header.hpp.

References BufferBuilder::Put(), BufferBuilder::Reserve(), and MultiplexerHeader::total_size.

Member Data Documentation

◆ partition_set_id

size_t partition_set_id = 0

Definition at line 134 of file multiplexer_header.hpp.

◆ receiver_local_worker

uint32_t receiver_local_worker = 0

Definition at line 137 of file multiplexer_header.hpp.

◆ sender_worker

uint32_t sender_worker = 0

Definition at line 138 of file multiplexer_header.hpp.

◆ seq

uint32_t seq = 0

sequence number in Stream

Definition at line 140 of file multiplexer_header.hpp.

The documentation for this class was generated from the following file:

thrill/data/multiplexer_header.hpp