Struct BlockDataBuffer 

pub struct BlockDataBuffer { /* private fields */ }

In-memory overlay for not-yet-flushed block data. Consulted before disk by every read of headers/bodies/numbers/receipts/codes/tx-locations.

Held behind Arc<RwLock<Arc<BlockDataBuffer>>> in Store. Readers clone the inner Arc under a brief read lock and then work lock-free; the single writer mutates a clone and RCU-swaps the Arc in. Both critical sections are O(1) pointer operations.

Implementations

impl BlockDataBuffer

pub fn new() -> Self

pub fn insert( &mut self, block: Block, receipts: Vec<Receipt>, codes: Vec<(H256, Code)>, )

Takes ownership of block and moves its header/body into the buffer (the caller hands ownership over the flush channel and drops it right after, so cloning would be pure waste).

pub fn get_header(&self, hash: &BlockHash) -> Option<BlockHeader>

pub fn get_body(&self, hash: &BlockHash) -> Option<BlockBody>

pub fn get_number(&self, hash: &BlockHash) -> Option<BlockNumber>

pub fn get_receipt(&self, hash: &BlockHash, index: u64) -> Option<Receipt>

pub fn get_receipts(&self, hash: &BlockHash) -> Option<Vec<Receipt>>

pub fn get_code(&self, code_hash: &H256) -> Option<Code>

pub fn get_tx_locations( &self, tx_hash: &H256, ) -> Vec<(BlockNumber, BlockHash, u64)>

pub fn flushed_upto(&self) -> BlockNumber

pub fn set_flushed_upto(&mut self, n: BlockNumber)

pub fn flushable(&self) -> Vec<Arc<BufferedBlock>>

All unflushed blocks, ascending by number (deterministic flush order).

pub fn codes_for(&self, hashes: &[BlockHash]) -> Vec<(H256, Code)>

Codes introduced by the given block hashes (for the flush write tx).

pub fn evict_flushed(&mut self, new_flushed_upto: BlockNumber)

Drop all buffered data for blocks with number <= new_flushed_upto and advance the durable marker. Called only after the disk write committed.

Trait Implementations

impl Clone for BlockDataBuffer

fn clone(&self) -> BlockDataBuffer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BlockDataBuffer

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

Formats the value using the given formatter.

impl Default for BlockDataBuffer

fn default() -> Self

Returns the “default value” for a type.