@@ -591,6 +591,7 @@ pub(crate) enum RAAMonitorUpdateBlockingAction {
591
591
}
592
592
593
593
impl RAAMonitorUpdateBlockingAction {
594
+ #[ allow( unused) ]
594
595
fn from_prev_hop_data ( prev_hop : & HTLCPreviousHopData ) -> Self {
595
596
Self :: ForwardedPaymentOtherChannelClaim {
596
597
channel_id : prev_hop. outpoint . to_channel_id ( ) ,
@@ -4538,7 +4539,6 @@ where
4538
4539
} ,
4539
4540
HTLCSource :: PreviousHopData ( hop_data) => {
4540
4541
let prev_outpoint = hop_data. outpoint ;
4541
- let completed_blocker = RAAMonitorUpdateBlockingAction :: from_prev_hop_data ( & hop_data) ;
4542
4542
let res = self . claim_funds_from_hop ( hop_data, payment_preimage,
4543
4543
|htlc_claim_value_msat| {
4544
4544
if let Some ( forwarded_htlc_value) = forwarded_htlc_value_msat {
@@ -5449,22 +5449,6 @@ where
5449
5449
} )
5450
5450
}
5451
5451
5452
- pub ( crate ) fn test_raa_monitor_updates_held ( & self , counterparty_node_id : PublicKey ,
5453
- channel_id : [ u8 ; 32 ] )
5454
- -> bool {
5455
- let per_peer_state = self . per_peer_state . read ( ) . unwrap ( ) ;
5456
- if let Some ( peer_state_mtx) = per_peer_state. get ( & counterparty_node_id) {
5457
- let mut peer_state_lck = peer_state_mtx. lock ( ) . unwrap ( ) ;
5458
- let peer_state = & mut * peer_state_lck;
5459
-
5460
- if let Some ( chan) = peer_state. channel_by_id . get ( & channel_id) {
5461
- return self . raa_monitor_updates_held ( & peer_state. actions_blocking_raa_monitor_updates ,
5462
- chan. get_funding_txo ( ) . unwrap ( ) , counterparty_node_id) ;
5463
- }
5464
- }
5465
- false
5466
- }
5467
-
5468
5452
fn internal_revoke_and_ack ( & self , counterparty_node_id : & PublicKey , msg : & msgs:: RevokeAndACK ) -> Result < ( ) , MsgHandleErrInternal > {
5469
5453
let ( htlcs_to_fail, res) = {
5470
5454
let per_peer_state = self . per_peer_state . read ( ) . unwrap ( ) ;
0 commit comments