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