Struct hotshot_types::traits::network::AsynchronousNetwork

pub struct AsynchronousNetwork {
    pub keep_numerator: u32,
    pub keep_denominator: u32,
    pub delay_low_ms: u64,
    pub delay_high_ms: u64,
}

An asynchronous network. Packets may be dropped entirely or delayed for arbitrarily long periods probability that packet is kept = keep_numerator / keep_denominator packet delay is obtained by sampling from a uniform distribution between delay_low_ms and delay_high_ms, inclusive

Fields

keep_numerator: u32

numerator for probability of keeping packets

keep_denominator: u32

denominator for probability of keeping packets

delay_low_ms: u64

lowest value in milliseconds that a packet may be delayed

delay_high_ms: u64

highest value in milliseconds that a packet may be delayed

Implementations

impl AsynchronousNetwork

pub fn new( keep_numerator: u32, keep_denominator: u32, delay_low_ms: u64, delay_high_ms: u64, ) -> Self

create new AsynchronousNetwork

Trait Implementations

impl Clone for AsynchronousNetwork

fn clone(&self) -> AsynchronousNetwork

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AsynchronousNetwork

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

Formats the value using the given formatter.

impl Default for AsynchronousNetwork

fn default() -> Self

Returns the “default value” for a type.

impl NetworkReliability for AsynchronousNetwork

fn sample_keep(&self) -> bool

Sample from bernoulli distribution to decide whether or not to keep a packet

fn sample_delay(&self) -> Duration

sample from uniform distribution to decide whether or not to keep a packet

fn scramble(&self, msg: Vec<u8>) -> Vec<u8>

scramble the packet

fn sample_repeat(&self) -> usize

number of times to repeat the packet

fn chaos_send_msg( &self, msg: Vec<u8>, send_fn: Arc<dyn Send + Sync + Fn(Vec<u8>) -> BoxSyncFuture<'static, ()> + 'static>, ) -> BoxSyncFuture<'static, ()>

given a message and a way to send the message, decide whether or not to send the message how long to delay the message whether or not to send duplicates and whether or not to include noise with the message then send the message note: usually self is stored in a rwlock so instead of doing the sending part, we just fiddle with the message then return a future that does the sending and delaying

impl Copy for AsynchronousNetwork