Struct phron_finality::party::manager::NodeSessionManagerImpl

pub struct NodeSessionManagerImpl<C, SC, B, RB, BE, SM, JS>
where
    B: BlockT<Hash = BlockHash>,
    B::Header: HeaderT<Number = BlockNumber>,
    C: ClientForPhron<B, BE> + Send + Sync + 'static,
    BE: Backend<B> + 'static,
    SC: SelectChain<B> + 'static,
    RB: RequestBlocks,
    SM: SessionManager<VersionedEitherMessage<Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>, Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>>> + 'static,
    JS: JustificationSubmissions<Justification> + Send + Sync + Clone,
{
    client: Arc<C>,
    select_chain: SC,
    session_info: SessionBoundaryInfo,
    unit_creation_delay: UnitCreationDelay,
    justifications_for_sync: JS,
    justification_translator: JustificationTranslator,
    block_requester: RB,
    metrics: TimingBlockMetrics,
    spawn_handle: SpawnHandle,
    session_manager: SM,
    keystore: Arc<dyn Keystore>,
    _phantom: PhantomData<(B, BE)>,
}

Fields

client: Arc<C>

select_chain: SC

session_info: SessionBoundaryInfo

unit_creation_delay: UnitCreationDelay

justifications_for_sync: JS

justification_translator: JustificationTranslator

block_requester: RB

metrics: TimingBlockMetrics

spawn_handle: SpawnHandle

session_manager: SM

keystore: Arc<dyn Keystore>

_phantom: PhantomData<(B, BE)>

Implementations

impl<C, SC, B, RB, BE, SM, JS> NodeSessionManagerImpl<C, SC, B, RB, BE, SM, JS>

where B: BlockT<Hash = BlockHash>, B::Header: HeaderT<Number = BlockNumber>, C: ClientForPhron<B, BE> + Send + Sync + 'static, C::Api: PhronSessionApi<B>, BE: Backend<B> + 'static, SC: SelectChain<B> + 'static, RB: RequestBlocks, SM: SessionManager<VersionedEitherMessage<Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>, Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>>>, JS: JustificationSubmissions<Justification> + Send + Sync + Clone + 'static,

pub fn new( client: Arc<C>, select_chain: SC, session_period: SessionPeriod, unit_creation_delay: UnitCreationDelay, justifications_for_sync: JS, justification_translator: JustificationTranslator, block_requester: RB, metrics: TimingBlockMetrics, spawn_handle: SpawnHandle, session_manager: SM, keystore: Arc<dyn Keystore> ) -> Self

fn legacy_subtasks<N: Network<VersionedEitherMessage<Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>, Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>>> + 'static>( &self, params: SubtasksParams<C, B, N, BE, JS> ) -> Subtasks

fn current_subtasks<N: Network<VersionedEitherMessage<Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>, Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>>> + 'static>( &self, params: SubtasksParams<C, B, N, BE, JS> ) -> Subtasks

async fn spawn_subtasks( &self, session_id: SessionId, authorities: &[AuthorityId], node_id: NodeIndex, exit_rx: Receiver<()>, backup: (Box<dyn Write + Send + Sync>, Box<dyn Read + Send + Sync>) ) -> Subtasks

Trait Implementations

impl<C, SC, B, RB, BE, SM, JS> NodeSessionManager for NodeSessionManagerImpl<C, SC, B, RB, BE, SM, JS>

where B: BlockT<Hash = BlockHash>, B::Header: HeaderT<Number = BlockNumber>, C: ClientForPhron<B, BE> + Send + Sync + 'static, C::Api: PhronSessionApi<B>, BE: Backend<B> + 'static, SC: SelectChain<B> + 'static, RB: RequestBlocks, SM: SessionManager<VersionedEitherMessage<Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>, Split<NetworkData<HashWrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, RmcNetworkData<BlockHash, Signature, SignatureSet<Signature>>>>>, JS: JustificationSubmissions<Justification> + Send + Sync + Clone + 'static,

type Error = <SM as SessionManager<VersionedEitherMessage<Split<NetworkData<Wrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, Message<SignableHash<<Header<u32, BlakeTwo256> as Header>::Hash>, Signature, SignatureSet<Signature>>>, Split<NetworkData<Wrapper<BlakeTwo256>, PhronData, Signature, SignatureSet<Signature>>, Message<SignableHash<<Header<u32, BlakeTwo256> as Header>::Hash>, Signature, SignatureSet<Signature>>>>>>::Error

fn spawn_authority_task_for_session<'life0, 'life1, 'async_trait>( &'life0 self, session: SessionId, node_id: NodeIndex, backup: (Box<dyn Write + Send + Sync>, Box<dyn Read + Send + Sync>), authorities: &'life1 [AuthorityId] ) -> Pin<Box<dyn Future<Output = AuthorityTask> + Send + 'async_trait>>

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

Spawns every task needed for an authority to run in a session.

fn early_start_validator_session( &self, session: SessionId, node_id: NodeIndex, authorities: &[AuthorityId] ) -> Result<(), Self::Error>

Prepare validator session.

fn start_nonvalidator_session( &self, session: SessionId, authorities: &[AuthorityId] ) -> Result<(), Self::Error>

Starts nonvalidator session.

fn stop_session(&self, session: SessionId) -> Result<(), Self::Error>

Terminates the session.

fn node_idx(&self, authorities: &[AuthorityId]) -> Option<NodeIndex>

Returns idx of the node if it is in the authority set, None otherwise