mirror of
https://github.com/XRPLF/rippled.git
synced 2026-08-23 15:20:54 +00:00
Merge branch 'develop' into ximinez/online-delete-gaps
This commit is contained in:
@@ -16,14 +16,14 @@ namespace xrpl {
|
||||
void
|
||||
SHAMapStoreImp::SavedStateDB::init(BasicConfig const& config, std::string const& dbName)
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
initStateDB(sqlDb_, config, dbName);
|
||||
}
|
||||
|
||||
LedgerIndex
|
||||
SHAMapStoreImp::SavedStateDB::getCanDelete()
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
|
||||
return xrpl::getCanDelete(sqlDb_);
|
||||
}
|
||||
@@ -31,7 +31,7 @@ SHAMapStoreImp::SavedStateDB::getCanDelete()
|
||||
LedgerIndex
|
||||
SHAMapStoreImp::SavedStateDB::setCanDelete(LedgerIndex canDelete)
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
|
||||
return xrpl::setCanDelete(sqlDb_, canDelete);
|
||||
}
|
||||
@@ -39,7 +39,7 @@ SHAMapStoreImp::SavedStateDB::setCanDelete(LedgerIndex canDelete)
|
||||
SavedState
|
||||
SHAMapStoreImp::SavedStateDB::getState()
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
|
||||
return xrpl::getSavedState(sqlDb_);
|
||||
}
|
||||
@@ -47,14 +47,14 @@ SHAMapStoreImp::SavedStateDB::getState()
|
||||
void
|
||||
SHAMapStoreImp::SavedStateDB::setState(SavedState const& state)
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
xrpl::setSavedState(sqlDb_, state);
|
||||
}
|
||||
|
||||
void
|
||||
SHAMapStoreImp::SavedStateDB::setLastRotated(LedgerIndex seq)
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
xrpl::setLastRotated(sqlDb_, seq);
|
||||
}
|
||||
|
||||
@@ -180,7 +180,7 @@ void
|
||||
SHAMapStoreImp::onLedgerClosed(std::shared_ptr<Ledger const> const& ledger)
|
||||
{
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
newLedger_ = ledger;
|
||||
working_ = true;
|
||||
}
|
||||
@@ -352,7 +352,7 @@ SHAMapStoreImp::run()
|
||||
void
|
||||
SHAMapStoreImp::dbPaths()
|
||||
{
|
||||
Section section{app_.config().section(ConfigSection::nodeDatabase())};
|
||||
Section const section{app_.config().section(ConfigSection::nodeDatabase())};
|
||||
boost::filesystem::path dbPath = get(section, "path");
|
||||
|
||||
if (boost::filesystem::exists(dbPath))
|
||||
@@ -440,7 +440,7 @@ SHAMapStoreImp::dbPaths()
|
||||
}
|
||||
|
||||
// The necessary directories exist. Now, remove any others.
|
||||
for (boost::filesystem::path& p : pathsToDelete)
|
||||
for (boost::filesystem::path const& p : pathsToDelete)
|
||||
boost::filesystem::remove_all(p);
|
||||
}
|
||||
|
||||
@@ -627,7 +627,7 @@ SHAMapStoreImp::stop()
|
||||
if (thread_.joinable())
|
||||
{
|
||||
{
|
||||
std::lock_guard lock(mutex_);
|
||||
std::lock_guard const lock(mutex_);
|
||||
stop_ = true;
|
||||
cond_.notify_one();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user