Function readNewBlock

tools/parser/block_processor.cpp:214–276

Process single block and its transactions */

/** Process single block and its transactions */
blocksci::RawBlock readNewBlock(uint32_t firstTxNum, uint64_t firstInputNum, uint64_t firstOutputNum, const BlockInfoBase &block, BlockFileReaderBase &fileReader, NewBlocksFiles &files, const std::function<bool(RawTransaction *&tx)> &loadFunc, const std::function<void(RawTransaction *tx)> &outFunc, bool isSegwit) {
    std::vector<unsigned char> coinbase;
    blocksci::uint256 nullHash;
    nullHash.SetNull();
    uint32_t headerSize = 80 + variableLengthIntSize(block.nTx);
    uint32_t baseSize = headerSize;
    uint32_t realSize = headerSize;
    uint32_t inputCount = 0;
    uint32_t outputCount = 0;

    // Iterate over all transactions of the current block
    for (uint32_t j = 0; j < block.nTx; j++) {
        RawTransaction *tx = nullptr;

        // Try to re-use memory from transactions that have passed the entire queue
        if (!loadFunc(tx)) {
            // No tx is currently available in finished_transaction_queue -> allocate new memory
            tx = new RawTransaction();
        } else {
            // loadFunc(tx) set the pointer tx to memory from a finished RawTransaction -> reuse that space
            assert(tx);
            fileReader.receivedFinishedTx(tx);
        }

        // Read next transaction into tx
        fileReader.nextTx(tx, isSegwit);

        // For every tx, write blockchain-wide number of the first tx input and output to file (FixedSizeFileMapper<uint64_t>)
        files.txFirstInput.write(firstInputNum + inputCount);
        files.txFirstOutput.write(firstOutputNum + outputCount);

        // Write tx version to file (FixedSizeFileMapper<int32_t>)
        files.txVersionFile.write(tx->version);

        // If transaction is a coinbase transaction, extract and assign coinbase data
        if (tx->inputs.size() == 1 && tx->inputs[0].rawOutputPointer.hash == nullHash) {
            auto scriptView = tx->inputs[0].getScriptView();
            coinbase.assign(scriptView.begin(), scriptView.end());
            tx->inputs.clear();  // do not store inputs for coinbase transactions
        }

        for (auto &input : tx->inputs) {
            // Write blockchain's sequence number field to file (FixedSizeFileMapper<uint32_t>)
            files.inputSequenceFile.write(input.sequenceNum);

            // Write the tx-internal output number of the spent output to file (FixedSizeFileMapper<uint16_t>)
            files.inputSpentOutNumFile.write(input.rawOutputPointer.outputNum);
        }
        
        inputCount += tx->inputs.size();
        outputCount += tx->outputs.size();
        baseSize += tx->baseSize;
        realSize += tx->realSize;

        // add tx to the queue of the first step of the processing pipeline
        outFunc(tx);
    }