monero-project/monero
monero-project/monero
1
0
Fork 0
mirror of https://github.com/monero-project/monero.git synced 2024-11-18 10:01:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

db_lmdb: use MDB_MULTIPLE_NEXT where possible for some speedup

Browse source
This commit is contained in:
moneromooo-monero 2018-10-19 16:46:52 +00:00
parent 5c85da5a73
commit 61304151b4
No known key found for this signature in database
GPG key ID: 686F07454D6CEFC3
1 changed files with 23 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/blockchain_db/lmdb/db_lmdb.cpp
View file

@ -1980,22 +1980,36 @@ std::vector<uint64_t> BlockchainLMDB::get_block_cumulative_rct_outputs(const std
MDB_val v; MDB_val v;
uint64_t prev_height = heights[0]; uint64_t prev_height = heights[0];
uint64_t range_begin = 0, range_end = 0;
for (uint64_t height: heights) for (uint64_t height: heights)
{
if (height >= range_begin && height < range_end)
{
// nohting to do
}
else
{ {
if (height == prev_height + 1) if (height == prev_height + 1)
{ {
MDB_val k2; MDB_val k2;
result = mdb_cursor_get(m_cur_block_info, &k2, &v, MDB_NEXT); result = mdb_cursor_get(m_cur_block_info, &k2, &v, MDB_NEXT_MULTIPLE);
range_begin = ((const mdb_block_info*)v.mv_data)->bi_height;
range_end = range_begin + v.mv_size / sizeof(mdb_block_info); // whole records please
if (height < range_begin || height >= range_end)
throw0(DB_ERROR(("Height " + std::to_string(height) + " not included in multuple record range: " + std::to_string(range_begin) + "-" + std::to_string(range_end)).c_str()));
} }
else else
{ {
v.mv_size = sizeof(uint64_t); v.mv_size = sizeof(uint64_t);
v.mv_data = (void*)&height; v.mv_data = (void*)&height;
result = mdb_cursor_get(m_cur_block_info, (MDB_val *)&zerokval, &v, MDB_GET_BOTH); result = mdb_cursor_get(m_cur_block_info, (MDB_val *)&zerokval, &v, MDB_GET_BOTH);
range_begin = height;
range_end = range_begin + 1;
} }
if (result) if (result)
throw0(DB_ERROR(lmdb_error("Error attempting to retrieve rct distribution from the db: ", result).c_str())); throw0(DB_ERROR(lmdb_error("Error attempting to retrieve rct distribution from the db: ", result).c_str()));
const mdb_block_info *bi = (const mdb_block_info *)v.mv_data; }
const mdb_block_info *bi = ((const mdb_block_info *)v.mv_data) + (height - range_begin);
res.push_back(bi->bi_cum_rct); res.push_back(bi->bi_cum_rct);
prev_height = height; prev_height = height;
} }