ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-11-28 14:35:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

more write debug

Browse Source
This commit is contained in:
Richard Holland
2025-02-17 13:58:25 +11:00
parent 1a8173f3df
commit 84942ce125
1 changed files with 36 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

58
src/ripple/rpc/handlers/Catalogue.cpp
View File

@@ -297,31 +297,45 @@ public:
auto& change = keyChanges[i];
bool hasNext = i < keyChanges.size() - 1;
outfile.write(
reinterpret_cast<const char*>(&change.sequence), 4);
uint32_t flagsAndSize = change.dataSize & SIZE_MASK;
if (hasNext)
flagsAndSize |= HAS_NEXT_FLAG;
outfile.write(reinterpret_cast<const char*>(&flagsAndSize), 4);
if (!change.isDeleted && change.hasDataChange)
// Ensure sequence is in valid range
if (change.sequence < ledgers.front()->info().seq ||
change.sequence > ledgers.back()->info().seq)
{
// Find the ledger with this sequence
size_t ledgerIndex =
change.sequence - ledgers.front()->info().seq;
if (ledgerIndex < ledgers.size())
std::cout << "invalid change sequence: " << change.sequence
<< "\n";
continue; // Skip invalid sequence
}
// Only write anything if there's an actual change
if (change.isDeleted || change.hasDataChange)
{
outfile.write(
reinterpret_cast<const char*>(&change.sequence), 4);
uint32_t flagsAndSize = change.dataSize & SIZE_MASK;
if (hasNext)
flagsAndSize |= HAS_NEXT_FLAG;
outfile.write(
reinterpret_cast<const char*>(&flagsAndSize), 4);
if (change.hasDataChange)
{
auto sle =
ledgers[ledgerIndex]->read(keylet::unchecked(key));
if (sle)
// Find the ledger with this sequence
size_t ledgerIndex =
change.sequence - ledgers.front()->info().seq;
if (ledgerIndex < ledgers.size())
{
Serializer s;
sle->add(s);
auto const& data = s.peekData();
outfile.write(
reinterpret_cast<const char*>(data.data()),
data.size());
auto sle = ledgers[ledgerIndex]->read(
keylet::unchecked(key));
if (sle)
{
Serializer s;
sle->add(s);
auto const& data = s.peekData();
outfile.write(
reinterpret_cast<const char*>(data.data()),
data.size());
}
}
}
}