Skip to content

Commit

Permalink
blockchain: simplify/speedup handle_get_objects
Browse files Browse the repository at this point in the history
  • Loading branch information
moneromooo-monero committed Jun 26, 2018
1 parent f025ae9 commit ef2cb63
Showing 1 changed file with 8 additions and 13 deletions.
21 changes: 8 additions & 13 deletions src/cryptonote_core/blockchain.cpp
Expand Up @@ -1633,14 +1633,17 @@ bool Blockchain::handle_get_objects(NOTIFY_REQUEST_GET_OBJECTS::request& arg, NO
std::vector<std::pair<cryptonote::blobdata,block>> blocks; std::vector<std::pair<cryptonote::blobdata,block>> blocks;
get_blocks(arg.blocks, blocks, rsp.missed_ids); get_blocks(arg.blocks, blocks, rsp.missed_ids);


for (const auto& bl: blocks) for (auto& bl: blocks)
{ {
std::vector<crypto::hash> missed_tx_ids; std::vector<crypto::hash> missed_tx_ids;
std::vector<cryptonote::blobdata> txs; std::vector<cryptonote::blobdata> txs;


rsp.blocks.push_back(block_complete_entry());
block_complete_entry& e = rsp.blocks.back();

// FIXME: s/rsp.missed_ids/missed_tx_id/ ? Seems like rsp.missed_ids // FIXME: s/rsp.missed_ids/missed_tx_id/ ? Seems like rsp.missed_ids
// is for missed blocks, not missed transactions as well. // is for missed blocks, not missed transactions as well.
get_transactions_blobs(bl.second.tx_hashes, txs, missed_tx_ids); get_transactions_blobs(bl.second.tx_hashes, e.txs, missed_tx_ids);


if (missed_tx_ids.size() != 0) if (missed_tx_ids.size() != 0)
{ {
Expand All @@ -1657,20 +1660,12 @@ bool Blockchain::handle_get_objects(NOTIFY_REQUEST_GET_OBJECTS::request& arg, NO
return false; return false;
} }


rsp.blocks.push_back(block_complete_entry());
block_complete_entry& e = rsp.blocks.back();
//pack block //pack block
e.block = bl.first; e.block = std::move(bl.first);
//pack transactions
for (const cryptonote::blobdata& tx: txs)
e.txs.push_back(tx);
} }
//get another transactions, if need //get and pack other transactions, if needed
std::vector<cryptonote::blobdata> txs; std::vector<cryptonote::blobdata> txs;
get_transactions_blobs(arg.txs, txs, rsp.missed_ids); get_transactions_blobs(arg.txs, rsp.txs, rsp.missed_ids);
//pack aside transactions
for (const auto& tx: txs)
rsp.txs.push_back(tx);


m_db->block_txn_stop(); m_db->block_txn_stop();
return true; return true;
Expand Down

0 comments on commit ef2cb63

Please sign in to comment.