Struct DataSubmessage 

pub struct DataSubmessage {
    pub extra_flags: u16,
    pub reader_id: EntityId,
    pub writer_id: EntityId,
    pub writer_sn: SequenceNumber,
    pub inline_qos: Option<ParameterList>,
    pub key_flag: bool,
    pub non_standard_flag: bool,
    pub serialized_payload: Arc<[u8]>,
}

DATA-Submessage. Phase 0 unterstuetzt nur D-Flag (Daten), kein Q (kein Inline-QoS), kein K, kein N.

serialized_payload ist Arc<[u8]> (WP 2.0a Zero-Copy-Spike). Writer teilen sich die Payload-Allocation mit CacheChange und allen DATA/DATA_FRAG-Datagrammen — clone() auf dieser Struct ist ein reiner Refcount-Bump.

Fields

extra_flags: u16

Reserved Extra-Flags (uint16, meist 0).

reader_id: EntityId

Empfaenger-EntityId.

writer_id: EntityId

Sender-EntityId.

writer_sn: SequenceNumber

Sequence-Number dieser DATA.

inline_qos: Option<ParameterList>

Inline-QoS-ParameterList (Q-Flag, §9.4.5.3.2). None = kein Q-Flag, kein Inline-QoS-Block. Trager fuer PID_KEY_HASH (WP 1.B), PID_STATUS_INFO, PID_COHERENT_SET etc.

key_flag: bool

K-Flag (Spec §8.3.8.2 Tab. 8.43). true: serialized_payload enthaelt nur die @key-Felder (key-only Sample, z.B. dispose- Marker). Der D-Flag kann gleichzeitig false sein, wenn nur Key gesendet wird; in dem Fall ist serialized_payload ein XCDR-codierter Key-Holder.

non_standard_flag: bool

N-Flag (Spec §8.3.8.2 Tab. 8.43, NonStandardPayloadFlag). true: serialized_payload ist NICHT in der durch representation_identifier impliziten CDR-Variante codiert (z.B. fuer DDS-Security-encrypted Payloads).

serialized_payload: Arc<[u8]>

Serialisierter Payload (XCDR2-codiert oder vendor-spezifisch).

Implementations

impl DataSubmessage

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

Encoded den DATA-Body (ohne Submessage-Header) in einen Vec. Setzt automatisch das D-Flag und ggf. das Q-Flag im flags-Output (rueckgegeben), damit der Caller den Submessage-Header korrekt fuellen kann.

Layout: extraFlags(2) + octetsToInlineQos(2) + readerId(4) + writerId(4) + writerSN(8) + [optional InlineQoS-PL] + payload.

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

Decoded den DATA-Body aus einem Slice. Backward-Compat-Wrapper fuer Caller, die kein Q-Flag tragen — Inline-QoS wird ignoriert.

Errors

UnexpectedEof bei zu kurzem Body.

pub fn read_body_with_flags( body: &[u8], little_endian: bool, flags: u8, ) -> Result<Self, WireError>

Decoded den DATA-Body unter Beruecksichtigung der Submessage-Flags. Wenn flags & DATA_FLAG_INLINE_QOS != 0 parst der Decoder die ParameterList nach dem writerSN, vor dem Payload.

Errors

UnexpectedEof bei zu kurzem Body. ParameterList-Fehler werden als WireError durchgereicht.

Trait Implementations

impl Clone for DataSubmessage

fn clone(&self) -> DataSubmessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DataSubmessage

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

Formats the value using the given formatter.

impl PartialEq for DataSubmessage

fn eq(&self, other: &DataSubmessage) -> 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 DataSubmessage

impl StructuralPartialEq for DataSubmessage