use crate::stackblur::stack_blur_pass::StackBlurWorkingPass;
use crate::unsafe_slice::UnsafeSlice;
use crate::wasm32::*;
use std::arch::wasm32::*;
pub(crate) struct HorizontalWasmStackBlurPass<const CN: usize> {}
impl<const CN: usize> Default for HorizontalWasmStackBlurPass<CN> {
fn default() -> Self {
HorizontalWasmStackBlurPass::<CN> {}
}
}
impl<const CN: usize> HorizontalWasmStackBlurPass<CN> {
#[inline]
#[target_feature(enable = "simd128")]
fn pass_impl(
&self,
pixels: &UnsafeSlice<u8>,
stride: u32,
width: u32,
height: u32,
radius: u32,
thread: usize,
total_threads: usize,
) {
unsafe {
let div = ((radius * 2) + 1) as usize;
let mut _xp;
let mut sp;
let mut stack_start;
let mut stacks = vec![0i32; 4 * div];
let mul_value = f32x4_splat(1. / ((radius as f32 + 1.) * (radius as f32 + 1.)));
let wm = width - 1;
let div = (radius * 2) + 1;
let min_y = thread * height as usize / total_threads;
let max_y = (thread + 1) * height as usize / total_threads;
for y in min_y..max_y {
let mut sums = i32x4_splat(0i32);
let mut sum_in = i32x4_splat(0i32);
let mut sum_out = i32x4_splat(0i32);
let mut src_ptr = stride as usize * y;
let src_pixel = load_u8_s32_fast::<CN>(pixels.get_ptr(src_ptr));
for i in 0..=radius {
let stack_value = stacks.as_mut_ptr().add(i as usize * 4);
v128_store(stack_value as *mut v128, src_pixel);
sums = i32x4_add(sums, i32x4_mul(src_pixel, i32x4_splat(i as i32 + 1)));
sum_out = i32x4_add(sum_out, src_pixel);
}
for i in 1..=radius {
if i <= wm {
src_ptr += CN;
}
let stack_ptr = stacks.as_mut_ptr().add((i + radius) as usize * 4);
let src_pixel = load_u8_s32_fast::<CN>(pixels.get_ptr(src_ptr));
v128_store(stack_ptr as *mut v128, src_pixel);
sums = i32x4_add(
sums,
i32x4_mul(src_pixel, i32x4_splat(radius as i32 + 1 - i as i32)),
);
sum_in = i32x4_add(sum_in, src_pixel);
}
sp = radius;
_xp = radius;
if _xp > wm {
_xp = wm;
}
src_ptr = CN * _xp as usize + y * stride as usize;
let mut dst_ptr = y * stride as usize;
for _ in 0..width {
let store_ld = pixels.get_ptr(dst_ptr);
let blurred = f32x4_nearest(f32x4_mul(f32x4_convert_i32x4(sums), mul_value));
let prepared_u16 = u32x4_pack_trunc_u16x8(blurred, blurred);
let blurred = u16x8_pack_trunc_u8x16(prepared_u16, prepared_u16);
w_store_u8x8_m4::<CN>(store_ld, blurred);
dst_ptr += CN;
sums = i32x4_sub(sums, sum_out);
stack_start = sp + div - radius;
if stack_start >= div {
stack_start -= div;
}
let stack = stacks.as_mut_ptr().add(stack_start as usize * 4);
let stack_val = v128_load(stack as *const v128);
sum_out = i32x4_sub(sum_out, stack_val);
if _xp < wm {
src_ptr += CN;
_xp += 1;
}
let src_pixel = load_u8_s32_fast::<CN>(pixels.get_ptr(src_ptr));
v128_store(stack.cast(), src_pixel);
sum_in = i32x4_add(sum_in, src_pixel);
sums = i32x4_add(sums, sum_in);
sp += 1;
if sp >= div {
sp = 0;
}
let stack = stacks.as_ptr().add(sp as usize * 4);
let stack_val = v128_load(stack.cast());
sum_out = i32x4_add(sum_out, stack_val);
sum_in = i32x4_add(sum_in, stack_val);
}
}
}
}
}
impl<const CN: usize> StackBlurWorkingPass<u8, CN> for HorizontalWasmStackBlurPass<CN> {
fn pass(
&self,
pixels: &UnsafeSlice<u8>,
stride: u32,
width: u32,
height: u32,
radius: u32,
thread: usize,
total_threads: usize,
) {
self.pass_impl(pixels, stride, width, height, radius, thread, total_threads);
}
}