Line data    Source code

       1              : use std::collections::HashMap;
       2              : 
       3              : const BLOCK_SIZE: usize = 8192;
       4              : 
       5              : /// A simple in-memory implementation of a block storage. Can be used to implement external
       6              : /// storage in tests.
       7              : pub struct BlockStorage {
       8              :     blocks: HashMap<u64, [u8; BLOCK_SIZE]>,
       9              : }
      10              : 
      11              : impl Default for BlockStorage {
      12            0 :     fn default() -> Self {
      13            0 :         Self::new()
      14            0 :     }
      15              : }
      16              : 
      17              : impl BlockStorage {
      18        87275 :     pub fn new() -> Self {
      19        87275 :         BlockStorage {
      20        87275 :             blocks: HashMap::new(),
      21        87275 :         }
      22        87275 :     }
      23              : 
      24        37827 :     pub fn read(&self, pos: u64, buf: &mut [u8]) {
      25        37827 :         let mut buf_offset = 0;
      26        37827 :         let mut storage_pos = pos;
      27        56323 :         while buf_offset < buf.len() {
      28        18496 :             let block_id = storage_pos / BLOCK_SIZE as u64;
      29        18496 :             let block = self.blocks.get(&block_id).unwrap_or(&[0; BLOCK_SIZE]);
      30        18496 :             let block_offset = storage_pos % BLOCK_SIZE as u64;
      31        18496 :             let block_len = BLOCK_SIZE as u64 - block_offset;
      32        18496 :             let buf_len = buf.len() - buf_offset;
      33        18496 :             let copy_len = std::cmp::min(block_len as usize, buf_len);
      34        18496 :             buf[buf_offset..buf_offset + copy_len]
      35        18496 :                 .copy_from_slice(&block[block_offset as usize..block_offset as usize + copy_len]);
      36        18496 :             buf_offset += copy_len;
      37        18496 :             storage_pos += copy_len as u64;
      38        18496 :         }
      39        37827 :     }
      40              : 
      41       144056 :     pub fn write(&mut self, pos: u64, buf: &[u8]) {
      42       144056 :         let mut buf_offset = 0;
      43       144056 :         let mut storage_pos = pos;
      44       288556 :         while buf_offset < buf.len() {
      45       144500 :             let block_id = storage_pos / BLOCK_SIZE as u64;
      46       144500 :             let block = self.blocks.entry(block_id).or_insert([0; BLOCK_SIZE]);
      47       144500 :             let block_offset = storage_pos % BLOCK_SIZE as u64;
      48       144500 :             let block_len = BLOCK_SIZE as u64 - block_offset;
      49       144500 :             let buf_len = buf.len() - buf_offset;
      50       144500 :             let copy_len = std::cmp::min(block_len as usize, buf_len);
      51       144500 :             block[block_offset as usize..block_offset as usize + copy_len]
      52       144500 :                 .copy_from_slice(&buf[buf_offset..buf_offset + copy_len]);
      53       144500 :             buf_offset += copy_len;
      54       144500 :             storage_pos += copy_len as u64
      55              :         }
      56       144056 :     }
      57              : }