Struct MipStore 

pub struct MipStore(pub Arc<RwLock<MipStoreRaw>>);

Database for all MIP info

Tuple Fields

0: Arc<RwLock<MipStoreRaw>>

Implementations

impl MipStore

pub fn get_network_version_current(&self) -> u32

Retrieve the current network version, as the store’s state says right now.

This follows the store’s current state, which only reaches Active once finality has processed the activation slot. Block headers must not use it: see MipStore::get_network_version_active_at.

pub fn get_network_version_active_at(&self, ts: MassaTime) -> u32

Retrieve the last active version at the given timestamp (e.g. a slot’s).

A MIP still LockedIn in this store counts as active at ts once ts > locked_at + activation_delay. That is exactly when LockedIn::on_advance activates it, and every node advances the store on every final slot, so Active.at is always the first slot timestamp past that instant. Answering from the instant rather than from the state means a node whose finality has not yet reached the activation slot agrees with a node that is already Active – and with the version the producer stamped – for every slot. Otherwise the blocks produced during the finality lag carry the old version, and any node that is already Active (e.g. one that just bootstrapped) rejects them.

Requires activation_delay to exceed the finality lag, so that nodes know a MIP is LockedIn before its activation instant (guaranteed on real networks by VERSIONING_ACTIVATION_DELAY_MIN, one cycle).

pub fn get_network_version_to_announce_at(&self, ts: MassaTime) -> Option<u32>

Retrieve the network version to announce in the header of a block at ts.

Same as MipStore::get_network_version_to_announce, except that a MIP already active at ts (see MipStore::get_network_version_active_at) is no longer announced: it is the header’s current version from then on, and announcing it as well would make the header invalid.

pub fn get_network_version_to_announce(&self) -> Option<u32>

Retrieve the network version number to announce in block header return 0 is there is nothing to announce

pub fn update_network_version_stats( &mut self, slot_timestamp: MassaTime, network_versions: Option<(u32, Option<u32>)>, )

pub fn update_with( &mut self, mip_store: &MipStore, ) -> Result<(Vec<MipInfo>, BTreeMap<MipInfo, MipState>), UpdateWithError>

pub fn get_latest_component_version_at( &self, component: &MipComponent, ts: MassaTime, ) -> u32

Get latest version at given timestamp (e.g. slot) for the given MipComponent.

Considers MIPs whose current store state is Active or LockedIn: the LockedIn→Active transition is a pure function of (locked_in_at, activation_delay, ts), so a node still in LockedIn agrees with peers that have already advanced to Active on whether ts is past activation. state_at(ts) remains the gate that decides if the version applies at ts (pre-activation queries while LockedIn still return the previous version).

pub(crate) fn get_all_active_component_versions( &self, component: &MipComponent, ) -> Vec<u32>

Get all versions in ‘Active state’ for the given MipComponent

pub(crate) fn get_all_component_versions( &self, component: &MipComponent, ) -> BTreeMap<u32, ComponentStateTypeId>

Get all versions (at any state) for the given MipComponent

pub fn get_mip_status(&self) -> BTreeMap<MipInfo, ComponentStateTypeId>

Retrieve a list of MIP info with their corresponding state (as id) - used for grpc API

pub fn is_consistent_with_shutdown_period( &self, shutdown_start: Slot, shutdown_end: Slot, thread_count: u8, t0: MassaTime, genesis_timestamp: MassaTime, ) -> Result<(), IsConsistentWithShutdownPeriodError>

pub fn update_for_network_shutdown( &mut self, shutdown_start: Slot, shutdown_end: Slot, thread_count: u8, t0: MassaTime, genesis_timestamp: MassaTime, ) -> Result<(), ModelsError>

pub fn is_key_value_valid( &self, serialized_key: &[u8], serialized_value: &[u8], ) -> bool

pub fn update_batches( &self, db_batch: &mut DBBatch, db_versioning_batch: &mut DBBatch, between: Option<(&MassaTime, &MassaTime)>, ) -> Result<(), SerializeError>

pub fn extend_from_db( &mut self, db: ShareableMassaDBController, ) -> Result<(Vec<MipInfo>, BTreeMap<MipInfo, MipState>), ExtendFromDbError>

pub fn started_mips_missing_from_db( &self, db: &ShareableMassaDBController, at: MassaTime, ) -> Vec<MipInfo>

MIPs of this store that a bootstrap server’s streamed state (db) does not contain, and whose start is at or before at, the timestamp of the bootstrapped final slot.

Such a server runs a release that predates the MIP, so it cannot provide the MIP’s state. Accepting it would leave this node replaying the MIP from its compiled-in Defined state, starting at its own first processed slot: the history it records (and, past lock-in, its activation) would differ from the rest of the network’s, and once the MIP is Active that history is part of the hashed final state. Before start nobody has recorded anything for the MIP yet, so replaying it locally is deterministic and such a server is still usable.

pub fn reset_db(&self, db: ShareableMassaDBController)

pub fn try_from_db( db: ShareableMassaDBController, cfg: MipStatsConfig, ) -> Result<Self, ExtendFromDbError>

Create a MIP store with what is written on the disk

Trait Implementations

impl Clone for MipStore

fn clone(&self) -> MipStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MipStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<const N: usize> TryFrom<([(MipInfo, MipState); N], MipStatsConfig)> for MipStore

type Error = UpdateWithError

The type returned in the event of a conversion error.

fn try_from( (value, cfg): ([(MipInfo, MipState); N], MipStatsConfig), ) -> Result<Self, Self::Error>

Performs the conversion.