File tree 1 file changed +1
-6
lines changed
1 file changed +1
-6
lines changed Original file line number Diff line number Diff line change @@ -814,12 +814,7 @@ where C::Target: chain::Filter,
814
814
let mut pending_monitor_events = self . pending_monitor_events . lock ( ) . unwrap ( ) . split_off ( 0 ) ;
815
815
for monitor_state in self . monitors . read ( ) . unwrap ( ) . values ( ) {
816
816
let is_pending_monitor_update = monitor_state. has_pending_chainsync_updates ( & monitor_state. pending_monitor_updates . lock ( ) . unwrap ( ) ) ;
817
- if is_pending_monitor_update &&
818
- monitor_state. last_chain_persist_height . load ( Ordering :: Acquire ) + LATENCY_GRACE_PERIOD_BLOCKS as usize
819
- > self . highest_chain_height . load ( Ordering :: Acquire )
820
- {
821
- log_debug ! ( self . logger, "A Channel Monitor sync is still in progress, refusing to provide monitor events!" ) ;
822
- } else {
817
+ if !is_pending_monitor_update || monitor_state. last_chain_persist_height . load ( Ordering :: Acquire ) + LATENCY_GRACE_PERIOD_BLOCKS as usize <= self . highest_chain_height . load ( Ordering :: Acquire ) {
823
818
if is_pending_monitor_update {
824
819
log_error ! ( self . logger, "A ChannelMonitor sync took longer than {} blocks to complete." , LATENCY_GRACE_PERIOD_BLOCKS ) ;
825
820
log_error ! ( self . logger, " To avoid funds-loss, we are allowing monitor updates to be released." ) ;
You can’t perform that action at this time.
0 commit comments