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. Carries a section (fragments) of a sample whose total size is in sample_size.

Flags (Q/H/K/N) are mirrored from the submessage header. The encoder does not currently set these flags; the decoder accepts them on read.

Fields

extra_flags: u16

octetsToInlineQos analogue to DATA (§8.3.7.2 speaks of extraFlags+ octetsToInlineQos; this variant carries 0).

reader_id: EntityId

Reader EntityId (target).

writer_id: EntityId

Writer EntityId (source).

writer_sn: SequenceNumber

Sequence number of the sample whose fragments this carries.

fragment_starting_num: FragmentNumber

First fragment in this submessage (1-based).

fragments_in_submessage: u16

Number of fragments in this submessage. Writer: always 1.

fragment_size: u16

Size of a single fragment (the last may be shorter).

sample_size: u32

Total size of the sample in bytes.

serialized_payload: Arc<[u8]>

Fragmented payload section. Arc-shared: writer re-sends are just refcount bumps, no copy.

inline_qos_flag: bool

Q-flag from the submessage header (inline_qos present).

hash_key_flag: bool

H-flag from the submessage header (hash_key).

key_flag: bool

K-flag from the submessage header (serialized_payload = key).

non_standard_flag: bool

N-flag from the submessage header (non-standard payload).

Implementations

impl DataFragSubmessage

pub const HEADER_WIRE_SIZE: usize = 32

Minimal body size without 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 from the end of this field to the start of inlineQos or serializedPayload. Variant with Q=false: offset = 28 (readerId..sampleSize).

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

Encodes the body. Returns (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>

Decodes the body. Flags are passed by the caller from the submessage header.

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 Eq for DataFragSubmessage

impl PartialEq for DataFragSubmessage

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for DataFragSubmessage