aboutsummaryrefslogtreecommitdiff
path: root/src/model/helper/bucket.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-04-27 17:57:54 +0200
committerAlex Auvolat <alex@adnab.me>2023-06-09 16:23:37 +0200
commit38d6ac429506f9f488ac522581b12fa530442a59 (patch)
treeac3d2b81f50c9b91038019649c3b096afeeb9a3d /src/model/helper/bucket.rs
parent6005491cd8adf569c0b7f88fc6b3af3f166963ea (diff)
downloadgarage-38d6ac429506f9f488ac522581b12fa530442a59.tar.gz
garage-38d6ac429506f9f488ac522581b12fa530442a59.zip
New multipart upload table layout
Diffstat (limited to 'src/model/helper/bucket.rs')
-rw-r--r--src/model/helper/bucket.rs6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/model/helper/bucket.rs b/src/model/helper/bucket.rs
index 4a488d7f..ff711d29 100644
--- a/src/model/helper/bucket.rs
+++ b/src/model/helper/bucket.rs
@@ -496,7 +496,9 @@ impl<'a> BucketHelper<'a> {
.get_range(
bucket_id,
start,
- Some(ObjectFilter::IsUploading),
+ Some(ObjectFilter::IsUploading {
+ check_multipart: None,
+ }),
1000,
EnumerationOrder::Forward,
)
@@ -508,7 +510,7 @@ impl<'a> BucketHelper<'a> {
let aborted_versions = object
.versions()
.iter()
- .filter(|v| v.is_uploading() && v.timestamp < older_than)
+ .filter(|v| v.is_uploading(None) && v.timestamp < older_than)
.map(|v| ObjectVersion {
state: ObjectVersionState::Aborted,
uuid: v.uuid,