nat_transversal #3
@@ -360,10 +360,11 @@ pub fn start_p2p_executor(
|
|||||||
let peer_addr_query = get_socket_address(username.clone(), ip.clone());
|
let peer_addr_query = get_socket_address(username.clone(), ip.clone());
|
||||||
|
|
||||||
match server_addr_query.await {
|
match server_addr_query.await {
|
||||||
Some(server_addr) => {
|
Some(server_addr) => match peer_addr_query.await {
|
||||||
|
Some(peer_addr) => {
|
||||||
let natreq = construct_message(
|
let natreq = construct_message(
|
||||||
NATTRAVERSALREQUEST,
|
NATTRAVERSALREQUEST,
|
||||||
ip.to_string().into_bytes(),
|
peer_addr.to_string().into_bytes(),
|
||||||
8,
|
8,
|
||||||
&sd.cryptopair(),
|
&sd.cryptopair(),
|
||||||
);
|
);
|
||||||
@@ -378,6 +379,12 @@ pub fn start_p2p_executor(
|
|||||||
sd.messages_list_ref(),
|
sd.messages_list_ref(),
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
|
None => {
|
||||||
|
let err_msg = format!("failed to retreive socket address")
|
||||||
|
.to_string();
|
||||||
|
let res = event_tx.send(NetworkEvent::Error(err_msg));
|
||||||
|
}
|
||||||
|
},
|
||||||
None => {
|
None => {
|
||||||
let err_msg =
|
let err_msg =
|
||||||
format!("failed to retreive socket address").to_string();
|
format!("failed to retreive socket address").to_string();
|
||||||
|
|||||||
Reference in New Issue
Block a user