use std::sync::Arc;
use num_integer::Integer;
use num_complex::Complex;
use num_traits::Zero;
use strength_reduce::StrengthReducedUsize;
use primal_check::miller_rabin;
use crate::common::FFTnum;
use crate::math_utils;
use crate::{Length, IsInverse, Fft};
pub struct RadersAlgorithm<T> {
inner_fft: Arc<dyn Fft<T>>,
inner_fft_data: Box<[Complex<T>]>,
primitive_root: usize,
primitive_root_inverse: usize,
len: StrengthReducedUsize,
inplace_scratch_len: usize,
outofplace_scratch_len: usize,
inverse: bool,
}
impl<T: FFTnum> RadersAlgorithm<T> {
pub fn new(inner_fft: Arc<dyn Fft<T>>) -> Self {
let inner_fft_len = inner_fft.len();
let len = inner_fft_len + 1;
assert!(miller_rabin(len as u64), "For raders algorithm, inner_fft.len() + 1 must be prime. Expected prime number, got {} + 1 = {}", inner_fft_len, len);
let inverse = inner_fft.is_inverse();
let reduced_len = StrengthReducedUsize::new(len);
let primitive_root = math_utils::primitive_root(len as u64).unwrap() as usize;
let gcd_data = i64::extended_gcd(&(primitive_root as i64), &(len as i64));
let primitive_root_inverse = if gcd_data.x >= 0 { gcd_data.x } else { gcd_data.x + len as i64 } as usize;
let unity_scale = T::from_f64(1f64 / inner_fft_len as f64).unwrap();
let mut inner_fft_input = vec![Complex::zero(); inner_fft_len];
let mut twiddle_input = 1;
for input_cell in &mut inner_fft_input {
let twiddle = T::generate_twiddle_factor(twiddle_input, len, inverse);
*input_cell = twiddle * unity_scale;
twiddle_input = (twiddle_input * primitive_root_inverse) % reduced_len;
}
let required_inner_scratch = inner_fft.get_inplace_scratch_len();
let extra_inner_scratch = if required_inner_scratch <= inner_fft_len { 0 } else { required_inner_scratch };
let mut inner_fft_scratch = vec![Zero::zero(); required_inner_scratch];
inner_fft.process_inplace_with_scratch(&mut inner_fft_input, &mut inner_fft_scratch);
Self {
inner_fft: inner_fft,
inner_fft_data: inner_fft_input.into_boxed_slice(),
primitive_root,
primitive_root_inverse,
len: reduced_len,
inplace_scratch_len: inner_fft_len + extra_inner_scratch,
outofplace_scratch_len: extra_inner_scratch,
inverse,
}
}
fn perform_fft_out_of_place(&self, input: &mut [Complex<T>], output: &mut [Complex<T>], scratch: &mut [Complex<T>]) {
let (output_first, output) = output.split_first_mut().unwrap();
let (input_first, input) = input.split_first_mut().unwrap();
let first_input_val = *input_first;
*output_first = *input_first;
let mut input_index = 1;
for output_element in output.iter_mut() {
input_index = (input_index * self.primitive_root) % self.len;
let input_element = input[input_index - 1];
*output_first = *output_first + input_element;
*output_element = input_element;
}
let inner_scratch = if scratch.len() > 0 { &mut scratch[..] } else { &mut input[..] };
self.inner_fft.process_inplace_with_scratch(output, inner_scratch);
for ((output_cell, input_cell), &multiple) in output.iter().zip(input.iter_mut()).zip(self.inner_fft_data.iter()) {
*input_cell = (*output_cell * multiple).conj();
}
let inner_scratch = if scratch.len() > 0 { scratch } else { &mut output[..] };
self.inner_fft.process_inplace_with_scratch(input, inner_scratch);
let mut output_index = 1;
for input_element in input {
output_index = (output_index * self.primitive_root_inverse) % self.len;
output[output_index - 1] = input_element.conj() + first_input_val;
}
}
fn perform_fft_inplace(&self, buffer: &mut [Complex<T>], scratch: &mut [Complex<T>]) {
let (buffer_first, buffer) = buffer.split_first_mut().unwrap();
let buffer_first_val = *buffer_first;
let (scratch, extra_scratch) = scratch.split_at_mut(self.len() - 1);
let mut input_index = 1;
for scratch_element in scratch.iter_mut() {
input_index = (input_index * self.primitive_root) % self.len;
let buffer_element = buffer[input_index - 1];
*buffer_first = *buffer_first + buffer_element;
*scratch_element = buffer_element;
}
let inner_scratch = if extra_scratch.len() > 0 { extra_scratch } else { &mut buffer[..] };
self.inner_fft.process_inplace_with_scratch(scratch, inner_scratch);
for (scratch_cell, &twiddle) in scratch.iter_mut().zip(self.inner_fft_data.iter()) {
*scratch_cell = (*scratch_cell * twiddle).conj();
}
self.inner_fft.process_inplace_with_scratch(scratch, inner_scratch);
let mut output_index = 1;
for scratch_element in scratch {
output_index = (output_index * self.primitive_root_inverse) % self.len;
buffer[output_index - 1] = scratch_element.conj() + buffer_first_val;
}
}
}
boilerplate_fft!(RadersAlgorithm,
|this: &RadersAlgorithm<_>| this.len.get(),
|this: &RadersAlgorithm<_>| this.inplace_scratch_len,
|this: &RadersAlgorithm<_>| this.outofplace_scratch_len
);
#[cfg(test)]
mod unit_tests {
use super::*;
use std::sync::Arc;
use crate::test_utils::check_fft_algorithm;
use crate::algorithm::DFT;
#[test]
fn test_raders() {
for len in 3..100 {
if miller_rabin(len as u64) {
test_raders_with_length(len, false);
test_raders_with_length(len, true);
}
}
}
fn test_raders_with_length(len: usize, inverse: bool) {
let inner_fft = Arc::new(DFT::new(len - 1, inverse));
let fft = RadersAlgorithm::new(inner_fft);
check_fft_algorithm::<f32>(&fft, len, inverse);
}
}