diff --git a/datman/src/bin/datman.rs b/datman/src/bin/datman.rs index 1667476..5b13f50 100644 --- a/datman/src/bin/datman.rs +++ b/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") ))?) diff --git a/datman/src/remote/backup_source_responder.rs b/datman/src/remote/backup_source_responder.rs index 1081bfe..dd84ad4 100644 --- a/datman/src/remote/backup_source_responder.rs +++ b/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 { diff --git a/yama/src/bin/yama.rs b/yama/src/bin/yama.rs index 0634b35..bff675f 100644 --- a/yama/src/bin/yama.rs +++ b/yama/src/bin/yama.rs @@ -116,7 +116,7 @@ fn wrapped_main() -> anyhow::Result { match &opts.command { PileCommand::Retrieve { pointer_name, - subset, + subset: _, destination, num_workers: workers, } => { diff --git a/yama/src/pile/encryption.rs b/yama/src/pile/encryption.rs index 0b61b75..b870272 100644 --- a/yama/src/pile/encryption.rs +++ b/yama/src/pile/encryption.rs @@ -114,8 +114,8 @@ impl RawPile for RawPileEncryptor { fn build_storage_pipeline( &self, - settings: StoragePipelineSettings, - controller_send: Sender, + _settings: StoragePipelineSettings, + _controller_send: Sender, ) -> anyhow::Result)>> { todo!() } diff --git a/yama/src/pile/local_sqlitebloblogs.rs b/yama/src/pile/local_sqlitebloblogs.rs index de2d91e..f287688 100644 --- a/yama/src/pile/local_sqlitebloblogs.rs +++ b/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)", diff --git a/yama/src/remote/requester.rs b/yama/src/remote/requester.rs index 2039043..84f5774 100644 --- a/yama/src/remote/requester.rs +++ b/yama/src/remote/requester.rs @@ -349,8 +349,8 @@ impl RawPile for Requester { fn build_storage_pipeline( &self, - settings: StoragePipelineSettings, - controller_send: Sender, + _settings: StoragePipelineSettings, + _controller_send: Sender, ) -> anyhow::Result)>> { // 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