mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-21 11:35:53 +00:00
Report the write load for SQLite too.
This commit is contained in:
@@ -243,6 +243,7 @@ bool HashedObjectStore::storeSQLite(HashedObjectType type, uint32 index,
|
|||||||
void HashedObjectStore::bulkWriteSQLite(Job&)
|
void HashedObjectStore::bulkWriteSQLite(Job&)
|
||||||
{
|
{
|
||||||
assert(!mLevelDB);
|
assert(!mLevelDB);
|
||||||
|
int setSize = 0;
|
||||||
while (1)
|
while (1)
|
||||||
{
|
{
|
||||||
std::vector< boost::shared_ptr<HashedObject> > set;
|
std::vector< boost::shared_ptr<HashedObject> > set;
|
||||||
@@ -257,8 +258,11 @@ void HashedObjectStore::bulkWriteSQLite(Job&)
|
|||||||
if (set.empty())
|
if (set.empty())
|
||||||
{
|
{
|
||||||
mWritePending = false;
|
mWritePending = false;
|
||||||
|
mWriteLoad = 0;
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
mWriteLoad = std::max(setSize, static_cast<int>(mWriteSet.size()));
|
||||||
|
setSize = set.size();
|
||||||
}
|
}
|
||||||
// WriteLog (lsTRACE, HashedObject) << "HOS: writing " << set.size();
|
// WriteLog (lsTRACE, HashedObject) << "HOS: writing " << set.size();
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user