diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-04-27 17:57:54 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-06-09 16:23:37 +0200 |
| commit | 38d6ac429506f9f488ac522581b12fa530442a59 (patch) | |
| tree | ac3d2b81f50c9b91038019649c3b096afeeb9a3d /src/model/helper/bucket.rs | |
| parent | 6005491cd8adf569c0b7f88fc6b3af3f166963ea (diff) | |
| download | garage-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.rs | 6 |
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, |