Run cargo fix

datman/src/bin/datman.rs

@@ -173,7 +173,7 @@ fn main() -> anyhow::Result<()> {
 
     let now = Utc::now();
 
-    let (shard, stopper) = BareMetricsRecorderCore::new(File::create(format!(
+    let (shard, _stopper) = BareMetricsRecorderCore::new(File::create(format!(
         "/tmp/datman_{}.baremetrics",
         now.format("%F_%H%M%S")
     ))?)

datman/src/remote/backup_source_responder.rs

@@ -91,7 +91,7 @@ pub struct ProgressSender {
 }
 
 impl ProgressSender {
-    pub fn send_now(&mut self, include_message: bool) {
+    pub fn send_now(&mut self, _include_message: bool) {
         self.sender
             .send((
                 RequestBody::Progress {

yama/src/bin/yama.rs

@@ -116,7 +116,7 @@ fn wrapped_main() -> anyhow::Result<i32> {
     match &opts.command {
         PileCommand::Retrieve {
             pointer_name,
-            subset,
+            subset: _,
             destination,
             num_workers: workers,
         } => {

yama/src/pile/encryption.rs

@@ -114,8 +114,8 @@ impl<R: RawPile> RawPile for RawPileEncryptor<R> {
 
     fn build_storage_pipeline(
         &self,
-        settings: StoragePipelineSettings,
-        controller_send: Sender<ControllerMessage>,
+        _settings: StoragePipelineSettings,
+        _controller_send: Sender<ControllerMessage>,
     ) -> anyhow::Result<Sender<(ChunkId, Vec<u8>)>> {
         todo!()
     }

yama/src/pile/local_sqlitebloblogs.rs

@@ -383,7 +383,7 @@ impl SqliteBloblogPile {
             pointers_buffered: &mut Vec<(ChunkId, BloblogPointer)>,
         ) -> anyhow::Result<()> {
             let mut inner = this.inner.lock().unwrap();
-            let mut txn = inner.connection.transaction()?;
+            let txn = inner.connection.transaction()?;
             {
                 let mut stmt = txn.prepare(
                     "INSERT OR FAIL INTO chunks (chunk_id, bloblog, offset) VALUES (?1, ?2, ?3)",

yama/src/remote/requester.rs

@@ -349,8 +349,8 @@ impl RawPile for Requester {
 
     fn build_storage_pipeline(
         &self,
-        settings: StoragePipelineSettings,
-        controller_send: Sender<ControllerMessage>,
+        _settings: StoragePipelineSettings,
+        _controller_send: Sender<ControllerMessage>,
     ) -> anyhow::Result<Sender<(ChunkId, Vec<u8>)>> {
         // this one is a little bit more complex.
         // We want to be able to send off multiple write requests at once, but not too many, so we