Struct DataFragSubmessage 

pub struct DataFragSubmessage {

    pub extra_flags: u16,
    pub reader_id: EntityId,
    pub writer_id: EntityId,
    pub writer_sn: SequenceNumber,
    pub fragment_starting_num: FragmentNumber,
    pub fragments_in_submessage: u16,
    pub fragment_size: u16,
    pub sample_size: u32,
    pub serialized_payload: Arc<[u8]>,
    pub inline_qos_flag: bool,
    pub hash_key_flag: bool,
    pub key_flag: bool,
    pub non_standard_flag: bool,
}

DATA_FRAG-Submessage. Traegt einen Ausschnitt (Fragmente) eines Samples, dessen Gesamtgroesse in sample_size steht.

Flags (Q/H/K/N) werden aus dem Submessage-Header gespiegelt. Encoder setzt diese Flags aktuell nicht; Decoder akzeptiert sie lesend.

Fields

extra_flags: u16

octetsToInlineQos-Analog zu DATA (§8.3.7.2 spricht von extraFlags+ octetsToInlineQos; Variante traegt 0).

reader_id: EntityId

Reader-EntityId (Ziel).

writer_id: EntityId

Writer-EntityId (Quelle).

writer_sn: SequenceNumber

Sequence-Number des Samples, dessen Fragmente dies traegt.

fragment_starting_num: FragmentNumber

Erstes Fragment in dieser Submessage (1-basiert).

fragments_in_submessage: u16

Anzahl der Fragmente in dieser Submessage. Writer: immer 1.

fragment_size: u16

Groesse eines einzelnen Fragments (das letzte darf kuerzer sein).

sample_size: u32

Gesamtgroesse des Samples in Bytes.

serialized_payload: Arc<[u8]>

Fragmentierter Payload-Ausschnitt. Arc-shared: Writer-Re-Sends bauen nur Refcount-Bumps, keine Kopie.

inline_qos_flag: bool

Q-Flag aus dem Submessage-Header (inline_qos present).

hash_key_flag: bool

H-Flag aus dem Submessage-Header (hash_key).

key_flag: bool

K-Flag aus dem Submessage-Header (serialized_payload = Key).

non_standard_flag: bool

N-Flag aus dem Submessage-Header (non-standard payload).

Implementations

impl DataFragSubmessage

pub const HEADER_WIRE_SIZE: usize = 32

Minimal-Body-Size ohne Payload: extraFlags(2) + octetsToInlineQos(2)

• readerId(4) + writerId(4) + writerSN(8) + fragmentStartingNum(4)
• fragmentsInSubmessage(2) + fragmentSize(2) + sampleSize(4) = 32.

pub const OCTETS_TO_INLINE_QOS: u16 = 28

octetsToInlineQos: Offset vom Ende dieses Felds bis zum Beginn von inlineQos bzw. serializedPayload. Variante mit Q=false: Offset = 28 (readerId..sampleSize).

pub fn write_body(&self, little_endian: bool) -> (Vec<u8>, u8)

Encoded den Body. Liefert (bytes, flags).

pub fn read_body( body: &[u8], little_endian: bool, inline_qos_flag: bool, hash_key_flag: bool, key_flag: bool, non_standard_flag: bool, ) -> Result<Self, WireError>

Decoded den Body. Flags werden aus dem Submessage-Header vom Caller uebergeben.

Errors

UnexpectedEof.

Trait Implementations

impl Clone for DataFragSubmessage

fn clone(&self) -> DataFragSubmessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DataFragSubmessage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for DataFragSubmessage

fn eq(&self, other: &DataFragSubmessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for DataFragSubmessage

impl StructuralPartialEq for DataFragSubmessage