rippled
ripple::NodeStore::DatabaseShardImp Member List

This is the complete list of members for ripple::NodeStore::DatabaseShardImp, including all inherited members.

acquireIndex_ripple::NodeStore::DatabaseShardImpprivate
app_ripple::NodeStore::DatabaseShardImpprivate
asyncFetch(uint256 const &hash, std::uint32_t ledgerSeq, std::function< void(std::shared_ptr< NodeObject > const &)> &&callback)ripple::NodeStore::Databasevirtual
avgShardFileSz_ripple::NodeStore::DatabaseShardImpprivate
backendName_ripple::NodeStore::DatabaseShardImpprivate
callForLedgerSQLByLedgerSeq(LedgerIndex ledgerSeq, std::function< bool(soci::session &session)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
callForLedgerSQLByShardIndex(std::uint32_t const shardIndex, std::function< bool(soci::session &session)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
callForTransactionSQLByLedgerSeq(LedgerIndex ledgerSeq, std::function< bool(soci::session &session)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
callForTransactionSQLByShardIndex(std::uint32_t const shardIndex, std::function< bool(soci::session &session)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
canAdd_ripple::NodeStore::DatabaseShardImpprivate
checkHistoricalPaths(std::lock_guard< std::mutex > const &) constripple::NodeStore::DatabaseShardImpprivate
chooseHistoricalPath(std::lock_guard< std::mutex > const &) constripple::NodeStore::DatabaseShardImpprivate
ctx_ripple::NodeStore::DatabaseShardImpprivate
Database()=deleteripple::NodeStore::Database
Database(Scheduler &scheduler, int readThreads, Section const &config, beast::Journal j)ripple::NodeStore::Database
databaseImporter_ripple::NodeStore::DatabaseShardImpprivate
databaseImportMarker_ripple::NodeStore::DatabaseShardImpprivatestatic
databaseImportStatus_ripple::NodeStore::DatabaseShardImpprivate
DatabaseShard(Scheduler &scheduler, int readThreads, Section const &config, beast::Journal journal)ripple::NodeStore::DatabaseShard
DatabaseShardImp()=deleteripple::NodeStore::DatabaseShardImp
DatabaseShardImp(DatabaseShardImp const &)=deleteripple::NodeStore::DatabaseShardImp
DatabaseShardImp(DatabaseShardImp &&)=deleteripple::NodeStore::DatabaseShardImp
DatabaseShardImp(Application &app, Scheduler &scheduler, int readThreads, beast::Journal j)ripple::NodeStore::DatabaseShardImp
dir_ripple::NodeStore::DatabaseShardImpprivate
doImportDatabase()ripple::NodeStore::DatabaseShardImp
earliestLedgerSeq() const noexceptripple::NodeStore::Database
earliestLedgerSeq_ripple::NodeStore::Databaseprotected
earliestShardIndex() const noexceptripple::NodeStore::Database
earliestShardIndex_ripple::NodeStore::Databaseprotected
fdRequired() constripple::NodeStore::Database
fdRequired_ripple::NodeStore::Databaseprotected
fetchDurationUs_ripple::NodeStore::Databaseprivate
fetchHitCount_ripple::NodeStore::Databaseprotected
fetchLedger(uint256 const &hash, std::uint32_t ledgerSeq) overrideripple::NodeStore::DatabaseShardImpvirtual
fetchNodeObject(uint256 const &hash, std::uint32_t ledgerSeq, FetchReport &fetchReport, bool duplicate) overrideripple::NodeStore::DatabaseShardImpprivatevirtual
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::Databaseprotected
fetchTotalCount_ripple::NodeStore::Databaseprivate
fileSz_ripple::NodeStore::DatabaseShardImpprivate
finalizeShard(std::shared_ptr< Shard > &shard, bool writeSQLite, std::optional< uint256 > const &expectedHash)ripple::NodeStore::DatabaseShardImpprivate
findAcquireIndex(std::uint32_t validLedgerSeq, std::lock_guard< std::mutex > const &)ripple::NodeStore::DatabaseShardImpprivate
firstLedgerSeq(std::uint32_t shardIndex) const noexceptripple::NodeStore::Database
for_each(std::function< void(std::shared_ptr< NodeObject >)> f) overrideripple::NodeStore::DatabaseShardImpprivatevirtual
getCounters() constripple::NodeStore::Databaseprivatevirtual
getCountsJson(Json::Value &obj)ripple::NodeStore::Database
getDatabaseImportSequence() const overrideripple::NodeStore::DatabaseShardImpvirtual
getDatabaseImportStatus() const overrideripple::NodeStore::DatabaseShardImpvirtual
getFetchHitCount() constripple::NodeStore::Database
getFetchSize() constripple::NodeStore::Database
getFetchTotalCount() constripple::NodeStore::Database
getName() const overrideripple::NodeStore::DatabaseShardImpvirtual
getNumTasks() const overrideripple::NodeStore::DatabaseShardImpvirtual
getPreShards() overrideripple::NodeStore::DatabaseShardImpvirtual
getRootDir() const overrideripple::NodeStore::DatabaseShardImpvirtual
getShardInfo() const overrideripple::NodeStore::DatabaseShardImpvirtual
getShardInfo(std::lock_guard< std::mutex > const &) constripple::NodeStore::DatabaseShardImpprivate
getStoreCount() constripple::NodeStore::Database
getStoreSize() constripple::NodeStore::Database
getWriteLoad() const overrideripple::NodeStore::DatabaseShardImpvirtual
haltDatabaseImport_ripple::NodeStore::DatabaseShardImpprivate
historicalPaths_ripple::NodeStore::DatabaseShardImpprivate
importDatabase(Database &source) overrideripple::NodeStore::DatabaseShardImpvirtual
importInternal(Backend &dstBackend, Database &srcDB)ripple::NodeStore::Databaseprotected
importShard(std::uint32_t shardIndex, boost::filesystem::path const &srcDir) overrideripple::NodeStore::DatabaseShardImpvirtual
init() overrideripple::NodeStore::DatabaseShardImpvirtual
init_ripple::NodeStore::DatabaseShardImpprivate
initConfig(std::lock_guard< std::mutex > const &)ripple::NodeStore::DatabaseShardImpprivate
isSameDB(std::uint32_t s1, std::uint32_t s2) overrideripple::NodeStore::DatabaseShardImpvirtual
isStopping() constripple::NodeStore::Database
iterateLedgerSQLsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
iterateLedgerSQLsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
iterateShardsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(Shard &shard)> const &visit)ripple::NodeStore::DatabaseShardImpprivate
iterateShardsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(Shard &shard)> const &visit)ripple::NodeStore::DatabaseShardImpprivate
iterateTransactionSQLsBack(std::optional< std::uint32_t > maxShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
iterateTransactionSQLsForward(std::optional< std::uint32_t > minShardIndex, std::function< bool(soci::session &session, std::uint32_t shardIndex)> const &callback) overrideripple::NodeStore::DatabaseShardImpvirtual
j_ripple::NodeStore::Databaseprotected
lastLedgerSeq(std::uint32_t shardIndex) const noexceptripple::NodeStore::Database
latestShardIndex_ripple::NodeStore::DatabaseShardImpprivate
ledgersPerShard() const noexceptripple::NodeStore::Database
ledgersPerShard_ripple::NodeStore::Databaseprotected
maxHistoricalShards_ripple::NodeStore::DatabaseShardImpprivate
maxLedgers(std::uint32_t shardIndex) const noexceptripple::NodeStore::Database
mutex_ripple::NodeStore::DatabaseShardImpmutableprivate
numHistoricalShards(std::lock_guard< std::mutex > const &lock) constripple::NodeStore::DatabaseShardImpprivate
openFinalLimit_ripple::NodeStore::DatabaseShardImpprivate
operator=(DatabaseShardImp const &)=deleteripple::NodeStore::DatabaseShardImp
operator=(DatabaseShardImp &&)=deleteripple::NodeStore::DatabaseShardImp
PathDesignation enum nameripple::NodeStore::DatabaseShardImpprivate
preparedIndexes_ripple::NodeStore::DatabaseShardImpprivate
prepareForNewShard(std::uint32_t shardIndex, std::uint32_t numHistoricalShards, std::lock_guard< std::mutex > const &lock)ripple::NodeStore::DatabaseShardImpprivate
prepareLedger(std::uint32_t validLedgerSeq) overrideripple::NodeStore::DatabaseShardImpvirtual
prepareShards(std::vector< std::uint32_t > const &shardIndexes) overrideripple::NodeStore::DatabaseShardImpvirtual
read_ripple::NodeStore::Databaseprivate
readCondVar_ripple::NodeStore::Databaseprivate
readLock_ripple::NodeStore::Databasemutableprivate
readStopping_ripple::NodeStore::Databaseprivate
readThreads_ripple::NodeStore::Databaseprivate
relocateOutdatedShards(std::lock_guard< std::mutex > const &lock)ripple::NodeStore::DatabaseShardImpprivate
removeFailedShard(std::shared_ptr< Shard > &shard)ripple::NodeStore::DatabaseShardImpprivate
removePreShard(std::uint32_t shardIndex) overrideripple::NodeStore::DatabaseShardImpvirtual
requestBundle_ripple::NodeStore::Databaseprotected
runningThreads_ripple::NodeStore::Databaseprivate
scheduler_ripple::NodeStore::Databaseprotected
secondLatestShardIndex_ripple::NodeStore::DatabaseShardImpprivate
seqToShardIndex(std::uint32_t ledgerSeq) const noexceptripple::NodeStore::Database
setStored(std::shared_ptr< Ledger const > const &ledger) overrideripple::NodeStore::DatabaseShardImpvirtual
setStoredInShard(std::shared_ptr< Shard > &shard, std::shared_ptr< Ledger const > const &ledger)ripple::NodeStore::DatabaseShardImpprivate
shardBoundaryIndex() constripple::NodeStore::DatabaseShardImpprivate
shards_ripple::NodeStore::DatabaseShardImpprivate
startDatabaseImportThread(std::lock_guard< std::mutex > const &)ripple::NodeStore::DatabaseShardImpprivate
startNodeToShard() overrideripple::NodeStore::DatabaseShardImpvirtual
stop() overrideripple::NodeStore::DatabaseShardImpvirtual
stopNodeToShard() overrideripple::NodeStore::DatabaseShardImpvirtual
store(NodeObjectType type, Blob &&data, uint256 const &hash, std::uint32_t ledgerSeq) overrideripple::NodeStore::DatabaseShardImpvirtual
storeCount_ripple::NodeStore::Databaseprivate
storeDurationUs_ripple::NodeStore::Databaseprivate
storeLedger(std::shared_ptr< Ledger const > const &srcLedger) overrideripple::NodeStore::DatabaseShardImpvirtual
ripple::NodeStore::DatabaseShard::storeLedger(Ledger const &srcLedger, std::shared_ptr< Backend > dstBackend)ripple::NodeStore::Databaseprotected
storeStats(std::uint64_t count, std::uint64_t sz)ripple::NodeStore::Databaseprotected
storeSz_ripple::NodeStore::Databaseprivate
sufficientStorage(std::uint32_t numShards, PathDesignation pathDesignation, std::lock_guard< std::mutex > const &) constripple::NodeStore::DatabaseShardImpprivate
sweep() overrideripple::NodeStore::DatabaseShardImpvirtual
sync() overrideripple::NodeStore::DatabaseShardImpvirtual
taskQueue_ripple::NodeStore::DatabaseShardImpprivate
threadEntry()ripple::NodeStore::Databaseprivate
updateFetchMetrics(uint64_t fetches, uint64_t hits, uint64_t duration)ripple::NodeStore::Databaseprotected
updateFileStats()ripple::NodeStore::DatabaseShardImpprivate
updatePeers(std::lock_guard< std::mutex > const &lock) constripple::NodeStore::DatabaseShardImpprivate
~Database()ripple::NodeStore::Databasevirtual
~DatabaseShardImp()ripple::NodeStore::DatabaseShardImp