silence a few compiler warnings

about unnecessary 'mut's and 'use's

compute_tools/src/compute.rs

@@ -30,7 +30,6 @@ use std::sync::atomic::{AtomicU32, Ordering};
 use std::sync::{Arc, Condvar, Mutex, RwLock};
 use std::time::{Duration, Instant};
 use std::{env, fs};
-use tokio::io::AsyncReadExt;
 use tokio::spawn;
 use tokio_util::io::StreamReader;
 use tracing::{Instrument, debug, error, info, instrument, warn};

pageserver/client_grpc/src/lib.rs

@@ -25,11 +25,6 @@ pub mod request_tracker;
 use tonic::transport::Channel;
 
 use metrics::{IntCounterVec, core::Collector};
-use crate::client_cache::{PooledItemFactory};
-
-use tokio::sync::mpsc;
-use async_trait::async_trait;
-
 
 #[derive(Error, Debug)]
 pub enum PageserverClientError {

pageserver/client_grpc/src/request_tracker.rs

@@ -15,7 +15,7 @@ use tonic::{transport::{Channel}, Request};
 use crate::ClientCacheOptions;
 use crate::PageserverClientAggregateMetrics;
 use tokio::sync::Mutex;
-use std::sync::atomic::{AtomicU64, Ordering};
+use std::sync::atomic::AtomicU64;
 
 use utils::shard::ShardIndex;
 
@@ -313,7 +313,7 @@ impl RequestTracker {
         req: GetPageRequest,
     ) -> Result<GetPageResponse, tonic::Status> {
         loop {
-            let mut request = req.clone();
+            let request = req.clone();
             // Increment cur_id
             //let request_id = self.cur_id.fetch_add(1, Ordering::SeqCst) + 1;
             let request_id = request.request_id;
@@ -531,7 +531,7 @@ impl ShardedRequestTracker {
     ) -> Result<u64, tonic::Status> {
         let shard_index = ShardIndex::unsharded();
         let inner = self.inner.lock().await;
-        let mut tracker: RequestTracker;
+        let tracker: RequestTracker;
         if let Some(t) = inner.trackers.get(&shard_index) {
             tracker = t.clone();
         } else {
@@ -552,7 +552,7 @@ impl ShardedRequestTracker {
     ) -> Result<u32, tonic::Status> {
         let shard_index = ShardIndex::unsharded();
         let inner = self.inner.lock().await;
-        let mut tracker: RequestTracker;
+        let tracker: RequestTracker;
         if let Some(t) = inner.trackers.get(&shard_index) {
             tracker = t.clone();
         } else {
@@ -573,7 +573,7 @@ impl ShardedRequestTracker {
     ) -> Result<bool, tonic::Status> {
         let shard_index = ShardIndex::unsharded();
         let inner = self.inner.lock().await;
-        let mut tracker: RequestTracker;
+        let tracker: RequestTracker;
         if let Some(t) = inner.trackers.get(&shard_index) {
             tracker = t.clone();
         } else {

pageserver/pagebench/src/cmd/getpage_latest_lsn.rs

@@ -5,7 +5,6 @@ use std::pin::Pin;
 use std::sync::atomic::{AtomicU64, Ordering};
 use std::sync::{Arc, Mutex};
 use std::time::{Duration, Instant};
-use std::io::Error;
 
 use anyhow::Context;
 use async_trait::async_trait;
@@ -27,8 +26,6 @@ use utils::id::TenantTimelineId;
 use utils::lsn::Lsn;
 use utils::shard::ShardIndex;
 
-use tonic::transport::Channel;
-
 use axum::Router;
 use axum::body::Body;
 use axum::extract::State;

pgxn/neon/communicator/src/worker_process/main_loop.rs

@@ -98,7 +98,7 @@ pub(super) async fn init(
         .integrated_cache_init_struct
         .worker_process_init(last_lsn, file_cache);
 
-    let mut request_tracker = ShardedRequestTracker::new();
+    let request_tracker = ShardedRequestTracker::new();
     request_tracker.update_shard_map(shard_map,
         None,
         tenant_id,