Struct HeartBeatDataSink

pub struct HeartBeatDataSink {
    pub met: u64,
    pub n_packets_sent: u64,
    pub n_packets_incoming: u64,
    pub n_bytes_written: u64,
    pub n_evid_missing: u64,
    pub n_evid_chunksize: u64,
    pub evid_missing: u64,
    pub evid_check_len: u64,
    pub n_pack_write_disk: u64,
    pub incoming_ch_len: u64,
}

Fields

met: u64

mission elapsed time in seconds

n_packets_sent: u64

n_packets_incoming: u64

n_bytes_written: u64

bytes written to disk

n_evid_missing: u64

event id check - missing event ids

n_evid_chunksize: u64

event id check - chunksize

evid_missing: u64

length of incoming buffer for the thread check for missing event ids

evid_check_len: u64

probe size for missing event id check

n_pack_write_disk: u64

number of packets written to disk

incoming_ch_len: u64

length of the incoming channel, which is basically packets queued to be sent

Implementations

impl HeartBeatDataSink

pub fn new() -> Self

pub fn get_sent_packet_rate(&self) -> f64

pub fn get_mbytes_to_disk_per_sec(&self) -> f64

pub fn to_string(&self) -> String

Trait Implementations

impl Clone for HeartBeatDataSink

fn clone(&self) -> HeartBeatDataSink

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for HeartBeatDataSink

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

Formats the value using the given formatter.

impl Default for HeartBeatDataSink

fn default() -> Self

Returns the “default value” for a type.

impl Display for HeartBeatDataSink

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

Formats the value using the given formatter.

impl FromRandom for HeartBeatDataSink

fn from_random() -> Self

impl Packable for HeartBeatDataSink

const PACKET_TYPE: PacketType = PacketType::HeartBeatDataSink

fn pack(&self) -> TofPacket

where Self: Serialization,

Wrap myself in a TofPacket

impl PartialEq for HeartBeatDataSink

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

const HEAD: u16 = 43_690u16

const TAIL: u16 = 21_845u16

const SIZE: usize = 84usize

The SIZE is the size of the serialized bytestream INCLUDING 4 bytes for head and tail bytes. In case the struct does NOT HAVE a fixed size, SIZE will be 0 (so default value of the trait

fn from_bytestream( stream: &Vec<u8>, pos: &mut usize, ) -> Result<Self, SerializationError>

Decode a serializable from a bytestream

fn to_bytestream(&self) -> Vec<u8>

Encode a serializable to a bytestream

fn verify_fixed( stream: &Vec<u8>, pos: &mut usize, ) -> Result<(), SerializationError>

Verify that the serialized representation of the struct has the correct size, including header + footer.

fn from_tofpacket(packet: &TofPacket) -> Result<Self, SerializationError>

where Self: Sized,

Decode a serializable directly from a TofPacket

fn from_slice( _slice: &[u8], _start_pos: usize, ) -> Result<Self, SerializationError>

where Self: Sized,

fn to_slice(&self) -> &[u8]

where Self: Sized,

Construct byte slice out of self.

impl Copy for HeartBeatDataSink

impl StructuralPartialEq for HeartBeatDataSink