@@ -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.
@@ -2285,7 +2278,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
2285
2278
if msg. is_some ( ) {
2286
2279
let update = self . build_commitment_no_status_check ( logger) ;
2287
2280
self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
2288
- update, blocked : true ,
2281
+ update,
2289
2282
} ) ;
2290
2283
}
2291
2284
}
@@ -3545,9 +3538,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
3545
3538
{
3546
3539
assert_eq ! ( self . context. channel_state & ChannelState :: MonitorUpdateInProgress as u32 , ChannelState :: MonitorUpdateInProgress as u32 ) ;
3547
3540
self . context . channel_state &= !( ChannelState :: MonitorUpdateInProgress as u32 ) ;
3548
- for upd in self . context . pending_monitor_updates . iter ( ) {
3549
- debug_assert ! ( upd. blocked) ;
3550
- }
3551
3541
3552
3542
// If we're past (or at) the FundingSent stage on an outbound channel, try to
3553
3543
// (re-)broadcast the funding transaction as we may have declined to broadcast it when we
@@ -4414,9 +4404,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
4414
4404
/// Returns the next blocked monitor update, if one exists, and a bool which indicates a
4415
4405
/// further blocked monitor update exists after the next.
4416
4406
pub fn unblock_next_blocked_monitor_update ( & mut self ) -> Option < ( ChannelMonitorUpdate , bool ) > {
4417
- for upd in self . context . pending_monitor_updates . iter ( ) {
4418
- debug_assert ! ( upd. blocked) ;
4419
- }
4420
4407
if self . context . pending_monitor_updates . is_empty ( ) { return None ; }
4421
4408
Some ( ( self . context . pending_monitor_updates . remove ( 0 ) . update ,
4422
4409
!self . context . pending_monitor_updates . is_empty ( ) ) )
@@ -4429,7 +4416,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
4429
4416
let release_monitor = self . context . pending_monitor_updates . is_empty ( ) ;
4430
4417
if !release_monitor {
4431
4418
self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
4432
- update, blocked : true ,
4419
+ update,
4433
4420
} ) ;
4434
4421
None
4435
4422
} else {
0 commit comments