kmwebnet/OpenSK
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

large blob commit is one transaction

Browse Source
This commit is contained in:
Fabian Kaczmarczyck
2021-01-22 14:16:34 +01:00
parent 3517b1163d
commit cf8b54b39c
1 changed files with 17 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
src/ctap/storage.rs
View File

@@ -514,26 +514,25 @@ impl PersistentStore {
&mut self, &mut self,
large_blob_array: &[u8], large_blob_array: &[u8],
) -> Result<(), Ctap2StatusCode> { ) -> Result<(), Ctap2StatusCode> {
let mut large_blob_index = 0; if large_blob_array.len() > MAX_LARGE_BLOB_ARRAY_SIZE {
let mut shard_key = key::LARGE_BLOB_SHARDS.start; return Err(Ctap2StatusCode::CTAP2_ERR_VENDOR_INTERNAL_ERROR);
while large_blob_index < large_blob_array.len() { }
if !key::LARGE_BLOB_SHARDS.contains(&shard_key) { const MIN_SHARD_KEY: usize = key::LARGE_BLOB_SHARDS.start;
return Err(Ctap2StatusCode::CTAP2_ERR_VENDOR_INTERNAL_ERROR); const SHARD_COUNT: usize = key::LARGE_BLOB_SHARDS.end - MIN_SHARD_KEY;
let mut transactions = Vec::with_capacity(SHARD_COUNT);
for shard_key in MIN_SHARD_KEY..key::LARGE_BLOB_SHARDS.end {
let large_blob_index = (shard_key - MIN_SHARD_KEY) * SHARD_SIZE;
if large_blob_array.len() > large_blob_index {
let shard_length = cmp::min(SHARD_SIZE, large_blob_array.len() - large_blob_index);
transactions.push(StoreUpdate::Insert {
key: shard_key,
value: &large_blob_array[large_blob_index..large_blob_index + shard_length],
});
} else {
transactions.push(StoreUpdate::Remove { key: shard_key });
} }
let shard_length = cmp::min(SHARD_SIZE, large_blob_array.len() - large_blob_index);
self.store.insert(
shard_key,
&large_blob_array[large_blob_index..large_blob_index + shard_length],
)?;
large_blob_index += shard_length;
shard_key += 1;
} }
// The length is not stored, so overwrite old entries explicitly. Ok(self.store.transaction(&transactions)?)
for key in shard_key..key::LARGE_BLOB_SHARDS.end {
// Assuming the store optimizes out unnecessary removes.
self.store.remove(key)?;
}
Ok(())
} }
/// Returns the attestation private key if defined. /// Returns the attestation private key if defined.