@@ -478,8 +478,8 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
478
478
let mut channel_txn = Vec :: new ( ) ;
479
479
macro_rules! make_channel {
480
480
( $source: expr, $dest: expr, $chan_id: expr) => { {
481
- $source. peer_connected( & $dest. get_our_node_id( ) , & Init { features: $dest. init_features( ) , remote_network_address: None } ) . unwrap( ) ;
482
- $dest. peer_connected( & $source. get_our_node_id( ) , & Init { features: $source. init_features( ) , remote_network_address: None } ) . unwrap( ) ;
481
+ $source. peer_connected( & $dest. get_our_node_id( ) , & Init { features: $dest. init_features( ) , remote_network_address: None } , true ) . unwrap( ) ;
482
+ $dest. peer_connected( & $source. get_our_node_id( ) , & Init { features: $source. init_features( ) , remote_network_address: None } , false ) . unwrap( ) ;
483
483
484
484
$source. create_channel( $dest. get_our_node_id( ) , 100_000 , 42 , 0 , None ) . unwrap( ) ;
485
485
let open_channel = {
@@ -998,15 +998,15 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
998
998
} ,
999
999
0x0e => {
1000
1000
if chan_a_disconnected {
1001
- nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1002
- nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : nodes[ 0 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1001
+ nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } , true ) . unwrap ( ) ;
1002
+ nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : nodes[ 0 ] . init_features ( ) , remote_network_address : None } , false ) . unwrap ( ) ;
1003
1003
chan_a_disconnected = false ;
1004
1004
}
1005
1005
} ,
1006
1006
0x0f => {
1007
1007
if chan_b_disconnected {
1008
- nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : nodes[ 2 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1009
- nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1008
+ nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : nodes[ 2 ] . init_features ( ) , remote_network_address : None } , true ) . unwrap ( ) ;
1009
+ nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } , false ) . unwrap ( ) ;
1010
1010
chan_b_disconnected = false ;
1011
1011
}
1012
1012
} ,
@@ -1201,13 +1201,13 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
1201
1201
1202
1202
// Next, make sure peers are all connected to each other
1203
1203
if chan_a_disconnected {
1204
- nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1205
- nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : nodes[ 0 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1204
+ nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } , true ) . unwrap ( ) ;
1205
+ nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : nodes[ 0 ] . init_features ( ) , remote_network_address : None } , false ) . unwrap ( ) ;
1206
1206
chan_a_disconnected = false ;
1207
1207
}
1208
1208
if chan_b_disconnected {
1209
- nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : nodes[ 2 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1210
- nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } ) . unwrap ( ) ;
1209
+ nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : nodes[ 2 ] . init_features ( ) , remote_network_address : None } , true ) . unwrap ( ) ;
1210
+ nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : nodes[ 1 ] . init_features ( ) , remote_network_address : None } , false ) . unwrap ( ) ;
1211
1211
chan_b_disconnected = false ;
1212
1212
}
1213
1213
0 commit comments