Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add ChannelContext::get_commitment_stats #3682

Open
wants to merge 4 commits into
base: main
Choose a base branch
from

Conversation

tankyleo
Copy link
Contributor

@tankyleo tankyleo commented Mar 24, 2025

    Add `ChannelContext::get_commitment_stats`
    
    It can be useful to get the stats on a potential commitment transaction
    without actually building it. Therefore, this commit splits the stats
    calculations from the actual build of a commitment transaction.
    
    This introduces an extra loop over the pending htlcs, but current
    network behavior produces very few concurrent htlcs on channels.
    Furthermore, each iteration of the loop in the stats calculation is very
    cheap.

Requested by @wpaulino in #3641

    Rename `CommitmentTransaction::htlcs` to `nondust_htlcs`
    Remove unnecessary clones of the HTLC-HTLCSource table
    Require all HTLC success states to hold their corresponding preimage
    
    This allows us to DRY the code that calculates the
    `value_to_self_msat_offset` in `ChannelContext::build_commitment_stats`.
    
    HTLC success states have held their corresponding preimage since
    0.0.105, and the release notes of 0.1 already require users running
    0.0.123 and earlier to resolve their HTLCs before upgrading to 0.1. So
    this change is fully compatible with existing upgrade paths to
    the yet-to-be-shipped 0.2 release.

@ldk-reviews-bot
Copy link

ldk-reviews-bot commented Mar 24, 2025

👋 Thanks for assigning @wpaulino as a reviewer!
I'll wait for their review and will help manage the review process.
Once they submit their review, I'll check if a second reviewer would be helpful.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch 2 times, most recently from 0af1b43 to 31300c3 Compare March 25, 2025 04:01
@tankyleo tankyleo marked this pull request as draft March 25, 2025 04:08
@TheBlueMatt
Copy link
Collaborator

Why is this draft?

@tankyleo
Copy link
Contributor Author

Why is this draft?

@TheBlueMatt I don't feel great about the code duplication between get_commitment_stats and build_commitment_transaction. Both functions filter for the non-dust HTLCs, but they do different things with them.

Let me know what you think.

@tankyleo
Copy link
Contributor Author

I'm working on further cleanups now.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from d6b1f51 to c540347 Compare March 25, 2025 19:52
@tankyleo tankyleo marked this pull request as ready for review March 25, 2025 19:59
@tankyleo
Copy link
Contributor Author

@wpaulino the PR is in a better spot now, let me know what you think.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from c540347 to c9b30cb Compare March 26, 2025 00:06
@tankyleo tankyleo requested a review from wpaulino March 26, 2025 03:12
@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch 3 times, most recently from e637050 to 4d6bf13 Compare March 26, 2025 17:40
@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch 3 times, most recently from 5a212d8 to d682615 Compare March 27, 2025 15:24
Copy link

codecov bot commented Mar 27, 2025

Codecov Report

Attention: Patch coverage is 98.00995% with 4 lines in your changes missing coverage. Please review.

Project coverage is 89.16%. Comparing base (2e435de) to head (71df614).
Report is 2 commits behind head on main.

Files with missing lines Patch % Lines
lightning/src/ln/chan_utils.rs 86.66% 2 Missing ⚠️
lightning/src/ln/channel.rs 98.77% 1 Missing and 1 partial ⚠️
Additional details and impacted files
@@            Coverage Diff             @@
##             main    #3682      +/-   ##
==========================================
- Coverage   89.18%   89.16%   -0.03%     
==========================================
  Files         155      155              
  Lines      120796   120861      +65     
  Branches   120796   120861      +65     
==========================================
+ Hits       107731   107760      +29     
- Misses      10415    10446      +31     
- Partials     2650     2655       +5     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from d682615 to 6f80f99 Compare March 27, 2025 16:14
@tankyleo
Copy link
Contributor Author

@TheBlueMatt take a look when you can thank you!

@@ -223,6 +223,25 @@ impl From<&InboundHTLCState> for Option<InboundHTLCStateDetails> {
}
}

impl InboundHTLCState {
fn as_str(&self) -> &str {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Heh, if its just for logging I think we can #[derive(Debug)] :)

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Debug would log all their inner contents too - don't think that's what we want here ?

I would have to derive Debug in a bunch more places.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Actually I'll just move that function to an impl fmt::Debug for InboundHTLCState :)

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Went with an impl fmt::Display here, seems this corresponds most to what we want.

/// have not yet committed it. Such HTLCs will only be included in transactions which are being
/// generated by the peer which proposed adding the HTLCs, and thus we need to understand both
/// which peer generated this transaction and "to whom" this transaction flows.
fn for_each_inbound<F>(&self, generated_by_local: bool, mut for_each: F)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The fn name here doesn't really communicate what it does/is used for. Maybe inbound_htlcs_in_commitment? It might also be more Rust-y to return an impl Iterator and let the callsite do the for, rather than doing it as a callback.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We initially had something like this is it closer to what you have in mind?

                for htlc in self.pending_inbound_htlcs.iter() {
                        if htlc.state.included_in_commitment(generated_by_local) {
                               ..
                        } else {
                               ..
                        }
                }

some other options for that specific function's return value:

  1. one iterator yielding (included, htlc)
  2. two iterators each yielding htlc, one for included, one for excluded.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Went with the very first option above.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch 2 times, most recently from a6c6eac to 71df614 Compare April 1, 2025 17:47
@tankyleo tankyleo requested a review from TheBlueMatt April 1, 2025 17:48
Copy link
Collaborator

@TheBlueMatt TheBlueMatt left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Basically LGTM, one nit. Sorry somehow I lost track of this one.

macro_rules! count_nondust_htlc {
($htlc: expr, $outbound: expr) => {
if $htlc.is_dust(local, feerate_per_kw, broadcaster_dust_limit_sat, self.get_channel_type()) {
log_trace!(logger, " ...not counting {} {} dust HTLC {} (hash {}) with value {} due to dust limit", if $outbound { "outbound" } else { "inbound" }, $htlc.state, $htlc.htlc_id, $htlc.payment_hash, $htlc.amount_msat);
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Hmm, this is gonna end up doubling the amount we log when we build a commitment - instead of logging once per HTLC we're now logging twice, once when building the stats and once when we build the commitment itself. IMO we should make one of the two methods silent (which depends a bit on how you intend to use commitment_stats going forward, which isn't clear from the commit msg.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

No problem ! Thank you I added the motivation for commitment_stats in the commit message, and removed all logs from that function. I prefer to let callers of this function do the logging depending on the use case.

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from 71df614 to 6d8fb6e Compare April 2, 2025 21:23
@tankyleo tankyleo requested review from TheBlueMatt and wpaulino April 2, 2025 21:28
} else {
htlc_success_tx_weight(features)
};
feerate_per_kw as u64 * htlc_tx_weight / 1000
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit: could note that we intentionally round down here as required by the spec

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

thanks will do

value_to_self_msat_offset += htlc.amount_msat as i64;
},
_ => {},
if let InboundHTLCState::LocalRemoved(InboundHTLCRemovalReason::Fulfill(_preimage)) = htlc.state {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit: use preimage() instead and check for Some?

value_to_self_msat_offset -= htlc.amount_msat as i64;
},
_ => {},
OutboundHTLCState::RemoteRemoved(OutboundHTLCOutcome::Success(_))
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Same here regarding preimage

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Both of these work so far - I just need to check that this comment here is true for the outbound states:

enum OutboundHTLCOutcome {
        /// LDK version 0.0.105+ will always fill in the preimage here.
        Success(Option<PaymentPreimage>),
        Failure(HTLCFailReason),
}
``

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@TheBlueMatt what do you think of replacing this if let ... with a if htlc.state.preimage().is_some() call ?

  • Would assume no upgrades from 0.0.104 and below straight to 0.2
  • We would now rely heavily on this statement being true: OutboundHTLCOutcome::Success always has a preimage filled in.
  • Right now if this is violated, a VLS will be missing a preimage.

Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Would assume no upgrades from 0.0.104 and below straight to 0.2

I believe we already require that for various things from some of wilmer's splicing work to, almost, the 0.1 "Nodes with pending forwarded HTLCs or unclaimed payments cannot be upgraded directly from 0.0.123 or earlier to 0.1"

We would now rely heavily on this statement being true: OutboundHTLCOutcome::Success always has a preimage filled in.

We should probably just enforce it in the deserialization step.

Copy link
Collaborator

@TheBlueMatt TheBlueMatt left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Needs rebase, it seems

@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from 6d8fb6e to 793d4d2 Compare April 3, 2025 18:58
@tankyleo tankyleo requested a review from TheBlueMatt April 3, 2025 22:18
@tankyleo
Copy link
Contributor Author

tankyleo commented Apr 4, 2025

A question for you in an above comment Matt thanks :)

@TheBlueMatt TheBlueMatt removed their request for review April 4, 2025 12:38
tankyleo added 4 commits April 4, 2025 20:42
It can be useful to get the stats on a potential commitment transaction
without actually building it. Therefore, this commit splits the stats
calculations from the actual build of a commitment transaction.

This introduces an extra loop over the pending htlcs when actually
building a commitment transaction, but current network behavior
produces very few concurrent htlcs on channels. Furthermore, each
iteration of the loop in the stats calculation is very cheap.

The motivating use case for `build_commitment_stats` is to calculate the
balances of the channel parties in order to validate the
`funding_contribution_satoshis` field of `splice_init` and `splice_ack`
messages without building a full commitment transaction.
This allows us to DRY the code that calculates the
`value_to_self_msat_offset` in `ChannelContext::build_commitment_stats`.

HTLC success states have held their corresponding preimage since
0.0.105, and the release notes of 0.1 already require users running
0.0.123 and earlier to resolve their HTLCs before upgrading to 0.1. So
this change is fully compatible with existing upgrade paths to
the yet-to-be-shipped 0.2 release.
@tankyleo tankyleo force-pushed the commitment-stats-less-duplication branch from 0c7bab6 to 285f1b9 Compare April 4, 2025 20:57
@tankyleo tankyleo requested a review from wpaulino April 4, 2025 21:02
OutboundHTLCState::RemoteRemoved(OutboundHTLCOutcome::Success(preimage)) |
OutboundHTLCState::AwaitingRemoteRevokeToRemove(OutboundHTLCOutcome::Success(preimage)) |
OutboundHTLCState::AwaitingRemovedRemoteRevoke(OutboundHTLCOutcome::Success(preimage)) => {
debug_assert!(preimage.is_some());
Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I am not 100 sure if this debug assert and those below should be hard asserts. I went with debug because from what I can see so far, lacking preimages can lead to force closes, but not loss of funds.

@ldk-reviews-bot
Copy link

🔔 1st Reminder

Hey @wpaulino! This PR has been waiting for your review.
Please take a look when you have a chance. If you're unable to review, please let us know so we can find another reviewer.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants