Struct BlockchainSyncState

pub struct BlockchainSyncState { /* private fields */ }

Maintains the state for fetching blocks from other peers into this peer. Tries to fetch the blocks in the most resource efficient way possible.

Implementations

impl BlockchainSyncState

pub fn new(batch_size: usize) -> BlockchainSyncState

pub fn get_fetching_block_count(&self) -> BlockId

pub fn get_blocks_to_fetch_per_peer( &mut self, ) -> HashMap<PeerIndex, Vec<(SaitoHash, BlockId)>>

Generates the list of blocks which needs to be fetched next. A list is generated per each peer since we can fetch from multiple peers concurrently.

pub fn mark_as_fetched(&mut self, hash: SaitoHash)

Mark the block state as “fetched”

Arguments

• peer_index:
• hash:

returns: ()

Examples

pub async fn add_entry( &mut self, block_hash: SaitoHash, block_id: BlockId, peer_index: PeerIndex, peer_lock: Arc<RwLock<PeerCollection>>, )

Adds an entry to this data structure which will be fetched later after prioritizing.

Arguments

• block_hash:
• block_id:
• peer_index:

returns: ()

Examples

pub fn remove_entry(&mut self, block_hash: SaitoHash)

Removes entry when the hash is added to the blockchain. If so we can move the block ceiling up.

Arguments

• block_hash:
• peer_index:

returns: ()

Examples

pub fn get_stats(&self) -> Vec<String>

pub fn mark_as_failed( &mut self, id: BlockId, hash: BlockHash, peer_index: PeerIndex, )

Mark the blocks which we couldn’t fetch from the peer. After a sevaral retries we will stop fetching the block until we fetch it from another peer.

Arguments

• id:
• hash:
• peer_index:

returns: ()

Examples