Struct ChainStateViewReadGuard 

pub struct ChainStateViewReadGuard<S: Storage>(/* private fields */);

A read guard providing access to a chain’s ChainStateView.

Holds a read lock on the chain worker state, preventing writes for its lifetime. The OwnedRwLockReadGuard internally holds a strong Arc reference to the RwLock<ChainWorkerState>, keeping the state alive. Dereferences to ChainStateView.

Methods from Deref<Target = ChainStateView<S::Context>>

pub async fn execution_state( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&ExecutionStateView<C>, Error>

pub async fn tip_state( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, ChainTipState>, Error>

pub async fn manager( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&ChainManager<C>, Error>

pub async fn pending_validated_blobs( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&PendingBlobsView<C>, Error>

pub async fn pending_proposed_blobs( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&ReentrantCollectionView<C, AccountOwner, PendingBlobsView<C>>, Error>

pub async fn block_hashes( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&CustomMapView<C, BlockHeight, CryptoHash>, Error>

pub async fn received_log( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&LogView<C, ChainAndHeight>, Error>

pub async fn received_certificate_trackers( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, HashMap<Secp256k1PublicKey, u64>>, Error>

pub async fn inboxes( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&ReentrantCollectionView<C, ChainId, InboxStateView<C>>, Error>

pub async fn outboxes( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&ReentrantCollectionView<C, ChainId, OutboxStateView<C>>, Error>

pub async fn next_expected_events( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&MapView<C, StreamId, u32>, Error>

pub async fn outbox_counters( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, NonCanonicalBTreeMap<BlockHeight, u32>>, Error>

pub async fn nonempty_outboxes( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, BTreeSet<ChainId>>, Error>

pub async fn nonempty_inboxes( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, BTreeSet<ChainId>>, Error>

pub async fn block_zero_executed_at( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, Timestamp>, Error>

pub async fn next_height_to_preprocess( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, BlockHeight>, Error>

pub async fn latest_checkpoint_height( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, Option<BlockHeight>>, Error>

pub async fn pre_checkpoint_block_trust( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&SetView<C, CryptoHash>, Error>

pub async fn outbox_index_tracked_hash( &self, ctx: &ContextBase<'_, &Positioned<Field>>, ) -> Result<&RegisterView<C, Option<CryptoHash>>, Error>

pub fn chain_id(&self) -> ChainId

Returns the ChainId of the chain this ChainStateView represents.

pub fn all_messages_delivered_up_to(&self, height: BlockHeight) -> bool

Returns true if there are no more outgoing messages in flight up to the given block height.

pub async fn is_active(&self) -> Result<bool, ChainError>

Invariant for the states of active chains.

pub async fn current_committee( &self, ) -> Result<(Epoch, Arc<Committee>), ChainError>

pub async fn ownership(&self) -> Result<&ChainOwnership, ChainError>

pub fn nonempty_outbox_chain_ids(&self) -> Vec<ChainId>

Returns the chain IDs of all recipients for which a message is waiting in the outbox.

pub async fn load_outboxes( &self, targets: &[ChainId], ) -> Result<Vec<ReadGuardedView<OutboxStateView<C>>>, ChainError>

Returns the outboxes for the given targets, or an error if any of them are missing.

pub fn outbox_index_is_reconciled( &self, tracked: Option<&Hashed<ChainIdSet>>, ) -> bool

Returns whether the outbox index is already reconciled to tracked (the stored hash matches), so the read-only network-actions path can read it without a write-lock rebuild.

pub async fn collect_unfinalized_heights( &self, ) -> Result<BTreeSet<BlockHeight>, ChainError>

Returns the sorted, deduplicated set of block heights referenced by the on-chain unfinalized_message_blocks map (one entry per height even if multiple bundles at that height are still unfinalized). Used both when building the checkpoint oracle response (to resolve heights to hashes via block_hashes) and on the bootstrap path (to zip with the certified outbox_block_hashes from the response).

pub async fn block_hashes_for_heights( &self, heights: impl IntoIterator<Item = BlockHeight>, ) -> Result<Vec<CryptoHash>, ChainError>

Returns the hashes of all blocks we have at the given heights, in input order. Unknown heights are skipped.

Trait Implementations

impl<S: Storage> Deref for ChainStateViewReadGuard<S>

type Target = ChainStateView<<S as Storage>::Context>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.