1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use crate::Matrix;
#[cfg(feature = "opencl")]
use custos::CLDevice;
use custos::{get_device, number::Float, Alloc, Buffer, CPU};
//use rand::{thread_rng, Rng, distributions::uniform::SampleUniform};

#[cfg(feature = "opencl")]
use crate::opencl::cl_write;

pub trait RandBuf<T> {
    fn rand(&mut self, lo: T, hi: T);
}
impl<T: Float> RandBuf<T> for Buffer<'_, T> {
    fn rand(&mut self, lo: T, hi: T) {
        let device = get_device!(self.device, RandOp<T>);
        device.rand(self, lo, hi)
    }
}

impl<'a, T: Float> Matrix<'a, T> {
    pub fn rand(&mut self, lo: T, hi: T) {
        self.as_mut_buf().rand(lo, hi);
    }
}

pub trait RandOp<T>: Alloc<T> {
    fn rand(&self, x: &mut Buffer<T>, lo: T, hi: T);
}

pub fn rand_slice<T: PartialOrd + Copy + Float>(slice: &mut [T], lo: T, hi: T) {
    let rng = fastrand::Rng::new();
    for value in slice {
        *value = T::as_generic(rng.f64()) * (hi - (lo)) + (lo);
    }
}

impl<T: Float> RandOp<T> for CPU {
    fn rand(&self, x: &mut Buffer<T>, lo: T, hi: T) {
        rand_slice(x, lo, hi)
    }
}

#[cfg(feature = "opencl")]
impl<T: Float> RandOp<T> for CLDevice {
    fn rand(&self, x: &mut Buffer<T>, lo: T, hi: T) {
        if self.unified_mem() {
            return rand_slice(x, lo, hi);
        }
        let mut data = vec![T::default(); x.len()];
        rand_slice(&mut data, lo, hi);
        cl_write(self, x, &data);
    }
}

#[cfg(feature = "cuda")]
use custos::{cuda::api::cu_write, CudaDevice};

#[cfg(feature = "cuda")]
impl<T: Float> RandOp<T> for CudaDevice {
    fn rand(&self, x: &mut Buffer<T>, lo: T, hi: T) {
        let mut data = vec![T::default(); x.len()];
        rand_slice(&mut data, lo, hi);
        cu_write(x.ptr.2, &data).unwrap();
    }
}