@@ -422,8 +422,8 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
422
422
let mut channel_txn = Vec :: new ( ) ;
423
423
macro_rules! make_channel {
424
424
( $source: expr, $dest: expr, $chan_id: expr) => { {
425
- $source. peer_connected( & $dest. get_our_node_id( ) , & Init { features: InitFeatures :: known( ) , remote_network_address: None } ) ;
426
- $dest. peer_connected( & $source. get_our_node_id( ) , & Init { features: InitFeatures :: known( ) , remote_network_address: None } ) ;
425
+ $source. peer_connected( & $dest. get_our_node_id( ) , & Init { features: InitFeatures :: known( ) , remote_network_address: None } ) . unwrap ( ) ;
426
+ $dest. peer_connected( & $source. get_our_node_id( ) , & Init { features: InitFeatures :: known( ) , remote_network_address: None } ) . unwrap ( ) ;
427
427
428
428
$source. create_channel( $dest. get_our_node_id( ) , 100_000 , 42 , 0 , None ) . unwrap( ) ;
429
429
let open_channel = {
@@ -940,15 +940,15 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
940
940
} ,
941
941
0x0e => {
942
942
if chan_a_disconnected {
943
- nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
944
- nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
943
+ nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
944
+ nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
945
945
chan_a_disconnected = false ;
946
946
}
947
947
} ,
948
948
0x0f => {
949
949
if chan_b_disconnected {
950
- nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
951
- nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
950
+ nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
951
+ nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
952
952
chan_b_disconnected = false ;
953
953
}
954
954
} ,
@@ -1143,13 +1143,13 @@ pub fn do_test<Out: Output>(data: &[u8], underlying_out: Out) {
1143
1143
1144
1144
// Next, make sure peers are all connected to each other
1145
1145
if chan_a_disconnected {
1146
- nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
1147
- nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
1146
+ nodes[ 0 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
1147
+ nodes[ 1 ] . peer_connected ( & nodes[ 0 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
1148
1148
chan_a_disconnected = false ;
1149
1149
}
1150
1150
if chan_b_disconnected {
1151
- nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
1152
- nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) ;
1151
+ nodes[ 1 ] . peer_connected ( & nodes[ 2 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
1152
+ nodes[ 2 ] . peer_connected ( & nodes[ 1 ] . get_our_node_id ( ) , & Init { features : InitFeatures :: known ( ) , remote_network_address : None } ) . unwrap ( ) ;
1153
1153
chan_b_disconnected = false ;
1154
1154
}
1155
1155
0 commit comments