Struct hotshot_testing::spinning_task::SpinningTask

pub struct SpinningTask<TYPES: NodeType, N: ConnectedNetwork<TYPES::SignatureKey>, I: TestableNodeImplementation<TYPES>, V: Versions> {
    pub(crate) handles: Arc<RwLock<Vec<Node<TYPES, I, V>>>>,
    pub(crate) late_start: HashMap<u64, LateStartNode<TYPES, I, V>>,
    pub(crate) changes: BTreeMap<TYPES::View, Vec<ChangeNode>>,
    pub(crate) latest_view: Option<TYPES::View>,
    pub(crate) last_decided_leaf: Leaf<TYPES>,
    pub(crate) high_qc: QuorumCertificate<TYPES>,
    pub(crate) async_delay_config: DelayConfig,
    pub(crate) restart_contexts: HashMap<usize, RestartContext<TYPES, N, I, V>>,
    pub(crate) channel_generator: AsyncGenerator<Network<TYPES, I>>,
}

Spinning task state

Fields

handles: Arc<RwLock<Vec<Node<TYPES, I, V>>>>

handle to the nodes

late_start: HashMap<u64, LateStartNode<TYPES, I, V>>

late start nodes

changes: BTreeMap<TYPES::View, Vec<ChangeNode>>

time based changes

latest_view: Option<TYPES::View>

most recent view seen by spinning task

last_decided_leaf: Leaf<TYPES>

Last decided leaf that can be used as the anchor leaf to initialize the node.

high_qc: QuorumCertificate<TYPES>

Highest qc seen in the test for restarting nodes

async_delay_config: DelayConfig

Add specified delay to async calls

restart_contexts: HashMap<usize, RestartContext<TYPES, N, I, V>>

Context stored for nodes to be restarted with

channel_generator: AsyncGenerator<Network<TYPES, I>>

Generate network channel for restart nodes

Trait Implementations

impl<TYPES: NodeType<InstanceState = TestInstanceState, ValidatedState = TestValidatedState, BlockHeader = TestBlockHeader>, I, N: ConnectedNetwork<TYPES::SignatureKey>, V: Versions> TestTaskState for SpinningTask<TYPES, N, I, V>

where I: TestableNodeImplementation<TYPES> + NodeImplementation<TYPES, Network = N, Storage = TestStorage<TYPES>, AuctionResultsProvider = TestAuctionResultsProvider<TYPES>>,

type Event = Event<TYPES>

Type of event sent and received by the task

fn handle_event<'life0, 'async_trait>( &'life0 mut self, __arg1: (Self::Event, usize), ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Handles an event from one of multiple receivers.

fn check<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = TestResult> + Send + 'async_trait>>

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

Check the result of the test.