Adding one more test

darleybarreto

Jul 31, 2021, 2:48 PM

57ARVVZEGNKP7DI5QGQWSZ22Q5T3YXXVDX2EC7PS5ITAZTLLC7HQC

Dependencies

• [2] NOSZA4ZM Fixing tests
• [3] HEFGMMUM Start oxidizing 1/N
• [4] K6L5F26W Fixing sequential test.
• [5] IB4L4N5M Fixing the lifetimes for `Seekable`
• [6] IH334Q5A Reboot
• [7] 6XB4RDRQ Adding changes from original impl

Change contents

• replacement in src/lib.rs at line 307
  [3.5624]→[2.306:366](∅→∅)
  − self.xxh_state.finish() as u32 & 0xFFFFFFFFu32

  −
  [3.5624]

  [3.5676]
  + self.xxh_state.finish() as u32
• replacement in src/lib.rs at line 771
  [3.16267]→[2.867:943](∅→∅)
  − && (self.xxh_state.finish() as u32 & 0xFFFFFFFFu32)
  [3.16267]

  [3.16336]
  + && self.xxh_state.finish() as u32
• replacement in src/lib.rs at line 811
  [3.17662]→[3.3470:3505](∅→∅)
  − let size = (&input).len();
  [3.17662]

  [3.600]
  + let size = input.len();
• edit in src/lib.rs at line 1123
  [3.261627]→[2.1498:1567](∅→∅)
  − let mut frames: Vec<CompressedFrame<D>> = Vec::with_capacity(n);
• replacement in src/lib.rs at line 1131
  [3.262053]→[2.1568:1573](∅→∅)
  −
  [3.262053]

  [3.25956]
  +
• replacement in src/lib.rs at line 1133
  [3.26025]→[2.1574:1606](∅→∅)
  − unsafe {frames.set_len(n)};
  [3.26025]

  [3.26059]
  + unsafe { frames.set_len(n) };
• replacement in src/lib.rs at line 1145
  [3.262481]→[2.1653:1654](∅→∅)
  − }
  [3.262481]
  + }
• replacement in tests/tests.rs at line 8
  [2.2596]→[2.2596:2743](∅→∅)
  − const chunk_size: usize = 256;

  − parallel_compress::<&mut Vec<u8>, [u8; chunk_size]>(data, &mut output, 10, 4, chunk_size).unwrap();
  [2.2596]

  [2.2743]
  + const chunk_size: usize = 200;

  + parallel_compress::<&mut Vec<u8>, [u8; chunk_size]>(data, &mut output, 10, 4, chunk_size)

  + .unwrap();
• replacement in tests/tests.rs at line 31
  [2.3358]→[2.3358:3497](∅→∅)
  − const chunk_size: usize = 256;

  − parallel_compress::<&mut Vec<u8>, [u8; chunk_size]>(data, &mut output, 10, 4, chunk_size).unwrap();
  [2.3358]

  [2.3497]
  + const chunk_size: usize = 128;

  + parallel_compress::<&mut Vec<u8>, [u8; chunk_size]>(data, &mut output, 10, 4, chunk_size)

  + .unwrap();
• replacement in tests/tests.rs at line 35
  [2.3520]→[2.3520:3557](∅→∅)
  − let mut decomp = vec![0;b_size];
  [2.3520]

  [2.3557]
  + let mut decomp = vec![0; b_size];
• replacement in tests/tests.rs at line 43
  [2.3823]→[2.3823:3941](∅→∅)
  − let r = s.decompress(&mut decomp[i*dst_size..(i+1)*dst_size], dst_size as u64, start_offset as u64).unwrap();
  [2.3823]

  [2.3941]
  + let r = s

  + .decompress(

  + &mut decomp[i * dst_size..(i + 1) * dst_size],

  + dst_size as u64,

  + start_offset as u64,

  + )

  + .unwrap();
• edit in tests/tests.rs at line 64
  [2.4185]

  [2.4185]
  + fn test_par_3() {

  + let mut output = Vec::new();

  + const chunk_size: usize = 100;

  + parallel_compress::<&mut Vec<u8>, [u8; chunk_size]>(data, &mut output, 10, 4, chunk_size)

  + .unwrap();

  + let b_size = 100;

  + let mut decomp = vec![0; b_size];

  + let mut s = { Seekable::init_buf(output.as_mut_slice()).unwrap() };

  + let mut start_offset = 0;

  + let end_offset = data.len();

  + let mut i = 0;

  + let mut string_stream = String::new(); // just to check the final value

  +

  + while start_offset < end_offset {

  + let dst_size = std::cmp::min(end_offset - start_offset, b_size);

  + let r = s

  + .decompress(&mut decomp[..], dst_size as u64, start_offset as u64)

  + .unwrap();

  +

  + string_stream.push_str(std::str::from_utf8(&decomp[..r]).unwrap());

  + assert_eq!(&data[i * b_size..i * b_size + dst_size], &decomp[..r]);

  +

  + if r == 0 {

  + break;

  + }

  + i += 1;

  + start_offset += r;

  + }

  +

  + print!("{:?}", string_stream);

  + }

  +

  + #[test]
• replacement in tests/tests.rs at line 133
  [2.5430]→[2.5430:5431](∅→∅)
  − }
  [2.5430]
  + }