Mirror/brk
1
0
Fork 0
mirror of https://github.com/bitcoinresearchkit/brk.git synced 2026-04-24 06:39:58 -07:00
Code Issues Packages Projects Releases Wiki Activity

global: snapshot

Browse Source
This commit is contained in:
nym21
2026-03-22 12:18:54 +01:00
parent fbff230c86
commit f731f0d9d0
2 changed files with 3 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
crates/brk_indexer/src/lib.rs
View File

@@ -124,7 +124,6 @@ impl Indexer {
(starting_indexes, Some(hash))
}
None => {
// Data inconsistency detected - reset and start fresh
info!("Data inconsistency detected, resetting indexer...");
self.vecs.reset()?;
self.stores.reset()?;
@@ -199,16 +198,12 @@ impl Indexer {
readers: &readers,
};
// 1. Process block metadata
processor.process_block_metadata()?;
// 2. Compute TXIDs (parallel)
let txs = processor.compute_txids()?;
// 2.5 Push block size/weight reusing per-tx sizes from compute_txids
processor.push_block_size_and_weight(&txs)?;
// 3. Process inputs and outputs (parallel)
let (txins_result, txouts_result) = rayon::join(
|| processor.process_inputs(&txs, &mut buffers.txid_prefix_map),
|| processor.process_outputs(),
@@ -220,16 +215,13 @@ impl Indexer {
let input_count = txins.len();
let output_count = txouts.len();
// 4. Collect same-block spent outpoints
BlockProcessor::collect_same_block_spent_outpoints(
&txins,
&mut buffers.same_block_spent,
);
// 5. Check TXID collisions (BIP-30)
processor.check_txid_collisions(&txs)?;
// 6. Finalize outputs/inputs || store tx metadata (parallel)
processor.finalize_and_store_metadata(
txs,
txouts,
@@ -239,7 +231,6 @@ impl Indexer {
&mut buffers.same_block_output_info,
)?;
// 7. Update indexes
processor.update_indexes(tx_count, input_count, output_count);
if is_export_height(height) {