BlockFilterIndex is used to store and retrieve block filters, hashes, and headers for a range of blocks by height. More...

#include <blockfilterindex.h>

Inheritance diagram for BlockFilterIndex:

[legend]

Collaboration diagram for BlockFilterIndex:

[legend]

Public Member Functions
	BlockFilterIndex (std::unique_ptr< interfaces::Chain > chain, BlockFilterType filter_type, size_t n_cache_size, bool f_memory=false, bool f_wipe=false)
	Constructs the index, which becomes available to be queried. More...

BlockFilterType	GetFilterType () const

bool	LookupFilter (const CBlockIndex *block_index, BlockFilter &filter_out) const
	Get a single filter by block. More...

bool	LookupFilterHeader (const CBlockIndex *block_index, uint256 &header_out) EXCLUSIVE_LOCKS_REQUIRED(!m_cs_headers_cache)
	Get a single filter header by block. More...

bool	LookupFilterRange (int start_height, const CBlockIndex *stop_index, std::vector< BlockFilter > &filters_out) const
	Get a range of filters between two heights on a chain. More...

bool	LookupFilterHashRange (int start_height, const CBlockIndex *stop_index, std::vector< uint256 > &hashes_out) const
	Get a range of filter hashes between two heights on a chain. More...

Public Member Functions inherited from BaseIndex
	BaseIndex (std::unique_ptr< interfaces::Chain > chain, std::string name)

virtual	~BaseIndex ()
	Destructor interrupts sync thread if running and blocks until it exits. More...

const std::string &	GetName () const LIFETIMEBOUND
	Get the name of the index for display in logs. More...

bool BlockUntilSyncedToCurrentChain() const LOCKS_EXCLUDED(void	Interrupt ()
	Blocks the current thread until the index is caught up to the current state of the block chain. More...

bool	Init ()
	Initializes the sync state and registers the instance to the validation interface so that it stays in sync with blockchain updates. More...

bool	StartBackgroundSync ()
	Starts the initial sync process on a background thread. More...

void	Sync ()
	Sync the index with the block index starting from the current best block. More...

void	Stop ()
	Stops the instance from staying in sync with blockchain updates. More...

IndexSummary	GetSummary () const
	Get a summary of the index and its state. More...

Protected Member Functions
bool	CustomInit (const std::optional< interfaces::BlockRef > &block) override
	Initialize internal state from the database and block index. More...

bool	CustomCommit (CDBBatch &batch) override
	Virtual method called internally by Commit that can be overridden to atomically commit more index state. More...

bool	CustomAppend (const interfaces::BlockInfo &block) override
	Write update index entries for a newly connected block. More...

bool	CustomRewind (const interfaces::BlockRef &current_tip, const interfaces::BlockRef &new_tip) override
	Rewind index to an earlier chain tip during a chain reorg. More...

BaseIndex::DB &	GetDB () const LIFETIMEBOUND override

Protected Member Functions inherited from BaseIndex
void	BlockConnected (ChainstateRole role, const std::shared_ptr< const CBlock > &block, const CBlockIndex *pindex) override
	Notifies listeners of a block being connected. More...

void	ChainStateFlushed (ChainstateRole role, const CBlockLocator &locator) override
	Notifies listeners of the new active block chain on-disk. More...

virtual bool	CustomInit (const std::optional< interfaces::BlockRef > &block)
	Initialize internal state from the database and block index. More...

virtual bool	CustomAppend (const interfaces::BlockInfo &block)
	Write update index entries for a newly connected block. More...

virtual bool	CustomCommit (CDBBatch &batch)
	Virtual method called internally by Commit that can be overridden to atomically commit more index state. More...

virtual bool	CustomRewind (const interfaces::BlockRef &current_tip, const interfaces::BlockRef &new_tip)
	Rewind index to an earlier chain tip during a chain reorg. More...

virtual DB &	GetDB () const =0

void	SetBestBlockIndex (const CBlockIndex *block)
	Update the internal best block index as well as the prune lock. More...

Protected Member Functions inherited from CValidationInterface
	~CValidationInterface ()=default
	Protected destructor so that instances can only be deleted by derived classes. More...

virtual void	UpdatedBlockTip (const CBlockIndex pindexNew, const CBlockIndex pindexFork, bool fInitialDownload)
	Notifies listeners when the block chain tip advances. More...

virtual void	ActiveTipChange (const CBlockIndex &new_tip, bool is_ibd)
	Notifies listeners any time the block chain tip changes, synchronously. More...

virtual void	TransactionAddedToMempool (const NewMempoolTransactionInfo &tx, uint64_t mempool_sequence)
	Notifies listeners of a transaction having been added to mempool. More...

virtual void	TransactionRemovedFromMempool (const CTransactionRef &tx, MemPoolRemovalReason reason, uint64_t mempool_sequence)
	Notifies listeners of a transaction leaving mempool. More...

virtual void	MempoolTransactionsRemovedForBlock (const std::vector< RemovedMempoolTransactionInfo > &txs_removed_for_block, unsigned int nBlockHeight)

virtual void	BlockConnected (ChainstateRole role, const std::shared_ptr< const CBlock > &block, const CBlockIndex *pindex)
	Notifies listeners of a block being connected. More...

virtual void	BlockDisconnected (const std::shared_ptr< const CBlock > &block, const CBlockIndex *pindex)
	Notifies listeners of a block being disconnected Provides the block that was disconnected. More...

virtual void	ChainStateFlushed (ChainstateRole role, const CBlockLocator &locator)
	Notifies listeners of the new active block chain on-disk. More...

virtual void	BlockChecked (const CBlock &, const BlockValidationState &)
	Notifies listeners of a block validation result. More...

virtual void	NewPoWValidBlock (const CBlockIndex *pindex, const std::shared_ptr< const CBlock > &block)
	Notifies listeners that a block which builds directly on our current tip has been received and connected to the headers tree, though not validated yet. More...

Private Member Functions
bool	ReadFilterFromDisk (const FlatFilePos &pos, const uint256 &hash, BlockFilter &filter) const

size_t	WriteFilterToDisk (FlatFilePos &pos, const BlockFilter &filter)

std::unordered_map< uint256, uint256, FilterHeaderHasher > m_headers_cache	GUARDED_BY (m_cs_headers_cache)
	cache of block hash to filter header, to avoid disk access when responding to getcfcheckpt. More...

bool	AllowPrune () const override

bool	Write (const BlockFilter &filter, uint32_t block_height, const uint256 &filter_header)

std::optional< uint256 >	ReadFilterHeader (int height, const uint256 &expected_block_hash)

Private Attributes
BlockFilterType	m_filter_type

std::unique_ptr< BaseIndex::DB >	m_db

FlatFilePos	m_next_filter_pos

std::unique_ptr< FlatFileSeq >	m_filter_fileseq

Mutex	m_cs_headers_cache

uint256	m_last_header {}

Additional Inherited Members
Protected Attributes inherited from BaseIndex
std::unique_ptr< interfaces::Chain >	m_chain

Chainstate *	m_chainstate {nullptr}

const std::string	m_name

Detailed Description

BlockFilterIndex is used to store and retrieve block filters, hashes, and headers for a range of blocks by height.

An index is constructed for each supported filter type with its own database (ie. filter data for different types are stored in separate databases).

This index is used to serve BIP 157 net requests.

Definition at line 29 of file blockfilterindex.h.

Constructor & Destructor Documentation

◆ BlockFilterIndex()

BlockFilterIndex::BlockFilterIndex	(	std::unique_ptr< interfaces::Chain >	chain,
		BlockFilterType	filter_type,
		size_t	n_cache_size,
		bool	f_memory = `false`,
		bool	f_wipe = `false`
	)

explicit

Constructs the index, which becomes available to be queried.

Definition at line 100 of file blockfilterindex.cpp.

Here is the call graph for this function:

Member Function Documentation

◆ AllowPrune()

bool BlockFilterIndex::AllowPrune ( ) const

inlineoverrideprivatevirtual

Implements BaseIndex.

Definition at line 48 of file blockfilterindex.h.

◆ CustomAppend()

bool BlockFilterIndex::CustomAppend ( const interfaces::BlockInfo & block )

overrideprotectedvirtual

Write update index entries for a newly connected block.

Reimplemented from BaseIndex.

Definition at line 251 of file blockfilterindex.cpp.

Here is the call graph for this function:

◆ CustomCommit()

bool BlockFilterIndex::CustomCommit ( CDBBatch & batch )

overrideprotectedvirtual

Virtual method called internally by Commit that can be overridden to atomically commit more index state.

Reimplemented from BaseIndex.

Definition at line 144 of file blockfilterindex.cpp.

Here is the call graph for this function:

◆ CustomInit()

bool BlockFilterIndex::CustomInit ( const std::optional< interfaces::BlockRef > & block )

overrideprotectedvirtual

Initialize internal state from the database and block index.

Reimplemented from BaseIndex.

Definition at line 115 of file blockfilterindex.cpp.

Here is the call graph for this function:

◆ CustomRewind()

bool BlockFilterIndex::CustomRewind	(	const interfaces::BlockRef &	current_tip,
		const interfaces::BlockRef &	new_tip
	)

overrideprotectedvirtual

Rewind index to an earlier chain tip during a chain reorg.

The tip must be an ancestor of the current best block.

Reimplemented from BaseIndex.

Definition at line 319 of file blockfilterindex.cpp.

Here is the call graph for this function:

◆ GetDB()

BaseIndex::DB & BlockFilterIndex::GetDB ( ) const

inlineoverrideprotectedvirtual

Implements BaseIndex.

Definition at line 63 of file blockfilterindex.h.

◆ GetFilterType()

BlockFilterType BlockFilterIndex::GetFilterType ( ) const

inline

Definition at line 70 of file blockfilterindex.h.

Here is the caller graph for this function:

◆ GUARDED_BY()

std::unordered_map< uint256, uint256, FilterHeaderHasher > m_headers_cache BlockFilterIndex::GUARDED_BY ( m_cs_headers_cache )

private

cache of block hash to filter header, to avoid disk access when responding to getcfcheckpt.

◆ LookupFilter()

bool BlockFilterIndex::LookupFilter	(	const CBlockIndex *	block_index,
		BlockFilter &	filter_out
	)		const

Get a single filter by block.

Definition at line 419 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LookupFilterHashRange()

bool BlockFilterIndex::LookupFilterHashRange	(	int	start_height,
		const CBlockIndex *	stop_index,
		std::vector< uint256 > &	hashes_out
	)		const

Get a range of filter hashes between two heights on a chain.

Definition at line 479 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LookupFilterHeader()

bool BlockFilterIndex::LookupFilterHeader	(	const CBlockIndex *	block_index,
		uint256 &	header_out
	)

Get a single filter header by block.

Definition at line 429 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ LookupFilterRange()

bool BlockFilterIndex::LookupFilterRange	(	int	start_height,
		const CBlockIndex *	stop_index,
		std::vector< BlockFilter > &	filters_out
	)		const

Get a range of filters between two heights on a chain.

Definition at line 459 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReadFilterFromDisk()

bool BlockFilterIndex::ReadFilterFromDisk	(	const FlatFilePos &	pos,
		const uint256 &	hash,
		BlockFilter &	filter
	)		const

private

Definition at line 163 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ ReadFilterHeader()

std::optional< uint256 > BlockFilterIndex::ReadFilterHeader	(	int	height,
		const uint256 &	expected_block_hash
	)

private

Definition at line 235 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Write()

bool BlockFilterIndex::Write	(	const BlockFilter &	filter,
		uint32_t	block_height,
		const uint256 &	filter_header
	)

private

Definition at line 272 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ WriteFilterToDisk()

size_t BlockFilterIndex::WriteFilterToDisk	(	FlatFilePos &	pos,
		const BlockFilter &	filter
	)

private

Definition at line 189 of file blockfilterindex.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ m_cs_headers_cache

Mutex BlockFilterIndex::m_cs_headers_cache

private

Definition at line 41 of file blockfilterindex.h.

◆ m_db

std::unique_ptr<BaseIndex::DB> BlockFilterIndex::m_db

private

Definition at line 33 of file blockfilterindex.h.

◆ m_filter_fileseq

std::unique_ptr<FlatFileSeq> BlockFilterIndex::m_filter_fileseq

private

Definition at line 36 of file blockfilterindex.h.

◆ m_filter_type

BlockFilterType BlockFilterIndex::m_filter_type

private

Definition at line 32 of file blockfilterindex.h.

◆ m_last_header

uint256 BlockFilterIndex::m_last_header {}

private

Definition at line 46 of file blockfilterindex.h.

◆ m_next_filter_pos

FlatFilePos BlockFilterIndex::m_next_filter_pos

private

Definition at line 35 of file blockfilterindex.h.

The documentation for this class was generated from the following files:

src/index/blockfilterindex.h
src/index/blockfilterindex.cpp

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ BlockFilterIndex()

Member Function Documentation

◆ AllowPrune()

◆ CustomAppend()

◆ CustomCommit()

◆ CustomInit()

◆ CustomRewind()

◆ GetDB()

◆ GetFilterType()

◆ GUARDED_BY()

◆ LookupFilter()

◆ LookupFilterHashRange()

◆ LookupFilterHeader()

◆ LookupFilterRange()

◆ ReadFilterFromDisk()

◆ ReadFilterHeader()

◆ Write()

◆ WriteFilterToDisk()

Member Data Documentation

◆ m_cs_headers_cache

◆ m_db

◆ m_filter_fileseq

◆ m_filter_type

◆ m_last_header

◆ m_next_filter_pos