ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2026-06-03 16:56:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #5 from ledhed2222/gw/remove-l-values

Browse Source 
remove l values
This commit is contained in:
ledhed2222
2023-05-05 00:13:16 -04:00
committed by GitHub
parent b8e1d414f5 fca45f3998
commit 646ca2c6d9
1 changed files with 8 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/main.cpp
View File

@@ -25,7 +25,7 @@ wait(boost::asio::steady_timer& timer, std::string const& reason)
static std::vector<NFTsData>
doNFTWrite(
std::vector<NFTsData>&& nfts,
std::vector<NFTsData>& nfts,
Backend::CassandraBackend& backend,
std::string const& tag)
{
@@ -35,19 +35,18 @@ doNFTWrite(
backend.writeNFTs(std::move(nfts));
backend.sync();
BOOST_LOG_TRIVIAL(info) << tag << ": Wrote " << size << " records";
nfts.clear();
return nfts;
return {};
}
static std::vector<NFTsData>
maybeDoNFTWrite(
std::vector<NFTsData>&& nfts,
std::vector<NFTsData>& nfts,
Backend::CassandraBackend& backend,
std::string const& tag)
{
if (nfts.size() < NFT_WRITE_BATCH_SIZE)
return nfts;
return doNFTWrite(std::move(nfts), backend, tag);
return doNFTWrite(nfts, backend, tag);
}
static std::optional<Backend::TransactionAndMetadata>
@@ -209,7 +208,7 @@ doMigration(
std::get<1>(getNFTDataFromTx(txMeta, sttx)).value());
}
toWrite = maybeDoNFTWrite(std::move(toWrite), backend, "TX");
toWrite = maybeDoNFTWrite(toWrite, backend, "TX");
morePages = cass_result_has_more_pages(result);
if (morePages)
@@ -219,7 +218,7 @@ doMigration(
}
cass_statement_free(nftTxQuery);
toWrite = doNFTWrite(std::move(toWrite), backend, "TX");
toWrite = doNFTWrite(toWrite, backend, "TX");
BOOST_LOG_TRIVIAL(info) << "\nDone with transaction loading!\n";
/*
@@ -247,11 +246,11 @@ doMigration(
toWrite.insert(toWrite.end(), objectNFTs.begin(), objectNFTs.end());
}
toWrite = maybeDoNFTWrite(std::move(toWrite), backend, "OBJ");
toWrite = maybeDoNFTWrite(toWrite, backend, "OBJ");
cursor = page.cursor;
} while (cursor.has_value());
toWrite = doNFTWrite(std::move(toWrite), backend, "OBJ");
toWrite = doNFTWrite(toWrite, backend, "OBJ");
BOOST_LOG_TRIVIAL(info) << "\nDone with object loading!\n";
/*