@@ -8780,7 +8780,7 @@ pub mod bench {
8780
8780
use crate :: chain:: Listen ;
8781
8781
use crate :: chain:: chainmonitor:: { ChainMonitor , Persist } ;
8782
8782
use crate :: chain:: keysinterface:: { EntropySource , KeysManager , InMemorySigner } ;
8783
- use crate :: ln:: channelmanager:: { self , BestBlock , ChainParameters , ChannelManager , PaymentHash , PaymentPreimage , PaymentId } ;
8783
+ use crate :: ln:: channelmanager:: { BestBlock , ChainParameters , ChannelManager , PaymentHash , PaymentPreimage , PaymentId } ;
8784
8784
use crate :: ln:: functional_test_utils:: * ;
8785
8785
use crate :: ln:: msgs:: { ChannelMessageHandler , Init } ;
8786
8786
use crate :: routing:: gossip:: NetworkGraph ;
@@ -8862,7 +8862,24 @@ pub mod bench {
8862
8862
} else { panic ! ( ) ; }
8863
8863
8864
8864
node_b. handle_funding_created ( & node_a. get_our_node_id ( ) , & get_event_msg ! ( node_a_holder, MessageSendEvent :: SendFundingCreated , node_b. get_our_node_id( ) ) ) ;
8865
+ let events_b = node_b. get_and_clear_pending_events ( ) ;
8866
+ assert_eq ! ( events_b. len( ) , 1 ) ;
8867
+ match events_b[ 0 ] {
8868
+ Event :: ChannelPending { ref counterparty_node_id, .. } => {
8869
+ assert_eq ! ( * counterparty_node_id, node_a. get_our_node_id( ) ) ;
8870
+ } ,
8871
+ _ => panic ! ( "Unexpected event" ) ,
8872
+ }
8873
+
8865
8874
node_a. handle_funding_signed ( & node_b. get_our_node_id ( ) , & get_event_msg ! ( node_b_holder, MessageSendEvent :: SendFundingSigned , node_a. get_our_node_id( ) ) ) ;
8875
+ let events_a = node_a. get_and_clear_pending_events ( ) ;
8876
+ assert_eq ! ( events_a. len( ) , 1 ) ;
8877
+ match events_a[ 0 ] {
8878
+ Event :: ChannelPending { ref counterparty_node_id, .. } => {
8879
+ assert_eq ! ( * counterparty_node_id, node_b. get_our_node_id( ) ) ;
8880
+ } ,
8881
+ _ => panic ! ( "Unexpected event" ) ,
8882
+ }
8866
8883
8867
8884
assert_eq ! ( & tx_broadcaster. txn_broadcasted. lock( ) . unwrap( ) [ ..] , & [ tx. clone( ) ] ) ;
8868
8885
0 commit comments