Struct snarkos_network::protocol::sync::SyncHandler

pub struct SyncHandler {
    pub sync_node: SocketAddr,
    pub sync_state: SyncState,
    // some fields omitted
}

Manages syncing chain state with a sync node.

1. The server_node sends a GetSync message to a sync_node.
2. The sync_node responds with a Sync message with block_headers the server_node is missing.
3. The server_node sends a GetBlock message for each BlockHeaderHash in the message.

Fields

sync_node: SocketAddr

sync_state: SyncState

Implementations

impl SyncHandler

pub fn new(bootnode: SocketAddr) -> Self

Construct a new SyncHandler.

pub fn update_syncing(&mut self, block_height: u32)

Set the SyncState to syncing and update the latest block height.

pub fn receive_hashes(&mut self, hashes: Vec<BlockHeaderHash>, height: u32)

Process a vector of block header hashes. Push new hashes to the sync handler so we can ask the sync node for them.

pub async fn increment<T: Transaction, P: LoadableMerkleParameters, '_>(
    &'_ mut self,
    channel: Arc<Channel>,
    storage: Arc<Ledger<T, P>>
) -> Result<(), SendError>

Finish syncing or ask for the next block from the sync node.