Struct EventBuilderHB

pub struct EventBuilderHB {

    pub met_seconds: u64,
    pub n_mte_received_tot: u64,
    pub n_rbe_received_tot: u64,
    pub n_rbe_per_te: u64,
    pub n_rbe_discarded_tot: u64,
    pub n_mte_skipped: u64,
    pub n_timed_out: u64,
    pub n_sent: u64,
    pub delta_mte_rbe: u64,
    pub event_cache_size: u64,
    pub event_id_cache_size: u64,
    pub drs_bsy_lost_hg_hits: u64,
    pub rbe_wo_mte: u64,
    pub mte_receiver_cbc_len: u64,
    pub rbe_receiver_cbc_len: u64,
    pub tp_sender_cbc_len: u64,
    pub n_rbe_from_past: u64,
    pub n_rbe_orphan: u64,
    pub n_rbe_per_loop: u64,
    pub data_mangled_ev: u64,
    pub timestamp: u64,
}

Fields

met_seconds: u64

Mission elapsed time in seconds

n_mte_received_tot: u64

Total number of received MasterTriggerEvents (from MTB)

n_rbe_received_tot: u64

Total number of received RBEvents (from all RB)

n_rbe_per_te: u64

Average number of RBEvents per each MTEvent

n_rbe_discarded_tot: u64

Total number of discarded RBEvents (accross all boards)

n_mte_skipped: u64

TOtal number of missed MTEvents. “Skipped means” gaps in consecutive rising event ids

n_timed_out: u64

Total number of events that timed out, which means they got send before all RBEvents could be associated with this event

n_sent: u64

Total number of events passed on to the gloabl data sink thread

delta_mte_rbe: u64

?

event_cache_size: u64

The total size of the current event cache in number of events

event_id_cache_size: u64

In paralel to the event_cache, the event_id cache holds event ids. This should be perfectly aligned to the event_cache by design.

drs_bsy_lost_hg_hits: u64

The total number of hits which we lost due to the DRS being busy (this is on the Readoutboards)

rbe_wo_mte: u64

The total number of RBEvents which do not have a MasterTriggerEvent

mte_receiver_cbc_len: u64

The current length of the channel which we use to send events from the MasterTrigger thread to the event builder

rbe_receiver_cbc_len: u64

The current length of the channel whcih we use for all readoutboard threads to send their events to the event builder

tp_sender_cbc_len: u64

the current length of the channel which we use to send built events to the global data sink thread

n_rbe_from_past: u64

The total number of RBEvents which have an event id which is SMALLER than the smallest event id in the event cache.

n_rbe_orphan: u64

n_rbe_per_loop: u64

data_mangled_ev: u64

The totabl number of events with the “AnyDataMangling” flag set

timestamp: u64

Implementations

impl EventBuilderHB

pub fn new() -> Self

pub fn get_average_rbe_te(&self) -> f64

The average number of RBEvents per TofEvent, tis is the average number of active ReadoutBoards per TofEvent

pub fn get_timed_out_frac(&self) -> f64

pub fn get_incoming_vs_outgoing_mte(&self) -> f64

pub fn get_nrbe_discarded_frac(&self) -> f64

pub fn get_mangled_frac(&self) -> f64

pub fn get_drs_lost_frac(&self) -> f64

pub fn pretty_print(&self) -> String

Trait Implementations

impl Clone for EventBuilderHB

fn clone(&self) -> EventBuilderHB

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventBuilderHB

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

Formats the value using the given formatter.

impl Default for EventBuilderHB

fn default() -> Self

Returns the “default value” for a type.

impl Display for EventBuilderHB

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

Formats the value using the given formatter.

impl MoniData for EventBuilderHB

fn get(&self, varname: &str) -> Option<f32>

Access the (data) members by name

fn keys() -> Vec<&'static str>

A list of the variables in this MoniData

fn get_board_id(&self) -> u8

Monitoring data is always tied to a specific board. This might not be its own board, but maybe the RB the data was gathered from This is an unique identifier for the monitoring data

fn get_timestamp(&self) -> u64

fn set_timestamp(&mut self, ts: u64)

impl MoniSeries<EventBuilderHB> for EventBuilderHBSeries

fn get_data(&self) -> &HashMap<u8, VecDeque<EventBuilderHB>>

fn get_data_mut(&mut self) -> &mut HashMap<u8, VecDeque<EventBuilderHB>>

fn get_max_size(&self) -> usize

fn get_timestamps(&self) -> &Vec<u64>

fn get_var(&self, varname: &str) -> HashMap<u8, Vec<f32>>

A HashMap of -> rbid, Vec<var>

fn get_var_for_board(&self, varname: &str, rb_id: &u8) -> Option<Vec<f32>>

Get a certain variable, but only for a single board

fn keys() -> Vec<&'static str>

A list of the variables in this MoniSeries

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

A list of boards in this series

fn add(&mut self, data: T)

Add another instance of the data container to the series

fn get_last_moni(&self, board_id: u8) -> Option<T>

impl PartialEq for EventBuilderHB

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

const HEAD: u16 = 43_690u16

Byte marker to mark beginning of payload

const TAIL: u16 = 21_845u16

Byte marker to mark end of payload

const SIZE: usize = 156usize

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_bytestream_alt( bytestream: &Vec<u8>, pos: &mut usize, ) -> Result<Self, SerializationError>

where Self: Sized,

Decode a serializable from a bytestream. This provides an alternative method to get the packet. If not implemented, it will be the same as from_bytestream.

impl TofPackable for EventBuilderHB

const TOF_PACKET_TYPE: TofPacketType = TofPacketType::EventBuilderHB

const TOF_PACKET_TYPE_ALT: TofPacketType = TofPacketType::Unknown

fn pack(&self) -> TofPacket

where Self: Serialization,

Wrap myself in a TofPacket

impl Copy for EventBuilderHB

impl StructuralPartialEq for EventBuilderHB