use crate::word::Word;
use crate::Result;
pub trait Read {
fn start_read(&mut self, bytes: &[u8]);
fn finish_read(&self) -> Result<()>;
fn read_bits(&mut self, bits: usize) -> Result<Word>;
fn read_bit(&mut self) -> Result<bool>;
fn read_bytes(&mut self, len: usize) -> Result<&[u8]>;
fn read_zeros(&mut self, max: usize) -> Result<usize>;
}
#[cfg(all(test, not(miri)))]
mod tests {
use crate::bit_buffer::BitBuffer;
use crate::nightly::div_ceil;
use crate::read::Read;
use crate::word::*;
use crate::word_buffer::WordBuffer;
use paste::paste;
use test::{black_box, Bencher};
fn bench_start_read<T: Read + Default>(b: &mut Bencher) {
let bytes = vec![123u8; 6659];
let mut buf = T::default();
b.iter(|| {
let bytes = black_box(bytes.as_slice());
buf.start_read(bytes);
black_box(&mut buf);
});
}
const TIMES: usize = 1000;
fn bench_read_bit<T: Read + Default>(b: &mut Bencher) {
let bytes = vec![123u8; div_ceil(TIMES, u8::BITS as usize)];
let mut buf = T::default();
buf.start_read(&bytes);
b.iter(|| {
let buf = black_box(&mut buf);
buf.start_read(black_box(&bytes));
for _ in 0..black_box(TIMES) {
black_box(buf.read_bit().unwrap());
}
});
}
fn bench_read_bits<T: Read + Default>(b: &mut Bencher, bits: usize) {
let bytes = vec![123u8; div_ceil(bits * TIMES, u8::BITS as usize)];
let mut buf = T::default();
buf.start_read(&bytes);
b.iter(|| {
let buf = black_box(&mut buf);
buf.start_read(black_box(&bytes));
for _ in 0..black_box(TIMES) {
black_box(buf.read_bits(bits).unwrap());
}
});
}
fn bench_read_bytes<T: Read + Default>(b: &mut Bencher, byte_count: usize) {
let bytes = vec![123u8; byte_count * TIMES + 1];
let mut buf = T::default();
buf.start_read(&bytes);
b.iter(|| {
let buf = black_box(&mut buf);
buf.start_read(black_box(&bytes));
buf.read_bit().unwrap(); for _ in 0..black_box(TIMES) {
black_box(buf.read_bytes(byte_count).unwrap());
}
});
}
fn bench_read_zeros<T: Read + Default>(b: &mut Bencher) {
let bytes = vec![1 << 7; TIMES];
let mut buf = T::default();
buf.start_read(&bytes);
b.iter(|| {
let buf = black_box(&mut buf);
buf.start_read(black_box(&bytes));
for _ in 0..black_box(TIMES) {
black_box(buf.read_zeros(black_box(WORD_BITS - 1)).unwrap());
buf.read_bit().unwrap();
}
});
}
macro_rules! bench_read_bits {
($name:ident, $T:ty, $n:literal) => {
paste! {
#[bench]
fn [<bench_ $name _read_bits_ $n>](b: &mut Bencher) {
bench_read_bits::<$T>(b, $n);
}
}
};
}
macro_rules! bench_read_bytes {
($name:ident, $T:ty, $n:literal) => {
paste! {
#[bench]
fn [<bench_ $name _read_bytes_ $n>](b: &mut Bencher) {
bench_read_bytes::<$T>(b, $n);
}
}
};
}
macro_rules! bench_read {
($name:ident, $T:ty) => {
paste! {
#[bench]
fn [<bench_ $name _copy_from_slice>](b: &mut Bencher) {
bench_start_read::<$T>(b);
}
#[bench]
fn [<bench_ $name _read_bit1>](b: &mut Bencher) {
bench_read_bit::<$T>(b);
}
#[bench]
fn [<bench_ $name _read_zeros>](b: &mut Bencher) {
bench_read_zeros::<$T>(b);
}
}
bench_read_bits!($name, $T, 5);
bench_read_bits!($name, $T, 41);
bench_read_bytes!($name, $T, 1);
bench_read_bytes!($name, $T, 10);
bench_read_bytes!($name, $T, 100);
bench_read_bytes!($name, $T, 1000);
};
}
bench_read!(bit_buffer, BitBuffer);
bench_read!(word_buffer, WordBuffer);
}