ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Small WAL cleanup.

Browse Source
This commit is contained in:
JoelKatz
2013-04-18 16:16:52 -07:00
parent 4f87d95add
commit 51b1cb17a0
1 changed files with 9 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/cpp/database/SqliteDatabase.cpp
View File

@@ -223,17 +223,18 @@ bool SqliteDatabase::setupCheckpointing(JobQueue *q)
void SqliteDatabase::doHook(const char *db, int pages)
{
if (pages < 1024)
if (pages < 1000)
return;
boost::mutex::scoped_lock sl(walMutex);
if (!walRunning)
{
boost::mutex::scoped_lock sl(walMutex);
if (walRunning)
return;
walRunning = true;
if (mWalQ)
mWalQ->addJob(jtWAL, std::string("WAL:") + mHost, boost::bind(&SqliteDatabase::runWal, this));
else
boost::thread(boost::bind(&SqliteDatabase::runWal, this)).detach();
}
if (mWalQ)
mWalQ->addJob(jtWAL, std::string("WAL:") + mHost, boost::bind(&SqliteDatabase::runWal, this));
else
boost::thread(boost::bind(&SqliteDatabase::runWal, this)).detach();
}
void SqliteDatabase::runWal()
@@ -246,7 +247,7 @@ void SqliteDatabase::runWal()
<< sqlite3_db_filename(mConnection, "main") << "): error " << ret;
}
else
cLog(lsTRACE) << "WAL(" << sqlite3_db_filename(mConnection, "main") <<
cLog(lsTRACE) << "WAL(" << sqlite3_db_filename(mConnection, "main") <<
"): frames=" << log << ", written=" << ckpt;
{