seminix 0.1.58

use alloc::sync::Arc;
use core::sync::atomic::{AtomicUsize, Ordering};

use crate::space::{
    addr::Uaddr,
    mm::{
        MmError, MmStruct, MmapPage, Result, VmFlags,
        pgtabledef::{
            DEVICE_NONE, DEVICE_RDONLY, DEVICE_READWRITE, PAGE_EXECONLY, PAGE_NONE, PAGE_RDONLY,
            PAGE_RDONLY_EXEC, PAGE_READWRITE, PAGE_READWRITE_EXEC, PAGE_SIZE, SECTION_DEVICE_NONE,
            SECTION_DEVICE_RDONLY, SECTION_DEVICE_READWRITE, SECTION_PAGE_EXECONLY,
            SECTION_PAGE_NONE, SECTION_PAGE_RDONLY, SECTION_PAGE_RDONLY_EXEC,
            SECTION_PAGE_READWRITE, SECTION_PAGE_READWRITE_EXEC, SECTION_SIZE,
        },
        tlb::tlb_gather_mmu,
    },
    uaccess::USER_SPACE_SIZE,
};

const PROTECTION_MAP: [usize; 28] = [
    PAGE_NONE,                   // 0
    PAGE_RDONLY,                 // 1
    PAGE_NONE,                   // 2
    PAGE_READWRITE,              // 3
    PAGE_EXECONLY,               // 4
    PAGE_RDONLY_EXEC,            // 5
    PAGE_NONE,                   // 6
    PAGE_READWRITE_EXEC,         // 7
    DEVICE_NONE,                 // 8
    DEVICE_RDONLY,               // 9
    DEVICE_NONE,                 // 10
    DEVICE_READWRITE,            // 11
    DEVICE_NONE,                 // 12
    DEVICE_NONE,                 // 13
    DEVICE_NONE,                 // 14
    DEVICE_NONE,                 // 15
    SECTION_DEVICE_NONE,         // 16
    SECTION_PAGE_RDONLY,         // 17
    SECTION_DEVICE_NONE,         // 18
    SECTION_PAGE_READWRITE,      // 19
    SECTION_PAGE_EXECONLY,       // 20
    SECTION_PAGE_RDONLY_EXEC,    // 21
    SECTION_PAGE_NONE,           // 22
    SECTION_PAGE_READWRITE_EXEC, // 23
    SECTION_PAGE_NONE,           // 24
    SECTION_DEVICE_RDONLY,       // 25
    SECTION_DEVICE_NONE,         // 26
    SECTION_DEVICE_READWRITE,    // 27
];

const fn to_vm_prot(vm_flags: VmFlags) -> usize {
    let idx = vm_flags.bits() & VmFlags::VM_PROT_MASK.bits();
    PROTECTION_MAP[idx]
}

// 用户虚拟空间域管理结构体。
pub(crate) struct VmAreaStruct {
    vm_start: Uaddr,
    vm_size: usize,
    vm_prot: usize,
    vm_flags: VmFlags,
    vm_page_size: usize,
    vm_prev_end: AtomicUsize,
    vm_prev_start: AtomicUsize,
    vm_next_start: AtomicUsize,
    mmap_page: Arc<MmapPage>,
    mm: Arc<MmStruct>,
}

impl VmFlags {
    /// 获取映射单页大小
    #[inline(always)]
    pub fn page_size(&self) -> usize {
        if self.contains(VmFlags::VM_HUGE) { SECTION_SIZE } else { PAGE_SIZE }
    }
}

impl VmAreaStruct {
    // 创建一个 vma
    pub(super) fn create(
        vm_start: Uaddr,
        vm_size: usize,
        vm_flags: VmFlags,
        mm: Arc<MmStruct>,
        mmap_page: Arc<MmapPage>,
    ) -> Result<Self> {
        let page_size = vm_flags.page_size();
        if (vm_start.to_value() & (page_size - 1)) != 0 || (vm_size & (page_size - 1)) != 0 {
            return Err(MmError::EAligned);
        }

        let vm_prot = to_vm_prot(vm_flags);
        if vm_prot == PAGE_NONE
            || vm_prot == DEVICE_NONE
            || vm_prot == SECTION_DEVICE_NONE
            || vm_prot == SECTION_PAGE_NONE
        {
            return Err(MmError::EVmFlags);
        }

        if vm_size != mmap_page.get_size() {
            return Err(MmError::ESpace);
        }

        Ok(Self {
            vm_start,
            vm_size,
            vm_prot,
            vm_flags,
            vm_page_size: page_size,
            vm_prev_end: AtomicUsize::new(0),
            vm_prev_start: AtomicUsize::new(0),
            vm_next_start: AtomicUsize::new(USER_SPACE_SIZE),
            mmap_page,
            mm,
        })
    }

    // 获取`vm_start`
    #[inline(always)]
    pub(crate) fn get_vm_start(&self) -> Uaddr {
        self.vm_start
    }

    // 获取`vm_size`
    #[inline(always)]
    pub(crate) fn get_vm_size(&self) -> usize {
        self.vm_size
    }

    // 获取`vm_port`
    #[inline(always)]
    pub(crate) fn get_vm_port(&self) -> usize {
        self.vm_prot
    }

    // 获取`vm_flags`
    #[inline(always)]
    pub(crate) fn get_vm_flags(&self) -> VmFlags {
        self.vm_flags
    }

    // 获取`vm_page_size`
    #[inline(always)]
    pub(crate) fn get_vm_page_size(&self) -> usize {
        self.vm_page_size
    }

    // 获取前一个 vma 的结束地址
    #[inline(always)]
    pub(crate) fn get_prev_end(&self) -> usize {
        self.vm_prev_end.load(Ordering::Relaxed)
    }

    // 设置前一个 vma 的结束地址
    #[inline(always)]
    pub(crate) fn set_prev_end(&self, end: usize) {
        self.vm_prev_end.store(end, Ordering::Relaxed);
    }

    // 获取前一个 vma 的起始地址
    #[inline(always)]
    pub(crate) fn get_prev_start(&self) -> usize {
        self.vm_prev_start.load(Ordering::Relaxed)
    }

    // 设置前一个 vma 的起始地址
    #[inline(always)]
    pub(crate) fn set_prev_start(&self, start: usize) {
        self.vm_prev_start.store(start, Ordering::Relaxed);
    }

    // 获取下一个 vma 的起始地址
    #[inline(always)]
    pub(crate) fn get_next_start(&self) -> usize {
        self.vm_next_start.load(Ordering::Relaxed)
    }

    // 设置下一个 vma 的起始地址
    #[inline(always)]
    pub(crate) fn set_next_start(&self, start: usize) {
        self.vm_next_start.store(start, Ordering::Relaxed);
    }

    // 获取`mmap_page`
    #[inline(always)]
    pub(crate) fn get_mmap_page(&self) -> &MmapPage {
        &self.mmap_page
    }

    // 获取`mm`
    #[inline(always)]
    pub(crate) fn get_mm(&self) -> &MmStruct {
        &self.mm
    }
}

impl Drop for VmAreaStruct {
    fn drop(&mut self) {
        let mm = self.get_mm();
        let pgd = &mm.pgd;
        let start = self.vm_start;
        let end = self.vm_start + self.vm_size;

        let mut tlb = tlb_gather_mmu(mm, start, end);
        pgd.pgd_unmap(start, end, &mut tlb, self);
        pgd.pgd_free_pgtables(start, end, &mut tlb, self);
        tlb.tlb_finish_mmu(start, end);
    }
}