Git-Mirrors/veilid
1
0
Fork 0
mirror of https://gitlab.com/veilid/veilid.git synced 2024-12-23 22:39:36 -05:00
Code Issues Packages Projects Releases Wiki Activity

remove unnecessary spans

Browse Source
This commit is contained in:
Christien Rioux 2024-07-22 09:54:10 -04:00
parent b091c78539
commit bcb9f2a96c
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
veilid-core/src/network_manager/native/network_udp.rs
View File

@ -58,6 +58,7 @@ impl Network {
match ph
.recv_message(&mut data)
.timeout_at(stop_token.clone())
.in_current_span()
.await
{
Ok(Ok((size, flow))) => {
@ -90,7 +91,7 @@ impl Network {
// Now we wait for join handles to exit,
// if any error out it indicates an error needing
// us to completely restart the network
while let Some(v) = protocol_handlers_unordered.next().await {
while let Some(v) = protocol_handlers_unordered.next().in_current_span().await {
// true = stopped, false = errored
if !v {
// If any protocol handler fails, our socket died and we need to restart the network
@ -99,7 +100,7 @@ impl Network {
}
log_net!("UDP listener task stopped");
});
}.instrument(trace_span!(parent: None, "UDP Listener")));
////////////////////////////////////////////////////////////
// Add to join handle

1
veilid-core/src/rpc_processor/mod.rs
View File

@ -1674,7 +1674,6 @@ impl RPCProcessor {
}
}
#[instrument(level="trace", target="rpc", skip_all)]
async fn rpc_worker(
self,
stop_token: StopToken,

3
veilid-tools/src/tick_task.rs
View File

@ -126,7 +126,7 @@ impl<E: Send + 'static> TickTask<E> {
if opt_stop_source.is_some() {
// See if the previous execution finished with an error
match self.single_future.check().in_current_span().await {
match self.single_future.check().await {
Ok(Some(Err(e))) => {
// We have an error result, which means the singlefuture ran but we need to propagate the error
return Err(e);
@ -163,7 +163,6 @@ impl<E: Send + 'static> TickTask<E> {
match self
.single_future
.single_spawn(&self.name, wrapped_routine)
.in_current_span()
.await
{
// We should have already consumed the result of the last run, or there was none