Skip to content

Commit a5358d0

Browse files
committed
f Avoid racing event queue
1 parent 4b4fae0 commit a5358d0

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

lightning/src/ln/channelmanager.rs

+1-2
Original file line numberDiff line numberDiff line change
@@ -1717,13 +1717,12 @@ macro_rules! process_events_body {
17171717
let mut pending_events = $self.pending_events.lock().unwrap();
17181718
pending_events.drain(..num_events);
17191719
processed_all_events = pending_events.is_empty();
1720+
$self.pending_events_processor.store(false, Ordering::Release);
17201721
}
17211722

17221723
if result == NotifyOption::DoPersist {
17231724
$self.persistence_notifier.notify();
17241725
}
1725-
1726-
$self.pending_events_processor.store(false, Ordering::Release);
17271726
}
17281727
}
17291728
}

0 commit comments

Comments
 (0)