diff options
| author | Alex Auvolat <alex@adnab.me> | 2024-03-21 14:06:59 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2024-03-26 14:56:47 +0100 |
| commit | 8fbc75059a018b288ae828c948285aedb31f8489 (patch) | |
| tree | bfeafe807c4524d0d5ce63c56f3003f5827984f1 /src/model/s3/mpu_table.rs | |
| parent | 7e0107c47db71e8da13990c9111ebde8cbf60d8f (diff) | |
| download | garage-8fbc75059a018b288ae828c948285aedb31f8489.tar.gz garage-8fbc75059a018b288ae828c948285aedb31f8489.zip | |
[s3-checksum] implement x-amz-checksum-* headerss3-checksum
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, + }; } } |