stm32-hal2 2.1.10

Hardware abstraction layer for the STM32 MCUs
Documentation
//! Hardware semaphore (HSEM)
//! Used on STM32WB to synchronize processes running on different cores.

use paste::paste;

use crate::pac::{self, HSEM, RCC};

#[derive(Clone, Copy)]
/// The core that's performing the requested operation. Core 1 is the M4 core, and Core 2 is the M0+ core.
pub enum Core {
    // todo: This is the same as ipcc::Core; DRY; keep in one place and import in the other/both?
    C1,
    C2,
}

pub struct Hsem {
    regs: HSEM,
}

// Helper, since we need to access one of to 31 similarly-named registers.
macro_rules! set_register_sem {
    ($semaphore_num:expr, $regs:expr, $core_id:expr, $proc_id:expr) => {
        paste! {
            $regs.[<r $semaphore_num>].modify(|_, w| {
                w.procid().bits($proc_id);
                w.coreid().bits($core_id);
                w.lock().bit(true)
            })
        }
    };
}

/// Represents an Hardware Semiphore (HSEM) peripheral.
impl Hsem {
    pub fn new(regs: HSEM) -> Self {
        let mut rcc = unsafe { &(*RCC::ptr()) };

        rcc.ahb3enr().modify(|_, w| w.hsemen().bit(true));
        rcc.ahb3rstr().modify(|_, w| w.hsemrst().bit(true));
        rcc.ahb3rstr().modify(|_, w| w.hsemrst().clear_bit());

        // todo: Why are these missing here and on IPCC `new`?
        // rcc.ahb4enr().modify(|_, w| w.hsemen().bit(true));
        // rcc.ahb4rstr().modify(|_, w| w.hsemrst().bit(true));
        // rcc.ahb4rstr().modify(|_, w| w.hsemrst().clear_bit());

        Self { regs }
    }

    /// RM: The 2-step lock procedure consists in a write to lock the semaphore, followed by a read to
    /// check if the lock has been successful, carried out from the HSEM_Rx register
    pub fn lock_2_step(&mut self, core: Core, semaphore_num: u8) {
        if semaphore_num > 31 {
            panic!("Semaphore number must be 0 - 31.")
        }

        // todo: You need a macro to do this! Currently only works on semaphore 1.

        let core_id = 0; // todo temp!
        let proc_id = 0; // todo temp!

        // * Write semaphore with PROCID and COREID, and LOCK = 1. The COREID data
        // written by software must match the AHB bus master information. i.e. a AHB bus master
        // set_register_sem!(semaphore_num, self.regs, core_id, proc_id);  // todo problem with macro syntax

        // ID = 1writes data COREID = 1.
        // Lock is put in place when the semaphore is free at write time.
        // * Read-back the semaphore
        // The software checks the lock status, if PROCID and COREID match the written data,
        // then the lock is confirmed.
        // * Else retry (the semaphore has been locked by another process, AHB bus master ID).
    }

    /// RM: The 1-step procedure consists in a read to lock and check the semaphore in a single step,
    /// carried out from the HSEM_RLRx register.
    pub fn lock_1_step(&mut self, core: Core, semaphore_num: u8) {
        if semaphore_num > 31 {
            panic!("Semaphore number must be 0 - 31.")
        }
        // * Read lock semaphore with the AHB bus master COREID.
        // * If read COREID matches and PROCID = 0, then lock is put in place. If COREID
        // matches and PROCID is not 0, this means that another process from the same
        // COREID has locked the semaphore with a 2-step (write) procedure.
        // * Else retry (the semaphore has been locked by another process, AHB bus master ID).
        // A semaphore can only be locked when it is free. When read locking a free semaphore,
        // PROCID is 0. Read locking a locked semaphore returns the COREID and PROCID that
        // locked it. All read locks, including the first one that locks the semaphore, return the COREID
        // that locks or locked the semaphore.
    }

    /// Unlock a semaphore.
    pub fn unlock(&self, core: Core, semaphore_num: u8) {
        if semaphore_num > 31 {
            panic!("Semaphore number must be 0 - 31.")
        }
        // RM: 38.3.5: Unlocking a semaphore is a protected process, to prevent accidental clearing by a AHB bus
        // master ID or by a process not having the semaphore lock right. The procedure consists in
        // writing to the semaphore HSEM_Rx register with the corresponding COREID and PROCID
        // and LOCK = 0. When unlocked the semaphore, the COREID, and the PROCID are all 0.
        // When unlocked, an interrupt may be generated to signal the event. To this end, the
        // semaphore interrupt shall be enabled.
        // The unlock procedure consists in a write to the semaphore HSEM_Rx register with
        // matching COREID regardless on how the semaphore has been locked (1-step or 2-step).
        //  Write semaphore with PROCID, COREID, and LOCK = 0
        //  If the written data matches the semaphore PROCID and COREID and the AHB bus
        // master ID , the semaphore is unlocked and an interrupt may be generated when
        // enabled, else write is ignored, semaphore remains locked and no interrupt is generated
        // (the semaphore is locked by another process, AHB bus master ID or the written data
        // does not match the AHB bus master signaling).
    }

    /// Enable an interrupt.
    pub fn enable_interrupt(&mut self, core: Core, semaphore_num: u8) {
        if semaphore_num > 31 {
            panic!("Semaphore number must be 0 - 31.")
        }
        // Cnier doesn't have individual fields
        match core {
            Core::C1 => {
                let orig_value = self.regs.c1ier().read().bits();
                self.regs
                    .c1ier()
                    .write(|w| unsafe { w.bits(orig_value | (1 << semaphore_num)) });
            }
            Core::C2 => {
                let orig_value = self.regs.c2ier().read().bits();
                self.regs
                    .c2ier()
                    .write(|w| unsafe { w.bits(orig_value | (1 << semaphore_num)) });
            }
        }
    }

    /// Clear an interrupt flag - run this in the interrupt's handler to prevent
    /// repeat firings.
    pub fn clear_interrupt(&mut self, core: Core, semaphore_num: u8) {
        if semaphore_num > 31 {
            panic!("Semaphore number must be 0 - 31.")
        }
        // todo: Do we need to read, or can we just do a write of the relevant bit
        match core {
            Core::C1 => {
                let orig_value = self.regs.c1icr().read().bits();
                self.regs
                    .c1icr()
                    .write(|w| unsafe { w.bits(orig_value | (1 << semaphore_num)) });
            }
            Core::C2 => {
                let orig_value = self.regs.c2icr().read().bits();
                self.regs
                    .c2icr()
                    .write(|w| unsafe { w.bits(orig_value | (1 << semaphore_num)) });
            }
        }
    }
}