Differential D8464 Diff 25884 src/index/blockfilterindex.cpp

Changeset View

Standalone View

src/index/blockfilterindex.cpp

Show All 33 Lines
constexpr char DB_FILTER_POS = 'P';		constexpr char DB_FILTER_POS = 'P';

// 16 MiB		// 16 MiB
constexpr unsigned int MAX_FLTR_FILE_SIZE = 0x1000000;		constexpr unsigned int MAX_FLTR_FILE_SIZE = 0x1000000;
/** The pre-allocation chunk size for fltr?????.dat files */		/** The pre-allocation chunk size for fltr?????.dat files */
// 1 MiB		// 1 MiB
constexpr unsigned int FLTR_FILE_CHUNK_SIZE = 0x100000;		constexpr unsigned int FLTR_FILE_CHUNK_SIZE = 0x100000;

		/**
		* Maximum size of the cfheaders cache.
		* We have a limit to prevent a bug in filling this cache
		* potentially turning into an OOM. At 2000 entries, this cache
		* is big enough for a 2,000,000 length block chain, which
		* we should be enough until ~2047.
		*/
		constexpr size_t CF_HEADERS_CACHE_MAX_SZ{2000};

namespace {		namespace {

struct DBVal {		struct DBVal {
uint256 hash;		uint256 hash;
uint256 header;		uint256 header;
FlatFilePos pos;		FlatFilePos pos;

ADD_SERIALIZE_METHODS;		ADD_SERIALIZE_METHODS;
▲ Show 20 Lines • Show All 362 Lines • ▼ Show 20 Lines	bool BlockFilterIndex::LookupFilter(const CBlockIndex *block_index,
if (!LookupOne(*m_db, block_index, entry)) {		if (!LookupOne(*m_db, block_index, entry)) {
return false;		return false;
}		}

return ReadFilterFromDisk(entry.pos, filter_out);		return ReadFilterFromDisk(entry.pos, filter_out);
}		}

bool BlockFilterIndex::LookupFilterHeader(const CBlockIndex *block_index,		bool BlockFilterIndex::LookupFilterHeader(const CBlockIndex *block_index,
uint256 &header_out) const {		uint256 &header_out) {
		LOCK(m_cs_headers_cache);

		bool is_checkpoint{block_index->nHeight % CFCHECKPT_INTERVAL == 0};

		if (is_checkpoint) {
		// Try to find the block in the headers cache if this is a checkpoint
		// height.
		auto header = m_headers_cache.find(block_index->GetBlockHash());
		if (header != m_headers_cache.end()) {
		header_out = header->second;
		return true;
		}
		}

DBVal entry;		DBVal entry;
if (!LookupOne(*m_db, block_index, entry)) {		if (!LookupOne(*m_db, block_index, entry)) {
return false;		return false;
}		}

		if (is_checkpoint && m_headers_cache.size() < CF_HEADERS_CACHE_MAX_SZ) {
		// Add to the headers cache if this is a checkpoint height.
		m_headers_cache.emplace(block_index->GetBlockHash(), entry.header);
		}

header_out = entry.header;		header_out = entry.header;
return true;		return true;
}		}

bool BlockFilterIndex::LookupFilterRange(		bool BlockFilterIndex::LookupFilterRange(
int start_height, const CBlockIndex *stop_index,		int start_height, const CBlockIndex *stop_index,
std::vector<BlockFilter> &filters_out) const {		std::vector<BlockFilter> &filters_out) const {
std::vector<DBVal> entries;		std::vector<DBVal> entries;
▲ Show 20 Lines • Show All 60 Lines • Show Last 20 Lines