liz/veilid
liz/veilid
1
0
Fork 0
Code Pull Requests Packages Releases Activity

last connection work

Browse Source
This commit is contained in:
John Smith 2022-08-06 13:15:33 -04:00
parent 5e1176db5a
commit 292712671a
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
veilid-core/src/network_manager/native/network_class_discovery.rs
View File

@ -81,15 +81,20 @@ impl DiscoveryContext {
let res = network_result_value_or_log!(debug match rpc.rpc_call_status(node_ref.clone()).await {
Ok(v) => v,
Err(e) => {
node_ref.clear_last_connection();
log_net!(error
"failed to get status answer from {:?}: {}",
node_ref, e
);
return None;
}
} => { return None; }
} => {
node_ref.clear_last_connection();
return None;
}
);
node_ref.clear_last_connection();
log_net!(
"request_public_address {:?}: Value({:?})",
node_ref,
@ -196,13 +201,16 @@ impl DiscoveryContext {
node_ref.set_filter(None);
// ask the node to send us a dial info validation receipt
rpc.rpc_call_validate_dial_info(node_ref.clone(), dial_info, redirect)
let out = rpc
.rpc_call_validate_dial_info(node_ref.clone(), dial_info, redirect)
.await
.map_err(logthru_net!(
"failed to send validate_dial_info to {:?}",
node_ref
))
.unwrap_or(false)
.unwrap_or(false);
node_ref.clear_last_connection();
out
}
#[instrument(level = "trace", skip(self), ret)]