File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -787,7 +787,7 @@ mod tests {
787
787
#[ test]
788
788
fn test_async_ooo_offchain_updates ( ) {
789
789
// Test that if we have multiple offchain updates being persisted and they complete
790
- // out-of-order, the ChainMonitor waits until all have completed until informing the
790
+ // out-of-order, the ChainMonitor waits until all have completed before informing the
791
791
// ChannelManager.
792
792
let chanmon_cfgs = create_chanmon_cfgs ( 2 ) ;
793
793
let node_cfgs = create_node_cfgs ( 2 , & chanmon_cfgs) ;
@@ -815,10 +815,11 @@ mod tests {
815
815
assert_eq ! ( updates. len( ) , 2 ) ;
816
816
817
817
// Note that updates is a HashMap so the ordering here is actually random. This shouldn't
818
- // fail either way but if it fails intermittently its depending on the ordering of updates.
818
+ // fail either way but if it fails intermittently it's depending on the ordering of updates.
819
819
let mut update_iter = updates. iter ( ) ;
820
820
nodes[ 1 ] . chain_monitor . chain_monitor . channel_monitor_updated ( * funding_txo, update_iter. next ( ) . unwrap ( ) . clone ( ) ) . unwrap ( ) ;
821
821
assert ! ( nodes[ 1 ] . chain_monitor. release_pending_monitor_events( ) . is_empty( ) ) ;
822
+ assert ! ( nodes[ 1 ] . node. get_and_clear_pending_msg_events( ) . is_empty( ) ) ;
822
823
nodes[ 1 ] . chain_monitor . chain_monitor . channel_monitor_updated ( * funding_txo, update_iter. next ( ) . unwrap ( ) . clone ( ) ) . unwrap ( ) ;
823
824
824
825
// Now manually walk the commitment signed dance - because we claimed two payments
You can’t perform that action at this time.
0 commit comments