ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-11-27 07:05:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

bug fixes

Browse Source
This commit is contained in:
CJ Cobb
2021-02-16 17:35:57 +00:00
parent 5fe031d613
commit 6bda1af3e6
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
reporting/ReportingBackend.cpp
View File

@@ -838,9 +838,9 @@ CassandraFlatMapBackend::open()
query = {};
query << "CREATE TABLE IF NOT EXISTS " << tableName << "account_tx"
<< " ( account blob, seq_idx tuple<bigint, bigint>, "
" hash blob"
" hash blob, "
"PRIMARY KEY "
"(account, seq_idx) WITH "
"(account, seq_idx)) WITH "
"CLUSTERING ORDER BY (seq_idx desc)";
statement = makeStatement(query.str().c_str(), 0);
fut = cass_session_execute(session_.get(), statement);
@@ -1430,7 +1430,7 @@ CassandraFlatMapBackend::open()
cass_future_free(prepare_future);
std::stringstream ss;
ss << "nodestore: error preparing gettoken : " << rc << ", "
ss << "nodestore: error preparing updateLedgerRange : " << rc << ", "
<< cass_error_desc(rc);
BOOST_LOG_TRIVIAL(error) << ss.str();
continue;
@@ -1438,7 +1438,7 @@ CassandraFlatMapBackend::open()
updateLedgerRange_ = cass_future_get_prepared(prepare_future);
query = {};
query << " select header from ledgers where sequence = ?";
query << " select header from " << tableName << "ledgers where sequence = ?";
prepare_future =
cass_session_prepare(session_.get(), query.str().c_str());
@@ -1452,7 +1452,7 @@ CassandraFlatMapBackend::open()
cass_future_free(prepare_future);
std::stringstream ss;
ss << "nodestore: error preparing gettoken : " << rc << ", "
ss << "nodestore: error preparing selectLedgerBySeq : " << rc << ", "
<< cass_error_desc(rc);
BOOST_LOG_TRIVIAL(error) << ss.str();
continue;
@@ -1460,7 +1460,7 @@ CassandraFlatMapBackend::open()
selectLedgerBySeq_ = cass_future_get_prepared(prepare_future);
query = {};
query << " select sequence from ledgers_range where is_latest = true";
query << " select sequence from " << tableName << "ledger_range where is_latest = true";
prepare_future =
cass_session_prepare(session_.get(), query.str().c_str());
@@ -1474,7 +1474,7 @@ CassandraFlatMapBackend::open()
cass_future_free(prepare_future);
std::stringstream ss;
ss << "nodestore: error preparing gettoken : " << rc << ", "
ss << "nodestore: error preparing selectLatestLedger : " << rc << ", "
<< cass_error_desc(rc);
BOOST_LOG_TRIVIAL(error) << ss.str();
continue;

4
reporting/ReportingETL.cpp
View File

@@ -428,13 +428,13 @@ ReportingETL::runETLPipeline(uint32_t startSequence)
if (isStopping())
continue;
auto numTxns = fetchResponse->transactions_list().transactions_size();
auto numObjects = fetchResponse->ledger_objects().objects_size();
auto start = std::chrono::system_clock::now();
auto [lgrInfo, success] = buildNextLedger(*fetchResponse);
auto end = std::chrono::system_clock::now();
auto duration = ((end - start).count()) / 1000000000.0;
auto numTxns = fetchResponse->hashes_list().hashes_size();
auto numObjects = fetchResponse->ledger_objects().objects_size();
BOOST_LOG_TRIVIAL(info)
<< "Load phase of etl : "
<< "Successfully published ledger! Ledger info: "