ancestry_ | kagome::network::SynchronizerImpl | private |
app_state_manager_ | kagome::network::SynchronizerImpl | private |
applying_in_progress_ | kagome::network::SynchronizerImpl | private |
applyNextBlock() | kagome::network::SynchronizerImpl | private |
applyNextJustification() | kagome::network::SynchronizerImpl | private |
asking_blocks_portion_in_progress_ | kagome::network::SynchronizerImpl | private |
askNextPortionOfBlocks() | kagome::network::SynchronizerImpl | private |
batches_store_ | kagome::network::SynchronizerImpl | private |
block_appender_ | kagome::network::SynchronizerImpl | private |
block_executor_ | kagome::network::SynchronizerImpl | private |
block_tree_ | kagome::network::SynchronizerImpl | private |
buffer_storage_ | kagome::network::SynchronizerImpl | private |
busy_peers_ | kagome::network::SynchronizerImpl | private |
discardBlock(const primitives::BlockHash &block) | kagome::network::SynchronizerImpl | private |
entries_ | kagome::network::SynchronizerImpl | private |
Error enum name | kagome::network::SynchronizerImpl | |
findCommonBlock(const libp2p::peer::PeerId &peer_id, primitives::BlockNumber lower, primitives::BlockNumber upper, primitives::BlockNumber hint, SyncResultHandler &&handler, std::map< primitives::BlockNumber, primitives::BlockHash > &&observed={}) | kagome::network::SynchronizerImpl | |
generations_ | kagome::network::SynchronizerImpl | private |
hasher_ | kagome::network::SynchronizerImpl | private |
hasIncompleteRequestOfStateSync() const override | kagome::network::SynchronizerImpl | inlinevirtual |
JustificationPair typedef | kagome::network::SynchronizerImpl | private |
justifications_ | kagome::network::SynchronizerImpl | private |
justifications_mutex_ | kagome::network::SynchronizerImpl | private |
kMaxDistanceToBlockForSubscription | kagome::network::SynchronizerImpl | static |
kMinPreloadedBlockAmount | kagome::network::SynchronizerImpl | static |
kMinPreloadedBlockAmountForFastSyncing | kagome::network::SynchronizerImpl | static |
known_blocks_ | kagome::network::SynchronizerImpl | private |
kRecentnessDuration | kagome::network::SynchronizerImpl | static |
loadBlocks(const libp2p::peer::PeerId &peer_id, primitives::BlockInfo from, SyncResultHandler &&handler) | kagome::network::SynchronizerImpl | |
loadJustifications(const libp2p::peer::PeerId &peer_id, primitives::BlockInfo target_block, std::optional< uint32_t > limit, SyncResultHandler &&handler) | kagome::network::SynchronizerImpl | |
log_ | kagome::network::SynchronizerImpl | private |
metric_import_queue_length_ | kagome::network::SynchronizerImpl | private |
metrics_registry_ | kagome::network::SynchronizerImpl | private |
node_is_shutting_down_ | kagome::network::SynchronizerImpl | private |
notifySubscribers(const primitives::BlockInfo &block_info, outcome::result< void > res) | kagome::network::SynchronizerImpl | private |
prepare() | kagome::network::SynchronizerImpl | |
prune(const primitives::BlockInfo &finalized_block) | kagome::network::SynchronizerImpl | private |
recent_requests_ | kagome::network::SynchronizerImpl | private |
router_ | kagome::network::SynchronizerImpl | private |
scheduler_ | kagome::network::SynchronizerImpl | private |
scheduleRecentRequestRemoval(const libp2p::peer::PeerId &peer_id, const BlocksRequest::Fingerprint &fingerprint) | kagome::network::SynchronizerImpl | private |
serializer_ | kagome::network::SynchronizerImpl | private |
start() | kagome::network::SynchronizerImpl | |
state_sync_on_block_ | kagome::network::SynchronizerImpl | private |
state_sync_request_ | kagome::network::SynchronizerImpl | private |
state_sync_request_in_progress_ | kagome::network::SynchronizerImpl | private |
stop() | kagome::network::SynchronizerImpl | |
storage_ | kagome::network::SynchronizerImpl | private |
subscribeToBlock(const primitives::BlockInfo &block_info, SyncResultHandler &&handler) | kagome::network::SynchronizerImpl | private |
subscriptions_ | kagome::network::SynchronizerImpl | private |
sync_block_ | kagome::network::SynchronizerImpl | private |
sync_method_ | kagome::network::SynchronizerImpl | private |
syncByBlockHeader(const primitives::BlockHeader &header, const libp2p::peer::PeerId &peer_id, SyncResultHandler &&handler) override | kagome::network::SynchronizerImpl | virtual |
syncByBlockInfo(const primitives::BlockInfo &block_info, const libp2p::peer::PeerId &peer_id, SyncResultHandler &&handler, bool subscribe_to_block) override | kagome::network::SynchronizerImpl | virtual |
SynchronizerImpl(const application::AppConfiguration &app_config, std::shared_ptr< application::AppStateManager > app_state_manager, std::shared_ptr< blockchain::BlockTree > block_tree, std::shared_ptr< storage::changes_trie::ChangesTracker > changes_tracker, std::shared_ptr< consensus::BlockAppender > block_appender, std::shared_ptr< consensus::BlockExecutor > block_executor, std::shared_ptr< storage::trie::TrieSerializer > serializer, std::shared_ptr< storage::trie::TrieStorage > storage, std::shared_ptr< network::Router > router, std::shared_ptr< libp2p::basic::Scheduler > scheduler, std::shared_ptr< crypto::Hasher > hasher, std::shared_ptr< storage::BufferStorage > buffer_storage) | kagome::network::SynchronizerImpl | |
syncMissingJustifications(const PeerId &peer_id, primitives::BlockInfo target_block, std::optional< uint32_t > limit, SyncResultHandler &&handler) override | kagome::network::SynchronizerImpl | virtual |
SyncResultHandler typedef | kagome::network::Synchronizer | |
syncState(const libp2p::peer::PeerId &peer_id, const primitives::BlockInfo &block, SyncResultHandler &&handler) override | kagome::network::SynchronizerImpl | virtual |
telemetry_ | kagome::network::SynchronizerImpl | private |
trie_changes_tracker_ | kagome::network::SynchronizerImpl | private |
watched_blocks_ | kagome::network::SynchronizerImpl | private |
watched_blocks_number_ | kagome::network::SynchronizerImpl | private |
~Synchronizer()=default | kagome::network::Synchronizer | virtual |