kylefang/bitcoin-indexer
1
0
Fork 0
mirror of https://github.com/alexgo-io/bitcoin-indexer.git synced 2026-01-12 16:52:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: edge case when requests processed out of order

Browse Source
This commit is contained in:
Ludo Galabru
2023-08-24 11:13:01 +02:00
parent a6651b851f
commit a35cea2b54
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
components/ordhook-core/src/core/pipeline/mod.rs
View File

@@ -209,13 +209,13 @@ pub async fn download_and_pipeline_blocks(
// Early "continue"
if inbox.is_empty() {
blocks_processed += ooo_compacted_blocks.len() as u64;
if let Some(ref blocks_tx) = blocks_post_processor_commands_tx {
let _ = blocks_tx.send(PostProcessorCommand::ProcessBlocks(
ooo_compacted_blocks,
vec![],
));
}
blocks_processed += 1;
continue;
}
@@ -229,13 +229,13 @@ pub async fn download_and_pipeline_blocks(
}
if !blocks.is_empty() {
blocks_processed += blocks.len() as u64;
if let Some(ref blocks_tx) = blocks_post_processor_commands_tx {
let _ = blocks_tx.send(PostProcessorCommand::ProcessBlocks(
compacted_blocks,
blocks,
));
}
blocks_processed += 1;
}
}
()