ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-12-01 09:05:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

clear out keys buffer in postgres. Fix postgres schema

Browse Source
This commit is contained in:
CJ Cobb
2021-06-01 15:10:14 +00:00
parent 9a4949263e
commit 46d4ee4548
4 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
reporting/BackendIndexer.cpp
View File

@@ -52,15 +52,22 @@ BackendIndexer::doKeysRepair(
// warning only shows up on the first page
if (!warning)
{
BOOST_LOG_TRIVIAL(debug)
<< __func__ << " flag ledger already written. returning";
BOOST_LOG_TRIVIAL(info)
<< __func__ << " - " << std::to_string(*sequence)
<< " flag ledger already written. returning";
return;
}
else
{
BOOST_LOG_TRIVIAL(info)
<< __func__ << " - " << std::to_string(*sequence)
<< " flag ledger not written. recursing..";
uint32_t lower = (*sequence - 1) >> keyShift_ << keyShift_;
doKeysRepair(backend, lower);
writeKeyFlagLedgerAsync(lower, backend);
BOOST_LOG_TRIVIAL(info)
<< __func__ << " - " << std::to_string(*sequence)
<< " finished recursing. submitting repair ";
writeKeyFlagLedgerAsync(*sequence, backend);
return;
}
}

2
reporting/Pg.cpp
View File

@@ -965,8 +965,6 @@ CREATE OR REPLACE RULE account_transactions_update_protect AS ON UPDATE TO
account_transactions DO INSTEAD NOTHING;
CREATE OR REPLACE RULE objects_update_protect AS ON UPDATE TO
objects DO INSTEAD NOTHING;
CREATE OR REPLACE RULE books_update_protect AS ON UPDATE TO
books DO INSTEAD NOTHING;
-- Return the earliest ledger sequence intended for range operations

2
reporting/PostgresBackend.cpp
View File

@@ -697,6 +697,8 @@ PostgresBackend::writeKeys(
{
if (numRows > 0)
conn.bulkInsert("keys", buffer.str());
std::stringstream temp;
buffer.swap(temp);
conn("COMMIT");
}
return true;

2
reporting/ReportingETL.cpp
View File

@@ -69,7 +69,7 @@ ReportingETL::insertTransactions(
auto metaSerializer = std::make_shared<ripple::Serializer>(
txMeta.getAsObject().getSerializer());
BOOST_LOG_TRIVIAL(debug)
BOOST_LOG_TRIVIAL(trace)
<< __func__ << " : "
<< "Inserting transaction = " << sttx.getTransactionID();