#[cfg(target_arch = "x86_64")]
use super::avx2;
use super::portable;
use crate::sync::OnceLock;
use crate::wire::frame::sizes::F32_BYTES;
struct Kernels {
fits: fn(&[f64]) -> bool,
narrow: fn(&[f64], &mut [u8]),
widen: fn(&[u8], &mut [f64]),
}
fn kernels() -> &'static Kernels {
static KERNELS: OnceLock<Kernels> = OnceLock::new();
KERNELS.get_or_init(|| {
#[cfg(target_arch = "x86_64")]
if std::arch::is_x86_feature_detected!("avx2") {
return Kernels {
fits: avx2::fits,
narrow: avx2::narrow,
widen: avx2::widen,
};
}
Kernels {
fits: portable::fits,
narrow: portable::narrow,
widen: portable::widen,
}
})
}
#[must_use]
pub fn fits_f32(items: &[f64]) -> bool {
(kernels().fits)(items)
}
pub fn put_narrow(out: &mut Vec<u8>, items: &[f64]) {
let at = out.len();
out.resize(at + items.len() * F32_BYTES, 0);
(kernels().narrow)(items, &mut out[at..]);
}
pub fn put_wide(out: &mut Vec<u8>, items: &[f64]) {
out.extend(items.iter().flat_map(|f| f.to_le_bytes()));
}
pub fn put_f32s(out: &mut Vec<u8>, items: &[f32]) {
out.extend(items.iter().flat_map(|f| f.to_le_bytes()));
}
#[must_use]
pub fn widen(raw: &[u8]) -> Vec<f64> {
let mut out = vec![0.0; raw.len() / F32_BYTES];
(kernels().widen)(raw, &mut out);
out
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn the_kernels_agree_with_the_portable_ones() {
let exact: Vec<f64> = (0..37).map(|i| f64::from(i) * 0.5 - 3.0).collect();
let mut odd = exact.clone();
odd[33] = 0.1;
let mut zero = exact.clone();
zero[2] = -0.0;
for items in [&exact, &odd, &zero] {
assert_eq!(fits_f32(items), portable::fits(items));
}
assert!(fits_f32(&exact) && !fits_f32(&odd) && fits_f32(&zero));
let (mut a, mut b) = (Vec::new(), vec![0; exact.len() * F32_BYTES]);
put_narrow(&mut a, &exact);
portable::narrow(&exact, &mut b);
assert_eq!(a, b);
assert_eq!(widen(&a), exact);
}
}