@@ -585,17 +585,10 @@ pub(crate) const DISCONNECT_PEER_AWAITING_RESPONSE_TICKS: usize = 2;
585585
586586struct PendingChannelMonitorUpdate {
587587 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 ,
594588}
595589
596590impl_writeable_tlv_based ! ( PendingChannelMonitorUpdate , {
597591 ( 0 , update, required) ,
598- ( 2 , blocked, required) ,
599592} ) ;
600593
601594/// Contains everything about the channel including state, and various flags.
@@ -2285,7 +2278,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
22852278 if msg. is_some ( ) {
22862279 let update = self . build_commitment_no_status_check ( logger) ;
22872280 self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
2288- update, blocked : true ,
2281+ update,
22892282 } ) ;
22902283 }
22912284 }
@@ -3545,9 +3538,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
35453538 {
35463539 assert_eq ! ( self . context. channel_state & ChannelState :: MonitorUpdateInProgress as u32 , ChannelState :: MonitorUpdateInProgress as u32 ) ;
35473540 self . context . channel_state &= !( ChannelState :: MonitorUpdateInProgress as u32 ) ;
3548- for upd in self . context . pending_monitor_updates . iter ( ) {
3549- debug_assert ! ( upd. blocked) ;
3550- }
35513541
35523542 // If we're past (or at) the FundingSent stage on an outbound channel, try to
35533543 // (re-)broadcast the funding transaction as we may have declined to broadcast it when we
@@ -4414,9 +4404,6 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
44144404 /// Returns the next blocked monitor update, if one exists, and a bool which indicates a
44154405 /// further blocked monitor update exists after the next.
44164406 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- }
44204407 if self . context . pending_monitor_updates . is_empty ( ) { return None ; }
44214408 Some ( ( self . context . pending_monitor_updates . remove ( 0 ) . update ,
44224409 !self . context . pending_monitor_updates . is_empty ( ) ) )
@@ -4429,7 +4416,7 @@ impl<Signer: WriteableEcdsaChannelSigner> Channel<Signer> {
44294416 let release_monitor = self . context . pending_monitor_updates . is_empty ( ) ;
44304417 if !release_monitor {
44314418 self . context . pending_monitor_updates . push ( PendingChannelMonitorUpdate {
4432- update, blocked : true ,
4419+ update,
44334420 } ) ;
44344421 None
44354422 } else {
0 commit comments