diff options
| author | Alex Auvolat <alex@adnab.me> | 2024-03-21 14:06:59 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2024-03-26 15:01:34 +0100 |
| commit | 74949c69cbf1a8222b6d10a02fcf5fe139ccb560 (patch) | |
| tree | 54128ccf24e8598c52c2a5366ad0b509bf1c296e /src/model/s3/mpu_table.rs | |
| parent | 7e0107c47db71e8da13990c9111ebde8cbf60d8f (diff) | |
| download | garage-74949c69cbf1a8222b6d10a02fcf5fe139ccb560.tar.gz garage-74949c69cbf1a8222b6d10a02fcf5fe139ccb560.zip | |
[s3-checksum] implement x-amz-checksum-* headers
Diffstat (limited to 'src/model/s3/mpu_table.rs')
| -rw-r--r-- | src/model/s3/mpu_table.rs | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/model/s3/mpu_table.rs b/src/model/s3/mpu_table.rs index 238cbf11..c9f79caf 100644 --- a/src/model/s3/mpu_table.rs +++ b/src/model/s3/mpu_table.rs @@ -17,6 +17,7 @@ pub const PARTS: &str = "parts"; pub const BYTES: &str = "bytes"; mod v09 { + use crate::s3::object_table::ChecksumValue; use garage_util::crdt; use garage_util::data::Uuid; use serde::{Deserialize, Serialize}; @@ -61,6 +62,9 @@ mod v09 { pub version: Uuid, /// ETag of the content of this part (known only once done uploading) pub etag: Option<String>, + /// Checksum requested by x-amz-checksum-algorithm + #[serde(default)] + pub checksum: Option<ChecksumValue>, /// Size of this part (known only once done uploading) pub size: Option<u64>, } @@ -155,6 +159,11 @@ impl Crdt for MpuPart { (Some(x), Some(y)) if x < y => other.size, (x, _) => x, }; + self.checksum = match (self.checksum.take(), &other.checksum) { + (None, Some(_)) => other.checksum.clone(), + (Some(x), Some(y)) if x < *y => other.checksum.clone(), + (x, _) => x, + }; } } |