Struct hotshot_testing::byzantine::byzantine_behaviour::ViewDelay

pub struct ViewDelay<TYPES: NodeType> {
    pub number_of_views_to_delay: u64,
    pub events_for_view: HashMap<TYPES::View, Vec<HotShotEvent<TYPES>>>,
    pub stop_view_delay_at_view_number: u64,
}

View delay configuration

Fields

number_of_views_to_delay: u64

How many views the node will be delayed

events_for_view: HashMap<TYPES::View, Vec<HotShotEvent<TYPES>>>

A map that is from view number to vector of events

stop_view_delay_at_view_number: u64

Specify which view number to stop delaying

Trait Implementations

impl<TYPES: Debug + NodeType> Debug for ViewDelay<TYPES>

where TYPES::View: Debug,

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

Formats the value using the given formatter.

impl<TYPES: NodeType, I: NodeImplementation<TYPES> + Debug, V: Versions> EventTransformerState<TYPES, I, V> for ViewDelay<TYPES>

fn recv_handler<'life0, 'life1, 'async_trait>( &'life0 mut self, event: &'life1 HotShotEvent<TYPES>, ) -> Pin<Box<dyn Future<Output = Vec<HotShotEvent<TYPES>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

modify incoming messages from the network

fn send_handler<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 mut self, event: &'life1 HotShotEvent<TYPES>, _public_key: &'life2 TYPES::SignatureKey, _private_key: &'life3 <TYPES::SignatureKey as SignatureKey>::PrivateKey, _upgrade_lock: &'life4 UpgradeLock<TYPES, V>, _consensus: Arc<RwLock<Consensus<TYPES>>>, ) -> Pin<Box<dyn Future<Output = Vec<HotShotEvent<TYPES>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

modify outgoing messages from the network

fn spawn_handle<'async_trait>( &'static mut self, public_key: <TYPES as NodeType>::SignatureKey, private_key: <<TYPES as NodeType>::SignatureKey as SignatureKey>::PrivateKey, nonce: u64, config: HotShotConfig<<TYPES as NodeType>::SignatureKey>, memberships: Memberships<TYPES>, network: Arc<<I as NodeImplementation<TYPES>>::Network>, initializer: HotShotInitializer<TYPES>, metrics: ConsensusMetricsValue, storage: <I as NodeImplementation<TYPES>>::Storage, marketplace_config: MarketplaceConfig<TYPES, I>, ) -> Pin<Box<dyn Future<Output = SystemContextHandle<TYPES, I, V>> + Send + 'async_trait>>

where Self: Send + 'async_trait,

Creates a SystemContextHandle with the given even transformer

fn add_network_tasks<'life0, 'async_trait>( &'static mut self, handle: &'life0 mut SystemContextHandle<TYPES, I, V>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: Send + 'async_trait,

Add byzantine network tasks with the trait

fn add_network_event_tasks(&self, handle: &mut SystemContextHandle<TYPES, I, V>)

Adds the NetworkEventTaskState tasks possibly modifying them as well.

fn add_network_event_task( &self, handle: &mut SystemContextHandle<TYPES, I, V>, channel: Arc<<I as NodeImplementation<TYPES>>::Network>, quorum_membership: <TYPES as NodeType>::Membership, da_membership: <TYPES as NodeType>::Membership, )

Adds a NetworkEventTaskState task. Can be reimplemented to modify its behaviour.