Struct hotshot_task_impls::response::NetworkResponseState

pub struct NetworkResponseState<TYPES: NodeType> {
    consensus: LockedConsensusState<TYPES>,
    membership: Arc<RwLock<TYPES::Membership>>,
    pub_key: TYPES::SignatureKey,
    private_key: <TYPES::SignatureKey as SignatureKey>::PrivateKey,
    id: u64,
}

Task state for the Network Request Task. The task is responsible for handling requests sent to this node by the network. It will validate the sender, parse the request, and try to find the data request in the consensus stores.

Fields

consensus: LockedConsensusState<TYPES>

Locked consensus state

membership: Arc<RwLock<TYPES::Membership>>

Quorum membership for checking if requesters have state

pub_key: TYPES::SignatureKey

This replicas public key

private_key: <TYPES::SignatureKey as SignatureKey>::PrivateKey

This replicas private key

id: u64

The node’s id

Implementations

impl<TYPES: NodeType> NetworkResponseState<TYPES>

pub fn new( consensus: LockedConsensusState<TYPES>, membership: Arc<RwLock<TYPES::Membership>>, pub_key: TYPES::SignatureKey, private_key: <TYPES::SignatureKey as SignatureKey>::PrivateKey, id: u64, ) -> Self

Create the network request state with the info it needs

async fn run_response_loop( self, receiver: Receiver<Arc<HotShotEvent<TYPES>>>, event_sender: Sender<Arc<HotShotEvent<TYPES>>>, )

Process request events or loop until a HotShotEvent::Shutdown is received.

async fn get_or_calc_vid_share( &self, view: TYPES::View, key: &TYPES::SignatureKey, ) -> Option<Proposal<TYPES, VidDisperseShare2<TYPES>>>

Get the VID share from consensus storage, or calculate it from the payload for the view, if we have the payload. Stores all the shares calculated from the payload if the calculation was done

async fn valid_sender( &self, sender: &TYPES::SignatureKey, epoch: TYPES::Epoch, ) -> bool

Makes sure the sender is allowed to send a request in the given epoch.