esp-hal 1.1.0

Bare-metal HAL for Espressif devices
Documentation 
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

use esp_sync::NonReentrantMutex;

use crate::{clock::Clocks, peripherals::RNG};

// TODO: find a better place for these
#[inline]
#[cfg(all(soc_cpu_has_csr_pc, soc_cpu_csr_prv_mode_is_set))]
fn tee_enabled() -> bool {
    false
}

#[inline]
fn current_cpu_cycles() -> usize {
    cfg_if::cfg_if! {
        if #[cfg(xtensa)] {
            xtensa_lx::timer::get_cycle_count() as usize
        } else if #[cfg(soc_cpu_has_csr_pc)] {
            const PRV_M: usize = 3;
            macro_rules! read_csr_fn {
                ($fnname:ident, $csr:expr) => {
                    #[inline]
                    fn $fnname() -> usize {
                        let r: usize;

                        unsafe {
                            core::arch::asm!(concat!("csrrs {0}, ", $csr, ", x0"), out(reg) r);
                        }

                        return r;
                    }
                }
            }

            read_csr_fn!(read_pccr_machine, "0x7e2");
            read_csr_fn!(read_pccr_user, "0x802");

            fn read_prv_mode() -> usize {
                #[cfg(soc_cpu_csr_prv_mode_is_set)]
                if tee_enabled() {
                    read_csr_fn!(read_prv_m, property!("soc.cpu_csr_prv_mode", str));
                    return read_prv_m();
                }

                PRV_M
            }

            if read_prv_mode() == PRV_M {
                read_pccr_machine()
            } else {
                read_pccr_user()
            }
        } else {
            riscv::register::mcycle::read()
        }
    }
}

static LAST_READ: NonReentrantMutex<usize> = NonReentrantMutex::new(0);

fn read_one(wait_cycles: usize) -> u32 {
    loop {
        let random = LAST_READ.with(|last_wait_start| {
            let now: usize = current_cpu_cycles();
            if now.wrapping_sub(*last_wait_start) >= wait_cycles {
                *last_wait_start = now;

                Some(RNG::regs().data().read().bits())
            } else {
                None
            }
        });
        if let Some(random) = random {
            return random;
        }
    }
}

pub(super) fn fill_ptr_range(data: *mut u8, len: usize) {
    let clocks = Clocks::get();
    let cpu_to_apb_freq_ratio = clocks.cpu_clock / clocks.apb_clock;
    let wait_cycles = cpu_to_apb_freq_ratio as usize * property!("rng.apb_cycle_wait_num");

    let mut remaining = len;
    let mut dst = data;
    while remaining > 0 {
        let random_bytes = read_one(wait_cycles).to_le_bytes();
        let bytes_to_copy = random_bytes.len().min(remaining);
        unsafe {
            dst.copy_from_nonoverlapping(random_bytes.as_ptr(), bytes_to_copy);
            dst = dst.add(bytes_to_copy);
        }
        remaining -= bytes_to_copy;
    }
}