acquireIndex_ | ripple::NodeStore::DatabaseShardImp | private |
app_ | ripple::NodeStore::DatabaseShardImp | private |
asyncFetch(uint256 const &hash, std::uint32_t ledgerSeq, std::function< void(std::shared_ptr< NodeObject > const &)> &&callback) | ripple::NodeStore::Database | virtual |
avgShardFileSz_ | ripple::NodeStore::DatabaseShardImp | private |
backendName_ | ripple::NodeStore::DatabaseShardImp | private |
callForLedgerSQLByLedgerSeq(LedgerIndex ledgerSeq, std::function< bool(soci::session &session)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
callForLedgerSQLByShardIndex(std::uint32_t const shardIndex, std::function< bool(soci::session &session)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
callForTransactionSQLByLedgerSeq(LedgerIndex ledgerSeq, std::function< bool(soci::session &session)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
callForTransactionSQLByShardIndex(std::uint32_t const shardIndex, std::function< bool(soci::session &session)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
canAdd_ | ripple::NodeStore::DatabaseShardImp | private |
checkHistoricalPaths(std::lock_guard< std::mutex > const &) const | ripple::NodeStore::DatabaseShardImp | private |
chooseHistoricalPath(std::lock_guard< std::mutex > const &) const | ripple::NodeStore::DatabaseShardImp | private |
ctx_ | ripple::NodeStore::DatabaseShardImp | private |
Database()=delete | ripple::NodeStore::Database | |
Database(Scheduler &scheduler, int readThreads, Section const &config, beast::Journal j) | ripple::NodeStore::Database | |
databaseImporter_ | ripple::NodeStore::DatabaseShardImp | private |
databaseImportMarker_ | ripple::NodeStore::DatabaseShardImp | privatestatic |
databaseImportStatus_ | ripple::NodeStore::DatabaseShardImp | private |
DatabaseShard(Scheduler &scheduler, int readThreads, Section const &config, beast::Journal journal) | ripple::NodeStore::DatabaseShard | |
DatabaseShardImp()=delete | ripple::NodeStore::DatabaseShardImp | |
DatabaseShardImp(DatabaseShardImp const &)=delete | ripple::NodeStore::DatabaseShardImp | |
DatabaseShardImp(DatabaseShardImp &&)=delete | ripple::NodeStore::DatabaseShardImp | |
DatabaseShardImp(Application &app, Scheduler &scheduler, int readThreads, beast::Journal j) | ripple::NodeStore::DatabaseShardImp | |
dir_ | ripple::NodeStore::DatabaseShardImp | private |
doImportDatabase() | ripple::NodeStore::DatabaseShardImp | |
earliestLedgerSeq() const noexcept | ripple::NodeStore::Database | |
earliestLedgerSeq_ | ripple::NodeStore::Database | protected |
earliestShardIndex() const noexcept | ripple::NodeStore::Database | |
earliestShardIndex_ | ripple::NodeStore::Database | protected |
fdRequired() const | ripple::NodeStore::Database | |
fdRequired_ | ripple::NodeStore::Database | protected |
fetchDurationUs_ | ripple::NodeStore::Database | private |
fetchHitCount_ | ripple::NodeStore::Database | protected |
fetchLedger(uint256 const &hash, std::uint32_t ledgerSeq) override | ripple::NodeStore::DatabaseShardImp | virtual |
fetchNodeObject(uint256 const &hash, std::uint32_t ledgerSeq, FetchReport &fetchReport, bool duplicate) override | ripple::NodeStore::DatabaseShardImp | privatevirtual |
ripple::NodeStore::DatabaseShard::fetchNodeObject(uint256 const &hash, std::uint32_t ledgerSeq=0, FetchType fetchType=FetchType::synchronous, bool duplicate=false) | ripple::NodeStore::Database | |
fetchSz_ | ripple::NodeStore::Database | protected |
fetchTotalCount_ | ripple::NodeStore::Database | private |
fileSz_ | ripple::NodeStore::DatabaseShardImp | private |
finalizeShard(std::shared_ptr< Shard > &shard, bool writeSQLite, std::optional< uint256 > const &expectedHash) | ripple::NodeStore::DatabaseShardImp | private |
findAcquireIndex(std::uint32_t validLedgerSeq, std::lock_guard< std::mutex > const &) | ripple::NodeStore::DatabaseShardImp | private |
firstLedgerSeq(std::uint32_t shardIndex) const noexcept | ripple::NodeStore::Database | |
for_each(std::function< void(std::shared_ptr< NodeObject >)> f) override | ripple::NodeStore::DatabaseShardImp | privatevirtual |
getCounters() const | ripple::NodeStore::Database | privatevirtual |
getCountsJson(Json::Value &obj) | ripple::NodeStore::Database | |
getDatabaseImportSequence() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getDatabaseImportStatus() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getFetchHitCount() const | ripple::NodeStore::Database | |
getFetchSize() const | ripple::NodeStore::Database | |
getFetchTotalCount() const | ripple::NodeStore::Database | |
getName() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getNumTasks() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getPreShards() override | ripple::NodeStore::DatabaseShardImp | virtual |
getRootDir() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getShardInfo() const override | ripple::NodeStore::DatabaseShardImp | virtual |
getShardInfo(std::lock_guard< std::mutex > const &) const | ripple::NodeStore::DatabaseShardImp | private |
getStoreCount() const | ripple::NodeStore::Database | |
getStoreSize() const | ripple::NodeStore::Database | |
getWriteLoad() const override | ripple::NodeStore::DatabaseShardImp | virtual |
haltDatabaseImport_ | ripple::NodeStore::DatabaseShardImp | private |
historicalPaths_ | ripple::NodeStore::DatabaseShardImp | private |
importDatabase(Database &source) override | ripple::NodeStore::DatabaseShardImp | virtual |
importInternal(Backend &dstBackend, Database &srcDB) | ripple::NodeStore::Database | protected |
importShard(std::uint32_t shardIndex, boost::filesystem::path const &srcDir) override | ripple::NodeStore::DatabaseShardImp | virtual |
init() override | ripple::NodeStore::DatabaseShardImp | virtual |
init_ | ripple::NodeStore::DatabaseShardImp | private |
initConfig(std::lock_guard< std::mutex > const &) | ripple::NodeStore::DatabaseShardImp | private |
isSameDB(std::uint32_t s1, std::uint32_t s2) override | ripple::NodeStore::DatabaseShardImp | virtual |
isStopping() const | ripple::NodeStore::Database | |
iterateLedgerSQLsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
iterateLedgerSQLsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
iterateShardsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(Shard &shard)> const &visit) | ripple::NodeStore::DatabaseShardImp | private |
iterateShardsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(Shard &shard)> const &visit) | ripple::NodeStore::DatabaseShardImp | private |
iterateTransactionSQLsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
iterateTransactionSQLsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) override | ripple::NodeStore::DatabaseShardImp | virtual |
j_ | ripple::NodeStore::Database | protected |
lastLedgerSeq(std::uint32_t shardIndex) const noexcept | ripple::NodeStore::Database | |
latestShardIndex_ | ripple::NodeStore::DatabaseShardImp | private |
ledgersPerShard() const noexcept | ripple::NodeStore::Database | |
ledgersPerShard_ | ripple::NodeStore::Database | protected |
maxHistoricalShards_ | ripple::NodeStore::DatabaseShardImp | private |
maxLedgers(std::uint32_t shardIndex) const noexcept | ripple::NodeStore::Database | |
mutex_ | ripple::NodeStore::DatabaseShardImp | mutableprivate |
numHistoricalShards(std::lock_guard< std::mutex > const &lock) const | ripple::NodeStore::DatabaseShardImp | private |
openFinalLimit_ | ripple::NodeStore::DatabaseShardImp | private |
operator=(DatabaseShardImp const &)=delete | ripple::NodeStore::DatabaseShardImp | |
operator=(DatabaseShardImp &&)=delete | ripple::NodeStore::DatabaseShardImp | |
PathDesignation enum name | ripple::NodeStore::DatabaseShardImp | private |
preparedIndexes_ | ripple::NodeStore::DatabaseShardImp | private |
prepareForNewShard(std::uint32_t shardIndex, std::uint32_t numHistoricalShards, std::lock_guard< std::mutex > const &lock) | ripple::NodeStore::DatabaseShardImp | private |
prepareLedger(std::uint32_t validLedgerSeq) override | ripple::NodeStore::DatabaseShardImp | virtual |
prepareShards(std::vector< std::uint32_t > const &shardIndexes) override | ripple::NodeStore::DatabaseShardImp | virtual |
read_ | ripple::NodeStore::Database | private |
readCondVar_ | ripple::NodeStore::Database | private |
readLock_ | ripple::NodeStore::Database | mutableprivate |
readStopping_ | ripple::NodeStore::Database | private |
readThreads_ | ripple::NodeStore::Database | private |
relocateOutdatedShards(std::lock_guard< std::mutex > const &lock) | ripple::NodeStore::DatabaseShardImp | private |
removeFailedShard(std::shared_ptr< Shard > &shard) | ripple::NodeStore::DatabaseShardImp | private |
removePreShard(std::uint32_t shardIndex) override | ripple::NodeStore::DatabaseShardImp | virtual |
requestBundle_ | ripple::NodeStore::Database | protected |
runningThreads_ | ripple::NodeStore::Database | private |
scheduler_ | ripple::NodeStore::Database | protected |
secondLatestShardIndex_ | ripple::NodeStore::DatabaseShardImp | private |
seqToShardIndex(std::uint32_t ledgerSeq) const noexcept | ripple::NodeStore::Database | |
setStored(std::shared_ptr< Ledger const > const &ledger) override | ripple::NodeStore::DatabaseShardImp | virtual |
setStoredInShard(std::shared_ptr< Shard > &shard, std::shared_ptr< Ledger const > const &ledger) | ripple::NodeStore::DatabaseShardImp | private |
shardBoundaryIndex() const | ripple::NodeStore::DatabaseShardImp | private |
shards_ | ripple::NodeStore::DatabaseShardImp | private |
startDatabaseImportThread(std::lock_guard< std::mutex > const &) | ripple::NodeStore::DatabaseShardImp | private |
startNodeToShard() override | ripple::NodeStore::DatabaseShardImp | virtual |
stop() override | ripple::NodeStore::DatabaseShardImp | virtual |
stopNodeToShard() override | ripple::NodeStore::DatabaseShardImp | virtual |
store(NodeObjectType type, Blob &&data, uint256 const &hash, std::uint32_t ledgerSeq) override | ripple::NodeStore::DatabaseShardImp | virtual |
storeCount_ | ripple::NodeStore::Database | private |
storeDurationUs_ | ripple::NodeStore::Database | private |
storeLedger(std::shared_ptr< Ledger const > const &srcLedger) override | ripple::NodeStore::DatabaseShardImp | virtual |
ripple::NodeStore::DatabaseShard::storeLedger(Ledger const &srcLedger, std::shared_ptr< Backend > dstBackend) | ripple::NodeStore::Database | protected |
storeStats(std::uint64_t count, std::uint64_t sz) | ripple::NodeStore::Database | protected |
storeSz_ | ripple::NodeStore::Database | private |
sufficientStorage(std::uint32_t numShards, PathDesignation pathDesignation, std::lock_guard< std::mutex > const &) const | ripple::NodeStore::DatabaseShardImp | private |
sweep() override | ripple::NodeStore::DatabaseShardImp | virtual |
sync() override | ripple::NodeStore::DatabaseShardImp | virtual |
taskQueue_ | ripple::NodeStore::DatabaseShardImp | private |
threadEntry() | ripple::NodeStore::Database | private |
updateFetchMetrics(uint64_t fetches, uint64_t hits, uint64_t duration) | ripple::NodeStore::Database | protected |
updateFileStats() | ripple::NodeStore::DatabaseShardImp | private |
updatePeers(std::lock_guard< std::mutex > const &lock) const | ripple::NodeStore::DatabaseShardImp | private |
~Database() | ripple::NodeStore::Database | virtual |
~DatabaseShardImp() | ripple::NodeStore::DatabaseShardImp | |