aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorAlex <lx@deuxfleurs.fr>2025-02-14 17:32:30 +0000
committerAlex <lx@deuxfleurs.fr>2025-02-14 17:32:30 +0000
commit859b38b0d260a0833e5e604c873c7d259acff22e (patch)
tree6b9cf06b8ec2240035c61d610fb2419c08f8fd56 /src
parent89c944ebd6a08f27dae44d16e81c9487ec9f9c30 (diff)
parent2729a71d9dc55f142a7f89236b1c868a1bdb1c0f (diff)
downloadgarage-859b38b0d260a0833e5e604c873c7d259acff22e.tar.gz
garage-859b38b0d260a0833e5e604c873c7d259acff22e.zip
Merge pull request 'fix compilation warnings' (#959) from fixes into mainHEADmain
Reviewed-on: https://git.deuxfleurs.fr/Deuxfleurs/garage/pulls/959
Diffstat (limited to 'src')
-rw-r--r--src/api/s3/api_server.rs1
-rw-r--r--src/api/s3/list.rs3
-rw-r--r--src/garage/tests/common/garage.rs6
-rw-r--r--src/model/garage.rs2
-rw-r--r--src/model/helper/locked.rs9
-rw-r--r--src/model/s3/lifecycle_worker.rs6
6 files changed, 13 insertions, 14 deletions
diff --git a/src/api/s3/api_server.rs b/src/api/s3/api_server.rs
index bf48bba1..14fd03c3 100644
--- a/src/api/s3/api_server.rs
+++ b/src/api/s3/api_server.rs
@@ -317,7 +317,6 @@ impl ApiHandler for S3ApiServer {
} => {
let query = ListPartsQuery {
bucket_name: ctx.bucket_name.clone(),
- bucket_id,
key,
upload_id,
part_number_marker: part_number_marker.map(|p| p.min(10000)),
diff --git a/src/api/s3/list.rs b/src/api/s3/list.rs
index a5cc03b0..94c2c895 100644
--- a/src/api/s3/list.rs
+++ b/src/api/s3/list.rs
@@ -54,7 +54,6 @@ pub struct ListMultipartUploadsQuery {
#[derive(Debug)]
pub struct ListPartsQuery {
pub bucket_name: String,
- pub bucket_id: Uuid,
pub key: String,
pub upload_id: String,
pub part_number_marker: Option<u64>,
@@ -1245,10 +1244,8 @@ mod tests {
#[test]
fn test_fetch_part_info() -> Result<(), Error> {
- let uuid = Uuid::from([0x08; 32]);
let mut query = ListPartsQuery {
bucket_name: "a".to_string(),
- bucket_id: uuid,
key: "a".to_string(),
upload_id: "xx".to_string(),
part_number_marker: None,
diff --git a/src/garage/tests/common/garage.rs b/src/garage/tests/common/garage.rs
index db23d316..da6c624b 100644
--- a/src/garage/tests/common/garage.rs
+++ b/src/garage/tests/common/garage.rs
@@ -13,7 +13,6 @@ static GARAGE_TEST_SECRET: &str =
#[derive(Debug, Default, Clone)]
pub struct Key {
- pub name: Option<String>,
pub id: String,
pub secret: String,
}
@@ -213,10 +212,7 @@ api_bind_addr = "127.0.0.1:{admin_port}"
assert!(!key.id.is_empty(), "Invalid key: Key ID is empty");
assert!(!key.secret.is_empty(), "Invalid key: Key secret is empty");
- Key {
- name: maybe_name.map(String::from),
- ..key
- }
+ key
}
}
diff --git a/src/model/garage.rs b/src/model/garage.rs
index 29e0bddd..11c0d90f 100644
--- a/src/model/garage.rs
+++ b/src/model/garage.rs
@@ -329,7 +329,7 @@ impl Garage {
pub async fn locked_helper(&self) -> helper::locked::LockedHelper {
let lock = self.bucket_lock.lock().await;
- helper::locked::LockedHelper(self, lock)
+ helper::locked::LockedHelper(self, Some(lock))
}
}
diff --git a/src/model/helper/locked.rs b/src/model/helper/locked.rs
index 43f4f363..482e91b0 100644
--- a/src/model/helper/locked.rs
+++ b/src/model/helper/locked.rs
@@ -27,9 +27,16 @@ use crate::permission::BucketKeyPerm;
/// See issues: #649, #723
pub struct LockedHelper<'a>(
pub(crate) &'a Garage,
- pub(crate) tokio::sync::MutexGuard<'a, ()>,
+ pub(crate) Option<tokio::sync::MutexGuard<'a, ()>>,
);
+impl<'a> Drop for LockedHelper<'a> {
+ fn drop(&mut self) {
+ // make it explicit that the mutexguard lives until here
+ drop(self.1.take())
+ }
+}
+
#[allow(clippy::ptr_arg)]
impl<'a> LockedHelper<'a> {
pub fn bucket(&self) -> BucketHelper<'a> {
diff --git a/src/model/s3/lifecycle_worker.rs b/src/model/s3/lifecycle_worker.rs
index 38212a1c..bb10ba48 100644
--- a/src/model/s3/lifecycle_worker.rs
+++ b/src/model/s3/lifecycle_worker.rs
@@ -395,13 +395,13 @@ fn midnight_ts(date: NaiveDate, use_local_tz: bool) -> u64 {
.expect("bad local midnight")
.timestamp_millis() as u64;
}
- midnight.timestamp_millis() as u64
+ midnight.and_utc().timestamp_millis() as u64
}
fn next_date(ts: u64) -> NaiveDate {
- NaiveDateTime::from_timestamp_millis(ts as i64)
+ DateTime::<Utc>::from_timestamp_millis(ts as i64)
.expect("bad timestamp")
- .date()
+ .date_naive()
.succ_opt()
.expect("no next day")
}