Thrill  0.1
Public Member Functions | Public Attributes | Static Public Attributes | List of all members
MultiplexerHeader Class Reference
Thrill Layers » Data Subsystem Layer

Detailed Description

Definition at line 36 of file multiplexer_header.hpp.

+ Inheritance diagram for MultiplexerHeader:

#include <multiplexer_header.hpp>

Public Member Functions

 MultiplexerHeader ()=default
 
 MultiplexerHeader (MagicByte m, const PinnedBlock &b)
 

Public Attributes

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...
 

Static Public Attributes

static constexpr size_t header_size
 
static constexpr bool self_verify = common::g_self_verify
 
static constexpr size_t total_size
 

Constructor & Destructor Documentation

◆ MultiplexerHeader() [1/2]

MultiplexerHeader ( )
default

◆ MultiplexerHeader() [2/2]

MultiplexerHeader ( MagicByte  m,
const PinnedBlock &  b 
)
inlineexplicit

Definition at line 53 of file multiplexer_header.hpp.

References MultiplexerHeader::typecode_verify.

Member Data Documentation

◆ first_item

uint32_t first_item

Definition at line 45 of file multiplexer_header.hpp.

Referenced by Multiplexer::OnCatStreamBlock(), Multiplexer::OnMixStreamBlock(), and Multiplexer::OnMultiplexerHeader().

◆ header_size

constexpr size_t header_size
static
Initial value:
=
sizeof(MagicByte) + 3 * sizeof(uint32_t)

Definition at line 63 of file multiplexer_header.hpp.

◆ is_last_block

uint32_t is_last_block

is last block piggybacked indicator

Definition at line 49 of file multiplexer_header.hpp.

Referenced by Multiplexer::OnCatStreamBlock(), and Multiplexer::OnMixStreamBlock().

◆ magic

MagicByte magic = MagicByte::Invalid

Definition at line 41 of file multiplexer_header.hpp.

Referenced by Multiplexer::OnMultiplexerHeader(), and StreamSet< StreamData >::OnWriterClosed().

◆ num_items

uint32_t num_items = 0

Definition at line 43 of file multiplexer_header.hpp.

Referenced by Multiplexer::OnCatStreamBlock(), Multiplexer::OnMixStreamBlock(), and Multiplexer::OnMultiplexerHeader().

◆ self_verify

constexpr bool self_verify = common::g_self_verify
static

Definition at line 39 of file multiplexer_header.hpp.

◆ size

uint32_t size = 0

Definition at line 42 of file multiplexer_header.hpp.

Referenced by Multiplexer::OnCatStreamBlock(), Multiplexer::OnMixStreamBlock(), and Multiplexer::OnMultiplexerHeader().

◆ total_size

constexpr size_t total_size
static
Initial value:
=
header_size + sizeof(size_t) + 3 * sizeof(uint32_t)

Definition at line 66 of file multiplexer_header.hpp.

Referenced by StreamSink::AppendPinnedBlock(), Multiplexer::AsyncReadMultiplexerHeader(), StreamMultiplexerHeader::CalcHostRank(), PartitionMultiplexerHeader::IsEnd(), StreamSet< StreamData >::OnWriterClosed(), StreamMultiplexerHeader::Serialize(), and PartitionMultiplexerHeader::Serialize().

◆ typecode_verify

uint32_t typecode_verify

typecode self verify

Definition at line 47 of file multiplexer_header.hpp.

Referenced by MultiplexerHeader::MultiplexerHeader(), Multiplexer::OnCatStreamBlock(), Multiplexer::OnMixStreamBlock(), and Multiplexer::OnMultiplexerHeader().

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