use super::{frame_range, phys_frame_range};
use bootloader::bootinfo::{MemoryMap, MemoryRegion, MemoryRegionType};
use x86_64::structures::paging::{PhysFrame, PhysFrameRange};
pub(crate) struct FrameAllocator<'a> {
pub memory_map: &'a mut MemoryMap,
}
impl<'a> FrameAllocator<'a> {
pub(crate) fn allocate_frame(&mut self, region_type: MemoryRegionType) -> Option<PhysFrame> {
let mut iter = self.memory_map.iter_mut().peekable();
while let Some(region) = iter.next() {
if region.region_type == region_type {
if let Some(next) = iter.peek() {
if next.range.start_frame_number == region.range.end_frame_number
&& next.region_type == MemoryRegionType::Usable
&& !next.range.is_empty()
{
let frame = phys_frame_range(region.range).end;
region.range.end_frame_number += 1;
iter.next().unwrap().range.start_frame_number += 1;
return Some(frame);
}
}
}
}
fn split_usable_region<'a, I>(iter: &mut I) -> Option<(PhysFrame, PhysFrameRange)>
where
I: Iterator<Item = &'a mut MemoryRegion>,
{
for region in iter {
if region.region_type != MemoryRegionType::Usable {
continue;
}
if region.range.is_empty() {
continue;
}
let frame = phys_frame_range(region.range).start;
region.range.start_frame_number += 1;
return Some((frame, PhysFrame::range(frame, frame + 1)));
}
None
}
let result = if region_type == MemoryRegionType::PageTable {
split_usable_region(&mut self.memory_map.iter_mut().rev())
} else {
split_usable_region(&mut self.memory_map.iter_mut())
};
if let Some((frame, range)) = result {
self.memory_map.add_region(MemoryRegion {
range: frame_range(range),
region_type,
});
Some(frame)
} else {
None
}
}
pub(crate) fn mark_allocated_region(&mut self, region: MemoryRegion) {
for r in self.memory_map.iter_mut() {
if region.range.start_frame_number >= r.range.end_frame_number {
continue;
}
if region.range.end_frame_number <= r.range.start_frame_number {
continue;
}
if r.region_type != MemoryRegionType::Usable {
panic!(
"region {:x?} overlaps with non-usable region {:x?}",
region, r
);
}
if region.range.start_frame_number == r.range.start_frame_number {
if region.range.end_frame_number < r.range.end_frame_number {
r.range.start_frame_number = region.range.end_frame_number;
self.memory_map.add_region(region);
} else {
*r = region;
}
} else if region.range.start_frame_number > r.range.start_frame_number {
if region.range.end_frame_number < r.range.end_frame_number {
let mut behind_r = r.clone();
behind_r.range.start_frame_number = region.range.end_frame_number;
r.range.end_frame_number = region.range.start_frame_number;
self.memory_map.add_region(behind_r);
self.memory_map.add_region(region);
} else {
r.range.end_frame_number = region.range.start_frame_number;
self.memory_map.add_region(region);
}
} else {
r.range.start_frame_number = region.range.end_frame_number;
self.memory_map.add_region(region);
}
return;
}
panic!("region {:x?} is not a usable memory region", region);
}
}