17 #include <unordered_map> 20 nonce(
GetRand(
std::numeric_limits<uint64_t>::max())),
21 shorttxids(block.vtx.size() - 1), prefilledtxn(1), header(block) {
25 for (
size_t i = 1; i < block.
vtx.size(); i++) {
43 static_assert(
SHORTTXIDS_LENGTH == 6,
"shorttxids calculation assumes 6-byte shorttxids");
59 int32_t lastprefilledindex = -1;
60 for (
size_t i = 0; i < cmpctblock.
prefilledtxn.size(); i++) {
64 lastprefilledindex += cmpctblock.
prefilledtxn[i].index + 1;
65 if (lastprefilledindex > std::numeric_limits<uint16_t>::max())
67 if ((uint32_t)lastprefilledindex > cmpctblock.
shorttxids.size() + i) {
73 txn_available[lastprefilledindex] = cmpctblock.
prefilledtxn[i].tx;
82 uint16_t index_offset = 0;
83 for (
size_t i = 0; i < cmpctblock.
shorttxids.size(); i++) {
84 while (txn_available[i + index_offset])
105 std::vector<bool> have_txn(txn_available.size());
108 for (
size_t i = 0; i < pool->vTxHashes.size(); i++) {
109 uint64_t shortid = cmpctblock.
GetShortID(pool->vTxHashes[i].first);
110 std::unordered_map<uint64_t, uint16_t>::iterator idit =
shorttxids.find(shortid);
112 if (!have_txn[idit->second]) {
113 txn_available[idit->second] = pool->vTxHashes[i].second->GetSharedTx();
114 have_txn[idit->second] =
true;
120 if (txn_available[idit->second]) {
121 txn_available[idit->second].reset();
134 for (
size_t i = 0; i < extra_txn.size(); i++) {
135 uint64_t shortid = cmpctblock.
GetShortID(extra_txn[i].first);
136 std::unordered_map<uint64_t, uint16_t>::iterator idit =
shorttxids.find(shortid);
138 if (!have_txn[idit->second]) {
139 txn_available[idit->second] = extra_txn[i].second;
140 have_txn[idit->second] =
true;
150 if (txn_available[idit->second] &&
151 txn_available[idit->second]->GetWitnessHash() != extra_txn[i].second->GetWitnessHash()) {
152 txn_available[idit->second].reset();
172 assert(index < txn_available.size());
173 return txn_available[index] !=
nullptr;
180 block.
vtx.resize(txn_available.size());
182 size_t tx_missing_offset = 0;
183 for (
size_t i = 0; i < txn_available.size(); i++) {
184 if (!txn_available[i]) {
185 if (vtx_missing.size() <= tx_missing_offset)
187 block.
vtx[i] = vtx_missing[tx_missing_offset++];
189 block.
vtx[i] = std::move(txn_available[i]);
194 txn_available.clear();
196 if (vtx_missing.size() != tx_missing_offset)
210 LogPrint(
BCLog::CMPCTBLOCK,
"Successfully reconstructed block %s with %lu txn prefilled, %lu txn from mempool (incl at least %lu from extra pool) and %lu txn requested\n", hash.ToString(), prefilled_count, mempool_count, extra_count, vtx_missing.size());
211 if (vtx_missing.size() < 5) {
212 for (
const auto& tx : vtx_missing) {
enum ReadStatus_t ReadStatus
CSHA256 & Write(const unsigned char *data, size_t len)
uint64_t SipHashUint256(uint64_t k0, uint64_t k1, const uint256 &val)
Optimized SipHash-2-4 implementation for uint256.
CBlockHeaderAndShortTxIDs()
uint64_t GetRand(uint64_t nMax) noexcept
Generate a uniform random integer in the range [0..range).
ReadStatus FillBlock(CBlock &block, const std::vector< CTransactionRef > &vtx_missing)
#define LogPrint(category,...)
uint64_t GetShortID(const uint256 &txhash) const
Double ended buffer combining vector and stream-like interfaces.
void FillShortTxIDSelector() const
size_t GetSerializeSize(const T &t, int nVersion=0)
static const unsigned int MAX_BLOCK_WEIGHT
The maximum allowed weight for a block, see BIP 141 (network rule)
const uint256 & GetWitnessHash() const
const uint256 & GetHash() const
void Finalize(unsigned char hash[OUTPUT_SIZE])
static constexpr int SHORTTXIDS_LENGTH
std::string ToString() const
bool CheckBlock(const CBlock &block, BlockValidationState &state, const Consensus::Params &consensusParams, bool fCheckPOW, bool fCheckMerkleRoot)
Functions for validating blocks and updating the block tree.
static const size_t MIN_SERIALIZABLE_TRANSACTION_WEIGHT
std::vector< uint64_t > shorttxids
std::vector< CTransactionRef > vtx
the block's data didn't match the data committed to by the PoW
const_iterator end() const
const_iterator begin() const
std::vector< PrefilledTransaction > prefilledtxn
const CChainParams & Params()
Return the currently selected parameters.
static const int PROTOCOL_VERSION
network protocol versioning
bool IsTxAvailable(size_t index) const
ReadStatus InitData(const CBlockHeaderAndShortTxIDs &cmpctblock, const std::vector< std::pair< uint256, CTransactionRef >> &extra_txn)
The basic transaction that is broadcasted on the network and contained in blocks. ...
size_t BlockTxCount() const
A hasher class for SHA-256.
uint64_t GetUint64(int pos) const