use core::future::poll_fn;
use core::marker::PhantomData;
use core::task::Poll;
use embassy_hal_internal::into_ref;
use py32_metapac::adc::vals::Ckmode;
use super::blocking_delay_us;
use crate::adc::{Adc, AdcChannel, Instance, Resolution, SampleTime};
use crate::interrupt::typelevel::Interrupt;
use crate::peripherals::ADC1;
use crate::{interrupt, rcc, Peripheral};
pub const VDDA_CALIB_MV: u32 = 3300;
pub const VREF_INT: u32 = 1200;
pub struct InterruptHandler<T: Instance> {
_phantom: PhantomData<T>,
}
impl<T: Instance> interrupt::typelevel::Handler<T::Interrupt> for InterruptHandler<T> {
unsafe fn on_interrupt() {
if T::regs().isr().read().eoc() {
T::regs().ier().modify(|w| w.set_eocie(false));
} else {
return;
}
T::state().waker.wake();
}
}
pub struct Vref;
impl AdcChannel<ADC1> for Vref {}
impl super::SealedAdcChannel<ADC1> for Vref {
fn channel(&self) -> u8 {
cfg_if::cfg_if!{
if #[cfg(py32f002b)] {
9
} else {
12
}
}
}
}
pub struct Temperature;
impl AdcChannel<ADC1> for Temperature {}
impl super::SealedAdcChannel<ADC1> for Temperature {
fn channel(&self) -> u8 {
cfg_if::cfg_if!{
if #[cfg(py32f002b)] {
8
} else {
11
}
}
}
}
impl<'d, T: Instance> Adc<'d, T> {
pub fn new(
adc: impl Peripheral<P = T> + 'd,
_irq: impl interrupt::typelevel::Binding<T::Interrupt, InterruptHandler<T>> + 'd,
) -> Self {
into_ref!(adc);
rcc::enable_and_reset::<T>();
blocking_delay_us(1);
Self::calibrate();
blocking_delay_us(1);
T::Interrupt::unpend();
unsafe {
T::Interrupt::enable();
}
Self {
adc,
sample_time: SampleTime::from_bits(0),
}
}
pub fn calibrate() {
T::regs().cfgr2().modify(|reg| reg.set_ckmode(Ckmode::PCLK));
#[cfg(dma)]
T::regs().cfgr1().modify(|reg| reg.set_dmaen(false));
T::regs().cr().modify(|reg| reg.set_adcal(true));
while T::regs().cr().read().adcal() {}
if T::regs().cr().read().aden() {
panic!("ADC is already enabled");
}
#[cfg(dma)]
let backup_dma_settings = T::regs().cfgr1().read();
#[cfg(dma)]
T::regs().cfgr1().modify(|reg| reg.set_dmaen(false));
T::regs().cr().modify(|reg| reg.set_adcal(true));
while T::regs().cr().read().adcal() {}
#[cfg(dma)]
T::regs().cfgr1().modify(|reg| {
reg.set_dmaen(backup_dma_settings.dmaen());
reg.set_dmacfg(backup_dma_settings.dmacfg());
});
}
pub fn enable_vref(&self) -> Vref {
T::regs().ccr().modify(|reg| reg.set_vrefen(true));
blocking_delay_us(10);
Vref
}
pub fn enable_temperature(&self) -> Temperature {
T::regs().ccr().modify(|reg| reg.set_tsen(true));
blocking_delay_us(10);
Temperature
}
pub fn set_sample_time(&mut self, sample_time: SampleTime) {
self.sample_time = sample_time;
}
pub fn set_resolution(&mut self, resolution: Resolution) {
T::regs()
.cfgr1()
.modify(|reg| reg.set_res(resolution.into()));
}
pub fn set_ckmode(&mut self, ckmode: Ckmode) {
T::regs().cfgr2().modify(|reg| reg.set_ckmode(ckmode));
}
pub async fn read(&mut self, channel: &mut impl AdcChannel<T>) -> u16 {
let ch_num = channel.channel();
channel.setup();
#[cfg(adc_v1b)]
T::regs().cr().modify(|reg| reg.set_addis(true));
T::regs()
.chselr()
.write(|reg| reg.set_chselx(ch_num as usize, true));
self.convert().await
}
async fn convert(&mut self) -> u16 {
T::regs().isr().modify(|reg| {
reg.set_eoc(true);
reg.set_eosmp(true);
});
T::regs()
.smpr()
.modify(|reg| reg.set_smp(self.sample_time.into()));
T::regs().ier().modify(|w| w.set_eocie(true));
T::regs().cr().modify(|reg| reg.set_aden(true));
blocking_delay_us(1);
T::regs().cr().modify(|reg| reg.set_adstart(true));
poll_fn(|cx| {
T::state().waker.register(cx.waker());
if T::regs().isr().read().eoc() {
Poll::Ready(())
} else {
Poll::Pending
}
})
.await;
T::regs().dr().read().data()
}
}
impl<'d, T: Instance> Drop for Adc<'d, T> {
fn drop(&mut self) {
T::regs().cr().modify(|reg| reg.set_adstp(true));
while T::regs().cr().read().adstp() {}
rcc::disable::<T>();
}
}