X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Fchain%2Fonchaintx.rs;h=fc4805b3391eba3b62a683e947918ca8bd6eab10;hb=79ffc5eac94cb618ff905894d480864384d0764f;hp=9bbc2a4abd2e3e9a852c71e5e1d700d043fd4472;hpb=9bd87e9c9d52782371acd843db863490583e2cf5;p=rust-lightning diff --git a/lightning/src/chain/onchaintx.rs b/lightning/src/chain/onchaintx.rs index 9bbc2a4a..fc4805b3 100644 --- a/lightning/src/chain/onchaintx.rs +++ b/lightning/src/chain/onchaintx.rs @@ -167,7 +167,6 @@ pub struct OnchainTxHandler { onchain_events_awaiting_threshold_conf: Vec, - latest_height: u32, pub(super) secp_ctx: Secp256k1, } @@ -222,7 +221,6 @@ impl OnchainTxHandler { } } } - self.latest_height.write(writer)?; write_tlv_fields!(writer, {}, {}); Ok(()) @@ -289,7 +287,6 @@ impl<'a, K: KeysInterface> ReadableArgs<&'a K> for OnchainTxHandler { }; onchain_events_awaiting_threshold_conf.push(OnchainEventEntry { txid, height, event }); } - let latest_height = Readable::read(reader)?; read_tlv_fields!(reader, {}, {}); @@ -307,7 +304,6 @@ impl<'a, K: KeysInterface> ReadableArgs<&'a K> for OnchainTxHandler { claimable_outpoints, pending_claim_requests, onchain_events_awaiting_threshold_conf, - latest_height, secp_ctx, }) } @@ -326,7 +322,6 @@ impl OnchainTxHandler { pending_claim_requests: HashMap::new(), claimable_outpoints: HashMap::new(), onchain_events_awaiting_threshold_conf: Vec::new(), - latest_height: 0, secp_ctx, } @@ -370,15 +365,11 @@ impl OnchainTxHandler { /// for this channel, provide new relevant on-chain transactions and/or new claim requests. /// Formerly this was named `block_connected`, but it is now also used for claiming an HTLC output /// if we receive a preimage after force-close. - pub(crate) fn update_claims_view(&mut self, txn_matched: &[&Transaction], requests: Vec, latest_height: Option, broadcaster: &B, fee_estimator: &F, logger: &L) + pub(crate) fn update_claims_view(&mut self, txn_matched: &[&Transaction], requests: Vec, height: u32, broadcaster: &B, fee_estimator: &F, logger: &L) where B::Target: BroadcasterInterface, F::Target: FeeEstimator, L::Target: Logger, { - let height = match latest_height { - Some(h) => h, - None => self.latest_height, - }; log_trace!(logger, "Updating claims view at height {} with {} matched transactions and {} claim requests", height, txn_matched.len(), requests.len()); let mut preprocessed_requests = Vec::with_capacity(requests.len()); let mut aggregated_request = None;