kumi/danicoin
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Use MDB_PREV_MULTIPLE

Browse source 
in get_global_output_indices
This commit is contained in:
Howard Chu 2016-01-07 18:29:19 +00:00
parent 7a4755d3a4
commit 02abe3590d
1 changed files with 40 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -2475,22 +2475,51 @@ void BlockchainLMDB::get_output_global_indices(const uint64_t& amount, const std
LOG_PRINT_L1("Index: " << index << " Elems: " << num_elems << " partial results found for get_output_tx_and_index"); LOG_PRINT_L1("Index: " << index << " Elems: " << num_elems << " partial results found for get_output_tx_and_index");
break; break;
} }
while (index >= curcount) if (!curcount && index > num_elems/2)
{ {
TIME_MEASURE_START(db1); mdb_cursor_get(cur, &k, &v, MDB_LAST_DUP);
if (mdb_cursor_get(cur, &k, &v, curcount == 0 ? MDB_GET_MULTIPLE : MDB_NEXT_MULTIPLE) != 0) mdb_cursor_get(cur, &k, &v, MDB_PREV); /* kludge to unset C_EOF */
mdb_cursor_get(cur, &k, &v, MDB_NEXT);
mdb_cursor_get(cur, &k, &v, MDB_GET_MULTIPLE);
curcount = num_elems;
while(1)
{ {
// allow partial results TIME_MEASURE_START(db1);
result = false; int count = v.mv_size / sizeof(uint64_t);
break; curcount -= count;
if (curcount > index)
{
mdb_cursor_get(cur, &k, &v, MDB_PREV_MULTIPLE);
} else
{
blockstart = curcount;
curcount += count;
break;
}
TIME_MEASURE_FINISH(db1);
t_dbmul += db1;
} }
int count = v.mv_size / sizeof(uint64_t); } else
{
while (index >= curcount)
{
TIME_MEASURE_START(db1);
if (mdb_cursor_get(cur, &k, &v, curcount == 0 ? MDB_GET_MULTIPLE : MDB_NEXT_MULTIPLE) != 0)
{
// allow partial results
result = false;
break;
}
blockstart = curcount; int count = v.mv_size / sizeof(uint64_t);
curcount += count;
TIME_MEASURE_FINISH(db1); blockstart = curcount;
t_dbmul += db1; curcount += count;
TIME_MEASURE_FINISH(db1);
t_dbmul += db1;
}
} }
LOG_PRINT_L3("Records returned: " << curcount << " Index: " << index); LOG_PRINT_L3("Records returned: " << curcount << " Index: " << index);