diff --git a/io/zenoh-transport/src/unicast/lowlatency/transport.rs b/io/zenoh-transport/src/unicast/lowlatency/transport.rs index 86bb81f71b..5d40f394f4 100644 --- a/io/zenoh-transport/src/unicast/lowlatency/transport.rs +++ b/io/zenoh-transport/src/unicast/lowlatency/transport.rs @@ -11,8 +11,6 @@ // Contributors: // ZettaScale Zenoh Team, // -#[cfg(feature = "transport_unixpipe")] -use super::link::send_with_link; #[cfg(feature = "stats")] use crate::stats::TransportStats; use crate::{ @@ -24,20 +22,12 @@ use crate::{ TransportManager, TransportPeerEventHandler, }; use async_executor::Task; -#[cfg(feature = "transport_unixpipe")] -use async_std::sync::RwLockUpgradableReadGuard; use async_std::sync::{Mutex as AsyncMutex, MutexGuard as AsyncMutexGuard, RwLock}; use async_std::task::JoinHandle; use async_trait::async_trait; use std::sync::{Arc, RwLock as SyncRwLock}; use std::time::Duration; -#[cfg(feature = "transport_unixpipe")] -use zenoh_core::zasyncread_upgradable; use zenoh_core::{zasynclock, zasyncread, zasyncwrite, zread, zwrite}; -#[cfg(feature = "transport_unixpipe")] -use zenoh_link::unixpipe::UNIXPIPE_LOCATOR_PREFIX; -use zenoh_link::Link; -#[cfg(feature = "transport_unixpipe")] use zenoh_link::Link; use zenoh_protocol::network::NetworkMessage; use zenoh_protocol::transport::TransportBodyLowLatency; @@ -47,7 +37,6 @@ use zenoh_protocol::{ core::{WhatAmI, ZenohId}, transport::close, }; -#[cfg(not(feature = "transport_unixpipe"))] use zenoh_result::{zerror, ZResult}; /*************************************/ diff --git a/io/zenoh-transport/src/unicast/universal/transport.rs b/io/zenoh-transport/src/unicast/universal/transport.rs index d9ed9f03b9..bc8faac03d 100644 --- a/io/zenoh-transport/src/unicast/universal/transport.rs +++ b/io/zenoh-transport/src/unicast/universal/transport.rs @@ -287,7 +287,7 @@ impl TransportUnicastTrait for TransportUnicastUniversal { other_initial_sn: TransportSn, other_lease: Duration, ) -> AddLinkResult { - let _add_link_guard = zasynclock!(self.add_link_lock); + let add_link_guard = zasynclock!(self.add_link_lock); // Check if we can add more inbound links { @@ -336,7 +336,7 @@ impl TransportUnicastTrait for TransportUnicastUniversal { *guard = links.into_boxed_slice(); drop(guard); - drop(_add_link_guard); + drop(add_link_guard); // create a callback to start the link let start_link = Box::new(move || {