Cargo fmt & clippy

eclipse-zenoh · Feb 2, 2024 · b67be59 · b67be59
1 parent 6446a12
commit b67be59
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 5 deletions.
diff --git a/zenoh/src/net/routing/hat/linkstate_peer/mod.rs b/zenoh/src/net/routing/hat/linkstate_peer/mod.rs
@@ -43,12 +43,12 @@ use crate::{
     },
     runtime::Runtime,
 };
-use tokio::task::JoinHandle;
 use std::{
     any::Any,
     collections::{HashMap, HashSet},
     sync::Arc,
 };
+use tokio::task::JoinHandle;
 use zenoh_config::{unwrap_or_default, ModeDependent, WhatAmI, WhatAmIMatcher, ZenohId};
 use zenoh_protocol::{
     common::ZExtBody,

diff --git a/zenoh/src/net/routing/hat/linkstate_peer/network.rs b/zenoh/src/net/routing/hat/linkstate_peer/network.rs
@@ -486,7 +486,8 @@ impl Network {
 
                         if !self.autoconnect.is_empty() {
                             // Connect discovered peers
-                            if zenoh_runtime::ZRuntime::Net.block_in_place(self.runtime.manager().get_transport_unicast(&zid))
+                            if zenoh_runtime::ZRuntime::Net
+                                .block_in_place(self.runtime.manager().get_transport_unicast(&zid))
                                 .is_none()
                                 && self.autoconnect.matches(whatami)
                             {
@@ -605,7 +606,8 @@ impl Network {
             for (_, idx, _) in &link_states {
                 let node = &self.graph[*idx];
                 if let Some(whatami) = node.whatami {
-                    if zenoh_runtime::ZRuntime::Net.block_in_place(self.runtime.manager().get_transport_unicast(&node.zid))
+                    if zenoh_runtime::ZRuntime::Net
+                        .block_in_place(self.runtime.manager().get_transport_unicast(&node.zid))
                         .is_none()
                         && self.autoconnect.matches(whatami)
                     {

diff --git a/zenoh/src/net/routing/hat/p2p_peer/gossip.rs b/zenoh/src/net/routing/hat/p2p_peer/gossip.rs
@@ -406,7 +406,8 @@ impl Network {
 
                     if !self.autoconnect.is_empty() {
                         // Connect discovered peers
-                        if zenoh_runtime::ZRuntime::Net.block_in_place(self.runtime.manager().get_transport_unicast(&zid))
+                        if zenoh_runtime::ZRuntime::Net
+                            .block_in_place(self.runtime.manager().get_transport_unicast(&zid))
                             .is_none()
                             && self.autoconnect.matches(whatami)
                         {

diff --git a/zenoh/src/net/routing/hat/router/mod.rs b/zenoh/src/net/routing/hat/router/mod.rs
@@ -47,13 +47,13 @@ use crate::{
     },
     runtime::Runtime,
 };
-use tokio::task::JoinHandle;
 use std::{
     any::Any,
     collections::{hash_map::DefaultHasher, HashMap, HashSet},
     hash::Hasher,
     sync::Arc,
 };
+use tokio::task::JoinHandle;
 use zenoh_config::{unwrap_or_default, ModeDependent, WhatAmI, WhatAmIMatcher, ZenohId};
 use zenoh_protocol::{
     common::ZExtBody,