Thrill  0.1
PartitionMultiplexerHeader Class Reference

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() [2/2]

PartitionMultiplexerHeader ( const PinnedBlock b)

Definition at line 144 of file multiplexer_header.hpp.

Member Function Documentation

◆ IsEnd()

bool IsEnd ( ) const

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)

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

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: