ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-11-04 10:45:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

ensure cache is not evicted before entry is written to db

Browse Source
This commit is contained in:
Richard Holland
2025-02-15 12:05:32 +11:00
parent 693579e01e
commit 60662a0ab6
1 changed files with 23 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/ripple/nodestore/backend/MySQLFactory.cpp
View File

@@ -215,6 +215,7 @@ private:
{
std::chrono::steady_clock::time_point last_access;
size_t size;
bool pending{false};
};
std::map<uint256, CacheEntry> cacheMetadata_;
@@ -272,7 +273,8 @@ private:
std::lock_guard<std::mutex> metadataLock(metadataMutex_);
for (const auto& [hash, metadata] : cacheMetadata_)
{
entries.emplace_back(hash, metadata.last_access);
if (!metadata.pending)
entries.emplace_back(hash, metadata.last_access);
}
}
@@ -449,7 +451,21 @@ private:
}
if (success)
mysql_query(conn->get(), "COMMIT");
{
if (mysql_query(conn->get(), "COMMIT") == 0)
{
// Clear pending flag for successfully written
// entries
std::lock_guard<std::mutex> metadataLock(
metadataMutex_);
for (const auto& op : batch)
{
auto it = cacheMetadata_.find(op.hash);
if (it != cacheMetadata_.end())
it->second.pending = false;
}
}
}
else
mysql_query(conn->get(), "ROLLBACK");
}
@@ -460,6 +476,11 @@ private:
void
queueWrite(uint256 const& hash, std::vector<std::uint8_t> const& data)
{
{
std::lock_guard<std::mutex> metadataLock(metadataMutex_);
auto& entry = cacheMetadata_[hash];
entry.pending = true;
}
std::lock_guard<std::mutex> lock(queueMutex_);
writeQueue_.push({hash, data});
queueCV_.notify_one();