Skip to content

Commit 416cb4c

Browse files
committed
Update comment to be more accurate
Following #174 (comment)
1 parent 4c72b9f commit 416cb4c

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

src/elements/asset.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -531,7 +531,7 @@ fn chain_asset_stats_delta<T>(
531531
.history_iter_scan(b'I', &asset_id.into_inner()[..], start_height)
532532
.map(TxHistoryRow::from_row)
533533
.filter_map(|history| {
534-
// skip over entries that point to non-existing heights (may happen during reorg handling)
534+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
535535
let header = headers.header_by_height(history.key.confirmed_height as usize)?;
536536
Some((history, BlockId::from(header)))
537537
});

src/new_index/schema.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -628,7 +628,7 @@ impl ChainQuery {
628628
Some(_) => 1, // skip the last_seen_txid itself
629629
None => 0,
630630
})
631-
// skip over entries that point to non-existing heights (may happen during reorg handling)
631+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
632632
.filter_map(|(txid, height)| Some((txid, headers.header_by_height(height)?)))
633633
.take(limit);
634634

@@ -660,7 +660,7 @@ impl ChainQuery {
660660
.map(TxHistoryRow::from_row)
661661
.map(|row| (row.get_txid(), row.key.confirmed_height as usize))
662662
.unique()
663-
// skip over entries that point to non-existing heights (may happen during reorg handling)
663+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
664664
.filter_map(|(txid, height)| Some((txid, headers.header_by_height(height)?.into())))
665665
.take(limit)
666666
.collect()
@@ -739,7 +739,7 @@ impl ChainQuery {
739739
let history_iter = self
740740
.history_iter_scan(b'H', scripthash, start_height)
741741
.map(TxHistoryRow::from_row)
742-
// skip over entries that point to non-existing heights (may happen during reorg handling)
742+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
743743
.filter_map(|history| {
744744
let header = headers.header_by_height(history.key.confirmed_height as usize)?;
745745
Some((history, BlockId::from(header)))
@@ -819,7 +819,7 @@ impl ChainQuery {
819819
let history_iter = self
820820
.history_iter_scan(b'H', scripthash, start_height)
821821
.map(TxHistoryRow::from_row)
822-
// skip over entries that point to non-existing heights (may happen during reorg handling)
822+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
823823
.filter_map(|history| {
824824
let header = headers.header_by_height(history.key.confirmed_height as usize)?;
825825
Some((history, BlockId::from(header)))
@@ -1026,7 +1026,7 @@ impl ChainQuery {
10261026
let _timer = self.start_timer("lookup_spend");
10271027
let edge = TxEdgeValue::from_bytes(&self.store.history_db.get(&TxEdgeRow::key(outpoint))?);
10281028
let headers = self.store.indexed_headers.read().unwrap();
1029-
// skip entries that point to non-existing heights (may happen during reorg handling)
1029+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
10301030
let header = headers.header_by_height(edge.spending_height as usize)?;
10311031
Some(SpendingInput {
10321032
txid: deserialize(&edge.spending_txid).expect("failed to parse Txid"),
@@ -1045,7 +1045,7 @@ impl ChainQuery {
10451045
.zip(outpoints)
10461046
.filter_map(|(edge_val, outpoint)| {
10471047
let edge = TxEdgeValue::from_bytes(&edge_val.unwrap()?);
1048-
// skip over entries that point to non-existing heights (may happen during reorg handling)
1048+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
10491049
let header = headers.header_by_height(edge.spending_height as usize)?;
10501050
Some((
10511051
outpoint,
@@ -1064,7 +1064,7 @@ impl ChainQuery {
10641064
let row_value = self.store.history_db.get(&TxConfRow::key(txid))?;
10651065
let height = TxConfRow::height_from_val(&row_value);
10661066
let headers = self.store.indexed_headers.read().unwrap();
1067-
// skip entries that point to non-existing heights (may happen during reorg handling)
1067+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
10681068
Some(headers.header_by_height(height as usize)?.into())
10691069
}
10701070

@@ -1235,7 +1235,7 @@ pub fn lookup_confirmations(
12351235
.zip(txids)
12361236
.filter_map(|(res, txid)| {
12371237
let confirmation_height = u32::from_le_bytes(res.unwrap()?.try_into().unwrap());
1238-
// skip over entries that point to non-existing heights (may happen during reorg handling)
1238+
// skip over entries that point to non-existing heights (may happen while new/reorged blocks are being processed)
12391239
(confirmation_height <= tip_height).then_some((txid, confirmation_height))
12401240
})
12411241
.collect()

0 commit comments

Comments
 (0)