@@ -663,7 +663,7 @@ fn test_channel_update_cached() {
663
663
664
664
let chan = create_announced_chan_between_nodes ( & nodes, 0 , 1 ) ;
665
665
666
- nodes[ 0 ] . node . force_close_channel_with_peer ( & chan. 2 , & nodes[ 1 ] . node . get_our_node_id ( ) , None , true ) . unwrap ( ) ;
666
+ let _ = nodes[ 0 ] . node . force_close_broadcasting_latest_txn ( & chan. 2 , & nodes[ 1 ] . node . get_our_node_id ( ) ) ;
667
667
check_added_monitors ! ( nodes[ 0 ] , 1 ) ;
668
668
check_closed_event ! ( nodes[ 0 ] , 1 , ClosureReason :: HolderForceClosed , [ nodes[ 1 ] . node. get_our_node_id( ) ] , 100000 ) ;
669
669
@@ -673,8 +673,8 @@ fn test_channel_update_cached() {
673
673
674
674
{
675
675
// Assert that ChannelUpdate message has been added to node[0] pending broadcast messages
676
- let pending_broadcast_messages= nodes[ 0 ] . node . pending_broadcast_messages . lock ( ) . unwrap ( ) ;
677
- assert_eq ! ( pending_broadcast_messages. len( ) , 1 ) ;
676
+ let pending_broadcast_messages = nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
677
+ assert_eq ! ( pending_broadcast_messages. len( ) , 2 ) ;
678
678
}
679
679
680
680
// Test that we do not retrieve the pending broadcast messages when we are not connected to any peer
@@ -704,7 +704,7 @@ fn test_channel_update_cached() {
704
704
}
705
705
{
706
706
// Assert that ChannelUpdate message has been cleared from nodes[0] pending broadcast messages
707
- let pending_broadcast_messages= nodes[ 0 ] . node . pending_broadcast_messages . lock ( ) . unwrap ( ) ;
707
+ let pending_broadcast_messages= nodes[ 0 ] . node . get_and_clear_pending_msg_events ( ) ;
708
708
assert_eq ! ( pending_broadcast_messages. len( ) , 0 ) ;
709
709
}
710
710
}
0 commit comments