Struct Dmsg 

pub struct Dmsg {
    pub id: MsgId,
    pub ty: DmsgType,
    pub flags: u8,
    pub version: u8,
    pub same_dc: bool,
    pub source_address: Option<SocketAddr>,
    pub mlen: u32,
    pub data: Vec<u8>,
    pub plen: u32,
    pub payload: Vec<u8>,
}

Parsed DNODE header.

data and payload hold copies of the on-the-wire bytes. The encoder side fills both before emitting; the parser fills them as it advances through the state machine.

Fields

id: MsgId

Message id.

ty: DmsgType

Message type.

flags: u8

Flag bit field; encryption is bit 0, compression is bit 1.

version: u8

Protocol version.

same_dc: bool

True when sender and receiver share a datacenter.

source_address: Option<SocketAddr>

Source address recorded by the recv path. Stage 7 leaves it None; Stage 9 stamps it from the connection state.

mlen: u32

Length (in bytes) of the inline data field.

data: Vec<u8>

Inline data: either the single-byte placeholder or the RSA-wrapped AES key during the crypto handshake.

plen: u32

Length (in bytes) of the trailing payload framed by the header.

payload: Vec<u8>

Payload bytes, if collected by the parser.

Implementations

impl Dmsg

pub fn new() -> Self

Construct an empty Dmsg defaulted the same way the reference engine’s dmsg_get initialises a fresh slot.

Examples

use dynomite::proto::dnode::{Dmsg, DmsgType, VERSION_10};
let d = Dmsg::new();
assert_eq!(d.ty, DmsgType::Unknown);
assert_eq!(d.version, VERSION_10);
assert!(d.same_dc);

pub fn is_encrypted(&self) -> bool

True when the encryption flag is set.

Examples

use dynomite::proto::dnode::{Dmsg, DMSG_FLAG_ENCRYPTED};
let mut d = Dmsg::new();
d.flags = DMSG_FLAG_ENCRYPTED;
assert!(d.is_encrypted());

pub fn is_compressed(&self) -> bool

True when the compression flag is set.

Examples

use dynomite::proto::dnode::{Dmsg, DMSG_FLAG_COMPRESSED};
let mut d = Dmsg::new();
d.flags = DMSG_FLAG_COMPRESSED;
assert!(d.is_compressed());

Trait Implementations

impl Clone for Dmsg

fn clone(&self) -> Dmsg

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Dmsg

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

Formats the value using the given formatter.

impl Default for Dmsg

fn default() -> Dmsg

Returns the “default value” for a type.

impl PartialEq for Dmsg

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

impl StructuralPartialEq for Dmsg