@@ -585,17 +585,10 @@ pub(crate) const DISCONNECT_PEER_AWAITING_RESPONSE_TICKS: usize = 2;
585
585
586
586
struct PendingChannelMonitorUpdate {
587
587
update : ChannelMonitorUpdate ,
588
- /// In some cases we need to delay letting the [`ChannelMonitorUpdate`] go until after an
589
- /// `Event` is processed by the user. This bool indicates the [`ChannelMonitorUpdate`] is
590
- /// blocked on some external event and the [`ChannelManager`] will update us when we're ready.
591
- ///
592
- /// [`ChannelManager`]: super::channelmanager::ChannelManager
593
- blocked : bool ,
594
588
}
595
589
596
590
impl_writeable_tlv_based ! ( PendingChannelMonitorUpdate , {
597
591
( 0 , update, required) ,
598
- ( 2 , blocked, required) ,
599
592
} ) ;
600
593
601
594
/// Contains everything about the channel including state, and various flags.
@@ -2286,7 +2279,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
2286
2279
debug_assert ! ( false , "If there is a pending blocked monitor we should have MonitorUpdateInProgress set" ) ;
2287
2280
let update = self . build_commitment_no_status_check ( logger) ;
2288
2281
self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
2289
- update, blocked : true ,
2282
+ update,
2290
2283
} ) ;
2291
2284
}
2292
2285
}
@@ -3544,9 +3537,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
3544
3537
{
3545
3538
assert_eq ! ( self . context. channel_state & ChannelState :: MonitorUpdateInProgress as u32 , ChannelState :: MonitorUpdateInProgress as u32 ) ;
3546
3539
self . context . channel_state &= !( ChannelState :: MonitorUpdateInProgress as u32 ) ;
3547
- for upd in self . context . pending_monitor_updates . iter ( ) {
3548
- debug_assert ! ( upd. blocked) ;
3549
- }
3550
3540
3551
3541
// If we're past (or at) the FundingSent stage on an outbound channel, try to
3552
3542
// (re-)broadcast the funding transaction as we may have declined to broadcast it when we
@@ -4413,9 +4403,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
4413
4403
/// Returns the next blocked monitor update, if one exists, and a bool which indicates a
4414
4404
/// further blocked monitor update exists after the next.
4415
4405
pub fn unblock_next_blocked_monitor_update ( & mut self ) -> Option < ( ChannelMonitorUpdate , bool ) > {
4416
- for upd in self . context . pending_monitor_updates . iter ( ) {
4417
- debug_assert ! ( upd. blocked) ;
4418
- }
4419
4406
if self . context . pending_monitor_updates . is_empty ( ) { return None ; }
4420
4407
Some ( ( self . context . pending_monitor_updates . remove ( 0 ) . update ,
4421
4408
!self . context . pending_monitor_updates . is_empty ( ) ) )
@@ -4428,7 +4415,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
4428
4415
let release_monitor = self . context . pending_monitor_updates . is_empty ( ) ;
4429
4416
if !release_monitor {
4430
4417
self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
4431
- update, blocked : true ,
4418
+ update,
4432
4419
} ) ;
4433
4420
None
4434
4421
} else {
0 commit comments