Skip to content

Commit 658678d

Browse files
committed
Update benchmarks for ChannelPending event
1 parent 143596f commit 658678d

File tree

1 file changed

+18
-1
lines changed

1 file changed

+18
-1
lines changed

lightning/src/ln/channelmanager.rs

Lines changed: 18 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8783,7 +8783,7 @@ pub mod bench {
87838783
use crate::chain::Listen;
87848784
use crate::chain::chainmonitor::{ChainMonitor, Persist};
87858785
use crate::chain::keysinterface::{EntropySource, KeysManager, InMemorySigner};
8786-
use crate::ln::channelmanager::{self, BestBlock, ChainParameters, ChannelManager, PaymentHash, PaymentPreimage, PaymentId};
8786+
use crate::ln::channelmanager::{BestBlock, ChainParameters, ChannelManager, PaymentHash, PaymentPreimage, PaymentId};
87878787
use crate::ln::functional_test_utils::*;
87888788
use crate::ln::msgs::{ChannelMessageHandler, Init};
87898789
use crate::routing::gossip::NetworkGraph;
@@ -8865,7 +8865,24 @@ pub mod bench {
88658865
} else { panic!(); }
88668866

88678867
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()));
8868+
let events_b = node_b.get_and_clear_pending_events();
8869+
assert_eq!(events_b.len(), 1);
8870+
match events_b[0] {
8871+
Event::ChannelPending{ ref counterparty_node_id, .. } => {
8872+
assert_eq!(*counterparty_node_id, node_a.get_our_node_id());
8873+
},
8874+
_ => panic!("Unexpected event"),
8875+
}
8876+
88688877
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()));
8878+
let events_a = node_a.get_and_clear_pending_events();
8879+
assert_eq!(events_a.len(), 1);
8880+
match events_a[0] {
8881+
Event::ChannelPending{ ref counterparty_node_id, .. } => {
8882+
assert_eq!(*counterparty_node_id, node_b.get_our_node_id());
8883+
},
8884+
_ => panic!("Unexpected event"),
8885+
}
88698886

88708887
assert_eq!(&tx_broadcaster.txn_broadcasted.lock().unwrap()[..], &[tx.clone()]);
88718888

0 commit comments

Comments
 (0)