diff --git a/bffhd/capnp/authenticationsystem.rs b/bffhd/capnp/authenticationsystem.rs index 0206f2b..197b38e 100644 --- a/bffhd/capnp/authenticationsystem.rs +++ b/bffhd/capnp/authenticationsystem.rs @@ -113,7 +113,7 @@ impl AuthenticationSystem for Authentication { f.write_char(')') } } - let mut response; + let response; let mut builder = results.get(); if let State::Running(mut session, manager) = diff --git a/bffhd/capnp/machine.rs b/bffhd/capnp/machine.rs index 013b9a1..5c19139 100644 --- a/bffhd/capnp/machine.rs +++ b/bffhd/capnp/machine.rs @@ -178,7 +178,7 @@ impl InUseServer for Machine { fn send_raw_data( &mut self, - mut params: inuse::SendRawDataParams, + params: inuse::SendRawDataParams, _: inuse::SendRawDataResults, ) -> Promise<(), ::capnp::Error> { let data: Vec = pry!(pry!(params.get()).get_data()).to_vec(); @@ -188,7 +188,7 @@ impl InUseServer for Machine { } impl ProdableServer for Machine { - fn prod_with_data(&mut self, mut params: ProdWithDataParams, _: ProdWithDataResults) -> Promise<(), Error> { + fn prod_with_data(&mut self, params: ProdWithDataParams, _: ProdWithDataResults) -> Promise<(), Error> { let data: Vec = pry!(pry!(params.get()).get_data()).to_vec(); self.resource.send_raw(data); Promise::ok(()) diff --git a/bffhd/capnp/permissionsystem.rs b/bffhd/capnp/permissionsystem.rs index 4506aa4..de5f0aa 100644 --- a/bffhd/capnp/permissionsystem.rs +++ b/bffhd/capnp/permissionsystem.rs @@ -36,7 +36,7 @@ impl PermissionSystem for Permissions { tracing::trace!("method call"); let roles = self.roles.list().collect::>(); - let mut builder = results.get(); + let builder = results.get(); let mut b = builder.init_role_list(roles.len() as u32); for (i, role) in roles.into_iter().enumerate() { let mut role_builder = b.reborrow().get(i as u32); diff --git a/bffhd/capnp/user.rs b/bffhd/capnp/user.rs index eb5cfe1..6e88ad6 100644 --- a/bffhd/capnp/user.rs +++ b/bffhd/capnp/user.rs @@ -214,7 +214,7 @@ impl card_d_e_s_fire_e_v2::Server for User { .userdata .kv .get("cardtoken") { - let mut b = results.get(); + let b = results.get(); let mut lb = b.init_token_list(1); lb.set(0, tk.as_ref()); } diff --git a/runtime/console/src/aggregate.rs b/runtime/console/src/aggregate.rs index 4029a1f..8379d62 100644 --- a/runtime/console/src/aggregate.rs +++ b/runtime/console/src/aggregate.rs @@ -7,7 +7,6 @@ use console_api::{async_ops, instrument, resources, tasks}; use crossbeam_channel::{Receiver, TryRecvError}; use futures_util::{FutureExt, StreamExt}; use std::collections::HashMap; -use std::num::NonZeroU64; use std::sync::atomic::{AtomicBool, Ordering}; use std::sync::Arc; use std::time::{Duration, Instant}; diff --git a/runtime/console/src/lib.rs b/runtime/console/src/lib.rs index c3d38af..2ecd8c8 100644 --- a/runtime/console/src/lib.rs +++ b/runtime/console/src/lib.rs @@ -1,5 +1,4 @@ use crossbeam_channel::{Sender, TrySendError}; -use std::borrow::Borrow; use std::cell::RefCell; use std::net::IpAddr; use std::sync::atomic::{AtomicUsize, Ordering}; @@ -9,7 +8,7 @@ use thread_local::ThreadLocal; use tracing::span; use tracing_core::span::Attributes; use tracing_core::{Interest, Metadata, Subscriber}; -use tracing_subscriber::layer::{Context, Filter}; +use tracing_subscriber::layer::Context; use tracing_subscriber::registry::{LookupSpan, SpanRef}; use tracing_subscriber::Layer; diff --git a/runtime/console/src/server.rs b/runtime/console/src/server.rs index b92e8c0..06997cd 100644 --- a/runtime/console/src/server.rs +++ b/runtime/console/src/server.rs @@ -4,11 +4,9 @@ use async_compat::CompatExt; use console_api::instrument; use console_api::instrument::instrument_server::{Instrument, InstrumentServer}; use console_api::tasks; -use futures_util::TryStreamExt; use std::error::Error; -use std::future::Future; use std::io::IoSlice; -use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr}; +use std::net::{IpAddr, Ipv4Addr, SocketAddr}; use std::pin::Pin; use std::task::{Context, Poll}; use tokio::io::AsyncRead as TokioAsyncRead; @@ -95,7 +93,7 @@ impl Server { } pub async fn serve( - mut self, /*, incoming: I */ + self, /*, incoming: I */ ) -> Result<(), Box> { let svc = InstrumentServer::new(self); diff --git a/runtime/executor/src/pool.rs b/runtime/executor/src/pool.rs index 9686706..aa37683 100644 --- a/runtime/executor/src/pool.rs +++ b/runtime/executor/src/pool.rs @@ -22,9 +22,6 @@ use std::marker::PhantomData; use std::mem::MaybeUninit; use std::sync::Arc; use std::time::Duration; -use tracing::field::FieldSet; -use tracing::metadata::Kind; -use tracing::{Instrument, Level, Span}; #[derive(Debug)] struct Spooler<'a> { diff --git a/runtime/executor/src/supervision.rs b/runtime/executor/src/supervision.rs index a11cfe0..6eead88 100644 --- a/runtime/executor/src/supervision.rs +++ b/runtime/executor/src/supervision.rs @@ -2,7 +2,6 @@ use lightproc::GroupId; use once_cell::sync::OnceCell; use sharded_slab::pool::Ref; use sharded_slab::{Clear, Pool}; -use std::borrow::Borrow; use std::cell; use std::cell::RefCell; use std::sync::atomic::{fence, AtomicUsize, Ordering}; diff --git a/runtime/executor/src/thread_manager.rs b/runtime/executor/src/thread_manager.rs index d8241b8..69d6b87 100644 --- a/runtime/executor/src/thread_manager.rs +++ b/runtime/executor/src/thread_manager.rs @@ -65,7 +65,7 @@ use std::{ }, thread, }; -use tracing::{debug, trace}; +use tracing::debug; /// The default thread park timeout before checking for new tasks. const THREAD_PARK_TIMEOUT: Duration = Duration::from_millis(1);