pub struct BankForks {
    banks: HashMap<Slot, Arc<Bank>>,
    descendants: HashMap<Slot, HashSet<Slot>>,
    root: Arc<AtomicSlot>,
    pub snapshot_config: Option<SnapshotConfig>,
    pub accounts_hash_interval_slots: Slot,
    last_accounts_hash_slot: Slot,
    in_vote_only_mode: Arc<AtomicBool>,
}

Fields§

§banks: HashMap<Slot, Arc<Bank>>§descendants: HashMap<Slot, HashSet<Slot>>§root: Arc<AtomicSlot>§snapshot_config: Option<SnapshotConfig>§accounts_hash_interval_slots: Slot§last_accounts_hash_slot: Slot§in_vote_only_mode: Arc<AtomicBool>

Implementations§

source§

impl BankForks

source

pub fn new(bank: Bank) -> Self

source

pub fn banks(&self) -> HashMap<Slot, Arc<Bank>>

source

pub fn get_vote_only_mode_signal(&self) -> Arc<AtomicBool>

source

pub fn len(&self) -> usize

source

pub fn is_empty(&self) -> bool

source

pub fn ancestors(&self) -> HashMap<Slot, HashSet<Slot>>

Create a map of bank slot id to the set of ancestors for the bank slot.

source

pub fn descendants(&self) -> HashMap<Slot, HashSet<Slot>>

Create a map of bank slot id to the set of all of its descendants

source

pub fn frozen_banks(&self) -> HashMap<Slot, Arc<Bank>>

source

pub fn active_bank_slots(&self) -> Vec<Slot>

source

pub fn get(&self, bank_slot: Slot) -> Option<Arc<Bank>>

source

pub fn get_with_checked_hash( &self, (bank_slot, expected_hash): (Slot, Hash) ) -> Option<Arc<Bank>>

source

pub fn bank_hash(&self, slot: Slot) -> Option<Hash>

source

pub fn root_bank(&self) -> Arc<Bank>

source

pub fn new_from_banks(initial_forks: &[Arc<Bank>], root: Slot) -> Self

source

pub fn insert(&mut self, bank: Bank) -> Arc<Bank>

source

pub fn remove(&mut self, slot: Slot) -> Option<Arc<Bank>>

source

pub fn highest_slot(&self) -> Slot

source

pub fn working_bank(&self) -> Arc<Bank>

source

fn do_set_root_return_metrics( &mut self, root: Slot, accounts_background_request_sender: &AbsRequestSender, highest_confirmed_root: Option<Slot> ) -> (Vec<Arc<Bank>>, SetRootMetrics)

source

pub fn set_root( &mut self, root: Slot, accounts_background_request_sender: &AbsRequestSender, highest_confirmed_root: Option<Slot> ) -> Vec<Arc<Bank>>

source

pub fn root(&self) -> Slot

source

pub fn get_atomic_root(&self) -> ReadOnlyAtomicSlot

Gets a read-only wrapper to an atomic slot holding the root slot.

source

fn prune_non_rooted( &mut self, root: Slot, highest_confirmed_root: Option<Slot> ) -> (Vec<Arc<Bank>>, u64, u64)

After setting a new root, prune the banks that are no longer on rooted paths

Given the following banks and slots…

slot 6                   * (G)
                        /
slot 5        (F)  *   /
                   |  /
slot 4    (E) *    | /
              |    |/
slot 3        |    * (D) <-- root, from set_root()
              |    |
slot 2    (C) *    |
               \   |
slot 1          \  * (B)
                 \ |
slot 0             * (A)  <-- highest confirmed root [1]

…where (D) is set as root, clean up (C) and (E), since they are not rooted.

(A) is kept because it is greater-than-or-equal-to the highest confirmed root, and (D) is one of its descendants (B) is kept for the same reason as (A) (C) is pruned since it is a lower slot than (D), but (D) is not one of its descendants (D) is kept since it is the root (E) is pruned since it is not a descendant of (D) (F) is kept since it is a descendant of (D) (G) is kept for the same reason as (F)

and in table form…

      |          |  is root a  | is a descendant ||
 slot | is root? | descendant? |    of root?     || keep?
------+----------+-------------+-----------------++-------
  (A) |     N    |      Y      |        N        ||   Y
  (B) |     N    |      Y      |        N        ||   Y
  (C) |     N    |      N      |        N        ||   N
  (D) |     Y    |      N      |        N        ||   Y
  (E) |     N    |      N      |        N        ||   N
  (F) |     N    |      N      |        Y        ||   Y
  (G) |     N    |      N      |        Y        ||   Y

[1] RPC has the concept of commitment level, which is based on the highest confirmed root, i.e. the cluster-confirmed root. This commitment is stronger than the local node’s root. So (A) and (B) are kept to facilitate RPC at different commitment levels. Everything below the highest confirmed root can be pruned.

source

pub fn set_snapshot_config(&mut self, snapshot_config: Option<SnapshotConfig>)

source

pub fn set_accounts_hash_interval_slots(&mut self, accounts_interval_slots: u64)

source

fn should_request_epoch_accounts_hash(&self, bank: &Bank) -> bool

Determine if this bank should request an epoch accounts hash

Trait Implementations§

source§

impl ForkGraph for BankForks

source§

fn relationship(&self, a: Slot, b: Slot) -> BlockRelation

Returns the BlockRelation of A to B
source§

impl Index<u64> for BankForks

§

type Output = Arc<Bank>

The returned type after indexing.
source§

fn index(&self, bank_slot: Slot) -> &Self::Output

Performs the indexing (container[index]) operation. Read more

Auto Trait Implementations§

Blanket Implementations§

source§

impl<T> AbiExample for T

source§

default fn example() -> T

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

§

impl<T> Pointable for T

§

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more