From 15b1c92e7d30ec0ce6286314d4901a6a862660b7 Mon Sep 17 00:00:00 2001 From: Denis Biryukov Date: Tue, 19 Mar 2024 15:13:37 +0000 Subject: [PATCH] clippy, fmt --- commons/zenoh-runtime/src/lib.rs | 4 ++-- io/zenoh-transport/src/multicast/transport.rs | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/commons/zenoh-runtime/src/lib.rs b/commons/zenoh-runtime/src/lib.rs index 8f11935bbe..41cfc6655c 100644 --- a/commons/zenoh-runtime/src/lib.rs +++ b/commons/zenoh-runtime/src/lib.rs @@ -162,9 +162,9 @@ pub unsafe fn zruntime_pool_free() { } #[doc(hidden)] -pub struct ZRuntimeGuard; +pub struct ZRuntimePoolGuard; -impl Drop for ZRuntimeGuard { +impl Drop for ZRuntimePoolGuard { fn drop(&mut self) { unsafe { zruntime_pool_free(); diff --git a/io/zenoh-transport/src/multicast/transport.rs b/io/zenoh-transport/src/multicast/transport.rs index 0cc7efc1d6..94564b74fd 100644 --- a/io/zenoh-transport/src/multicast/transport.rs +++ b/io/zenoh-transport/src/multicast/transport.rs @@ -389,7 +389,8 @@ impl TransportMulticastInner { let _ = c_self.del_peer(&c_locator, close::reason::EXPIRED); }; - self.task_controller.spawn_cancellable_with_rt(zenoh_runtime::ZRuntime::Acceptor, task); + self.task_controller + .spawn_cancellable_with_rt(zenoh_runtime::ZRuntime::Acceptor, task); // TODO(yuyuan): Integrate the above async task into TransportMulticastPeer // Store the new peer