axplat-dyn 0.6.2

A dynamic platform module for ArceOS, providing runtime platform detection and configuration
Documentation
extern crate alloc;

use alloc::{format, string::ToString, vec, vec::Vec};
use core::ptr::NonNull;

use fdt_edit::{Fdt, Node, NodeType, Phandle, RegFixed};
use rdrive::{
    DriverGeneric, PlatformDevice, module_driver, probe::OnProbeError, register::FdtInfo,
};
use rockchip_soc::{BankId, GpioDirection, PinConfig, PinCtrl, PinCtrlOp, PinId, SocType};

use crate::drivers::iomap;

const DRIVER_NAME: &str = "rk3588-pinctrl";
const GPIO_BANK_COUNT: usize = 5;

module_driver!(
    name: "Rockchip PinCtrl",
    level: ProbeLevel::PostKernel,
    priority: ProbePriority::CLK,
    probe_kinds: &[
        ProbeKind::Fdt {
            compatibles: &["rockchip,rk3588-pinctrl"],
            on_probe: probe
        }
    ],
);

pub(crate) struct RockchipPinCtrl {
    inner: PinCtrl,
    fdt_addr: NonNull<u8>,
}

unsafe impl Send for RockchipPinCtrl {}

impl RockchipPinCtrl {
    fn new(inner: PinCtrl, fdt_addr: NonNull<u8>) -> Self {
        Self { inner, fdt_addr }
    }

    pub(crate) fn enable_fixed_regulator(&mut self, phandle: Phandle) -> Result<(), OnProbeError> {
        let fdt = live_fdt(self.fdt_addr)?;
        let node = fdt.get_by_phandle(phandle).ok_or_else(|| {
            OnProbeError::other(format!("regulator phandle {phandle:?} not found"))
        })?;
        let node_name = node.name().to_string();
        let active_value = fixed_regulator_active_value(node.as_node());
        let gpio_active_low = gpio_active_low(node.as_node());
        let drive_value = if gpio_active_low {
            !active_value
        } else {
            active_value
        };
        let pins = if let Some(gpio) = parse_gpio_pin(&fdt, node.as_node(), "gpios")
            .or_else(|| parse_gpio_pin(&fdt, node.as_node(), "gpio"))
        {
            vec![gpio?]
        } else {
            let pinctrls = node
                .as_node()
                .get_property("pinctrl-0")
                .ok_or_else(|| OnProbeError::other(format!("[{node_name}] has no enable GPIO")))?
                .get_u32_iter()
                .map(Phandle::from)
                .collect::<Vec<_>>();

            let mut pins = Vec::new();
            for pinctrl in pinctrls {
                pins.extend(self.apply_pinctrl_phandle(pinctrl)?);
            }
            if pins.is_empty() {
                return Err(OnProbeError::other(format!(
                    "[{node_name}] pinctrl-0 did not configure any GPIO"
                )));
            }
            pins
        };

        for pin in pins {
            self.inner
                .set_gpio_direction(pin, GpioDirection::Output(drive_value))
                .map_err(|err| {
                    OnProbeError::other(format!(
                        "failed to set [{node_name}] GPIO {pin:?} direction: {err}"
                    ))
                })?;
            self.inner.write_gpio(pin, drive_value).map_err(|err| {
                OnProbeError::other(format!("failed to drive [{node_name}] GPIO {pin:?}: {err}"))
            })?;
        }

        let startup_delay_us = node
            .as_node()
            .get_property("startup-delay-us")
            .and_then(|prop| prop.get_u32())
            .unwrap_or(0);
        if startup_delay_us != 0 {
            axklib::time::busy_wait(core::time::Duration::from_micros(u64::from(
                startup_delay_us,
            )));
        }

        info!("Rockchip fixed regulator {node_name} enabled via pinctrl");
        Ok(())
    }

    fn apply_pinctrl_phandle(&mut self, phandle: Phandle) -> Result<Vec<PinId>, OnProbeError> {
        let fdt = live_fdt(self.fdt_addr)?;
        let node = fdt
            .get_by_phandle(phandle)
            .ok_or_else(|| OnProbeError::other(format!("pinctrl phandle {phandle:?} not found")))?;
        self.apply_pinctrl_node(node)
    }

    fn apply_pinctrl_node(&mut self, node: NodeType<'_>) -> Result<Vec<PinId>, OnProbeError> {
        let pins = node
            .as_node()
            .get_property("rockchip,pins")
            .ok_or_else(|| OnProbeError::other(format!("[{}] has no rockchip,pins", node.name())))?
            .get_u32_iter()
            .collect::<Vec<_>>();
        if pins.len() % 4 != 0 {
            return Err(OnProbeError::other(format!(
                "[{}] has malformed rockchip,pins with {} cells",
                node.name(),
                pins.len()
            )));
        }

        let mut configured = Vec::new();
        for cells in pins.chunks(4) {
            let config = PinConfig::new_with_fdt(cells, self.fdt_addr);
            let pin = config.id;
            self.inner.set_config(config).map_err(|err| {
                OnProbeError::other(format!(
                    "failed to apply pinctrl [{}] pin {pin:?}: {err}",
                    node.name()
                ))
            })?;
            configured.push(pin);
        }

        Ok(configured)
    }
}

impl DriverGeneric for RockchipPinCtrl {
    fn name(&self) -> &str {
        DRIVER_NAME
    }
}

fn probe(info: FdtInfo<'_>, plat_dev: PlatformDevice) -> Result<(), OnProbeError> {
    let fdt_addr = live_fdt_addr()?;
    let fdt = live_fdt(fdt_addr)?;

    let grf_phandle = info
        .node
        .as_node()
        .get_property("rockchip,grf")
        .and_then(|prop| prop.get_u32())
        .map(Phandle::from)
        .ok_or_else(|| {
            OnProbeError::other(format!("[{}] has no rockchip,grf", info.node.name()))
        })?;
    let ioc = map_phandle_reg(&fdt, grf_phandle, "pinctrl rockchip,grf")?;

    let mut gpio_banks = Vec::new();
    for node in fdt.find_compatible(&["rockchip,gpio-bank"]) {
        if gpio_banks.len() == GPIO_BANK_COUNT {
            break;
        }
        gpio_banks.push(map_node_reg(node, "rockchip,gpio-bank")?);
    }
    if gpio_banks.len() != GPIO_BANK_COUNT {
        return Err(OnProbeError::other(format!(
            "RK3588 pinctrl requires {GPIO_BANK_COUNT} GPIO banks, found {}",
            gpio_banks.len()
        )));
    }

    let pinctrl = PinCtrl::new(SocType::Rk3588, ioc, &gpio_banks);
    plat_dev.register(RockchipPinCtrl::new(pinctrl, fdt_addr));
    info!("Rockchip RK3588 pinctrl registered successfully");
    Ok(())
}

fn live_fdt_addr() -> Result<NonNull<u8>, OnProbeError> {
    let ptr = somehal::fdt_addr().ok_or_else(|| OnProbeError::other("live FDT not found"))?;
    NonNull::new(ptr).ok_or_else(|| OnProbeError::other("live FDT pointer is null"))
}

fn live_fdt(fdt_addr: NonNull<u8>) -> Result<Fdt, OnProbeError> {
    unsafe { Fdt::from_ptr(fdt_addr.as_ptr()) }
        .map_err(|err| OnProbeError::other(format!("failed to parse live FDT: {err:?}")))
}

fn map_phandle_reg(
    fdt: &Fdt,
    phandle: Phandle,
    context: &str,
) -> Result<NonNull<u8>, OnProbeError> {
    let node = fdt
        .get_by_phandle(phandle)
        .ok_or_else(|| OnProbeError::other(format!("{context} phandle {phandle:?} not found")))?;
    map_node_reg(node, context)
}

fn map_node_reg(node: NodeType<'_>, context: &str) -> Result<NonNull<u8>, OnProbeError> {
    let reg = node.regs().into_iter().next().ok_or_else(|| {
        OnProbeError::other(format!("[{}] has no reg for {context}", node.name()))
    })?;
    map_reg(reg)
}

fn map_reg(reg: RegFixed) -> Result<NonNull<u8>, OnProbeError> {
    let size = align_up_4k((reg.size.unwrap_or(0x1000) as usize).max(1));
    iomap((reg.address as usize).into(), size)
}

fn fixed_regulator_active_value(node: &Node) -> bool {
    node.get_property("enable-active-low").is_none()
}

fn gpio_active_low(node: &Node) -> bool {
    node.get_property("gpios")
        .or_else(|| node.get_property("gpio"))
        .and_then(|prop| prop.get_u32_iter().nth(2))
        .is_some_and(|flags| flags & 1 != 0)
}

fn parse_gpio_pin(fdt: &Fdt, node: &Node, prop_name: &str) -> Option<Result<PinId, OnProbeError>> {
    let prop = node.get_property(prop_name)?;
    Some((|| {
        let mut cells = prop.get_u32_iter();
        let phandle = Phandle::from(cells.next().ok_or_else(|| {
            OnProbeError::other(format!("[{}] has malformed {prop_name}", node.name()))
        })?);
        let pin = cells.next().ok_or_else(|| {
            OnProbeError::other(format!("[{}] has malformed {prop_name}", node.name()))
        })?;
        let gpio = fdt.get_by_phandle(phandle).ok_or_else(|| {
            OnProbeError::other(format!(
                "[{}] {prop_name} GPIO phandle {phandle:?} not found",
                node.name()
            ))
        })?;
        let bank = gpio_bank_index(gpio.as_node()).ok_or_else(|| {
            OnProbeError::other(format!(
                "[{}] cannot resolve GPIO bank for {prop_name} phandle {phandle:?}",
                node.name()
            ))
        })?;
        PinId::from_bank_pin(BankId::new(bank).unwrap_or(BankId::from(bank)), pin).ok_or_else(
            || {
                OnProbeError::other(format!(
                    "[{}] invalid GPIO bank {bank} pin {pin}",
                    node.name()
                ))
            },
        )
    })())
}

fn gpio_bank_index(node: &Node) -> Option<u32> {
    let name = node.name();
    if let Some(name) = name
        .strip_prefix("gpio")
        .filter(|name| !name.starts_with('@'))
    {
        if let Some(bank) = name
            .chars()
            .next()
            .and_then(|ch| ch.to_digit(10))
            .filter(|bank| *bank < GPIO_BANK_COUNT as u32)
        {
            return Some(bank);
        }
    }

    let address = gpio_bank_address(node)?;
    match address {
        0xfd8a_0000 => Some(0),
        0xfec2_0000 => Some(1),
        0xfec3_0000 => Some(2),
        0xfec4_0000 => Some(3),
        0xfec5_0000 => Some(4),
        _ => None,
    }
}

fn gpio_bank_address(node: &Node) -> Option<u64> {
    if let Some(address) = node
        .name()
        .split_once('@')
        .and_then(|(_, unit)| u64::from_str_radix(unit, 16).ok())
    {
        return Some(address);
    }

    let reg = node.get_property("reg")?.get_u32_iter().collect::<Vec<_>>();
    match reg.as_slice() {
        [addr] => Some(u64::from(*addr)),
        cells if cells.len() >= 2 => Some((u64::from(cells[0]) << 32) | u64::from(cells[1])),
        _ => None,
    }
}

fn align_up_4k(size: usize) -> usize {
    const MASK: usize = 0xfff;
    (size + MASK) & !MASK
}