blockfilterindex.h

Go to the documentation of this file.

// Copyright (c) 2018 The Bitcoin Core developers
// Distributed under the MIT software license, see the accompanying
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
 
#ifndef BITCOIN_INDEX_BLOCKFILTERINDEX_H
#define BITCOIN_INDEX_BLOCKFILTERINDEX_H
 
#include <blockfilter.h>
#include <chain.h>
#include <flatfile.h>
#include <index/base.h>
#include <util/hasher.h>
 
static const char *const DEFAULT_BLOCKFILTERINDEX = "0";
 
static constexpr int CFCHECKPT_INTERVAL = 1000;
 
class BlockFilterIndex final : public BaseIndex {
private:
    BlockFilterType m_filter_type;
    std::string m_name;
    std::unique_ptr<BaseIndex::DB> m_db;
 
    FlatFilePos m_next_filter_pos;
    std::unique_ptr<FlatFileSeq> m_filter_fileseq;
 
    bool ReadFilterFromDisk(const FlatFilePos &pos, BlockFilter &filter) const;
    size_t WriteFilterToDisk(FlatFilePos &pos, const BlockFilter &filter);
 
    Mutex m_cs_headers_cache;
    std::unordered_map<BlockHash, uint256, FilterHeaderHasher>
        m_headers_cache GUARDED_BY(m_cs_headers_cache);
 
    bool AllowPrune() const override { return true; }
 
protected:
    bool Init() override;
 
    bool CommitInternal(CDBBatch &batch) override;
 
    bool WriteBlock(const CBlock &block, const CBlockIndex *pindex) override;
 
    bool Rewind(const CBlockIndex *current_tip,
                const CBlockIndex *new_tip) override;
 
    BaseIndex::DB &GetDB() const override { return *m_db; }
 
    const char *GetName() const override { return m_name.c_str(); }
 
public:
    explicit BlockFilterIndex(BlockFilterType filter_type, size_t n_cache_size,
                              bool f_memory = false, bool f_wipe = false);
 
    BlockFilterType GetFilterType() const { return m_filter_type; }
 
    bool LookupFilter(const CBlockIndex *block_index,
                      BlockFilter &filter_out) const;
 
    bool LookupFilterHeader(const CBlockIndex *block_index, uint256 &header_out)
        EXCLUSIVE_LOCKS_REQUIRED(!m_cs_headers_cache);
 
    bool LookupFilterRange(int start_height, const CBlockIndex *stop_index,
                           std::vector<BlockFilter> &filters_out) const;
 
    bool LookupFilterHashRange(int start_height, const CBlockIndex *stop_index,
                               std::vector<uint256> &hashes_out) const;
};
 
BlockFilterIndex *GetBlockFilterIndex(BlockFilterType filter_type);
 
void ForEachBlockFilterIndex(std::function<void(BlockFilterIndex &)> fn);
 
bool InitBlockFilterIndex(BlockFilterType filter_type, size_t n_cache_size,
                          bool f_memory = false, bool f_wipe = false);
 
bool DestroyBlockFilterIndex(BlockFilterType filter_type);
 
void DestroyAllBlockFilterIndexes();
 
#endif // BITCOIN_INDEX_BLOCKFILTERINDEX_H