use crate::components::core::shapes::Size;
use crate::components::layer::atlas::{self, Atlas};
use crate::components::layer::image::{Data, Handle};
use rustc_hash::{FxHashMap, FxHashSet};
#[derive(Debug)]
pub enum Memory {
Host(image_rs::ImageBuffer<image_rs::Rgba<u8>, Vec<u8>>),
Device(atlas::Entry),
NotFound,
Invalid,
}
impl Memory {
pub fn dimensions(&self) -> Size<u32> {
match self {
Memory::Host(image) => {
let (width, height) = image.dimensions();
Size { width, height }
}
Memory::Device(entry) => entry.size(),
Memory::NotFound => Size {
width: 1,
height: 1,
},
Memory::Invalid => Size {
width: 1,
height: 1,
},
}
}
}
#[derive(Debug, Default)]
pub struct Cache {
map: FxHashMap<u64, Memory>,
hits: FxHashSet<u64>,
}
pub fn load_image(handle: &Handle) -> image_rs::ImageResult<image_rs::DynamicImage> {
match handle.data() {
Data::Path(path) => {
let image = image_rs::ImageReader::open(path)?.decode()?;
Ok(image)
}
Data::Bytes(bytes) => {
let image = image_rs::load_from_memory(bytes)?;
Ok(image)
}
Data::Rgba {
width,
height,
pixels,
} => {
if let Some(image) =
image_rs::ImageBuffer::from_vec(*width, *height, pixels.to_vec())
{
Ok(image_rs::DynamicImage::ImageRgba8(image))
} else {
Err(image_rs::error::ImageError::Limits(
image_rs::error::LimitError::from_kind(
image_rs::error::LimitErrorKind::DimensionError,
),
))
}
}
}
}
impl Cache {
pub fn load(
&mut self,
handle: &crate::components::layer::image::Handle,
) -> &mut Memory {
if self.contains(handle) {
return self.get(handle).unwrap();
}
let memory = match load_image(handle) {
Ok(image) => Memory::Host(image.to_rgba8()),
Err(image_rs::error::ImageError::IoError(_)) => Memory::NotFound,
Err(_) => Memory::Invalid,
};
self.insert(handle, memory);
self.get(handle).unwrap()
}
pub fn upload(
&mut self,
device: &wgpu::Device,
encoder: &mut wgpu::CommandEncoder,
handle: &crate::components::layer::image::Handle,
atlas: &mut Atlas,
context: &crate::context::Context,
) -> Option<&atlas::Entry> {
let memory = self.load(handle);
if let Memory::Host(image) = memory {
let (width, height) = image.dimensions();
let entry = atlas.upload(device, encoder, width, height, image, context)?;
*memory = Memory::Device(entry);
}
if let Memory::Device(allocation) = memory {
Some(allocation)
} else {
None
}
}
pub fn clear(&mut self) {
self.map.clear();
self.hits.clear();
}
pub fn trim(&mut self, atlas: &mut Atlas) {
let hits = &self.hits;
self.map.retain(|k, memory| {
let retain = hits.contains(k);
if !retain {
if let Memory::Device(entry) = memory {
atlas.remove(entry);
}
}
retain
});
self.hits.clear();
}
fn get(
&mut self,
handle: &crate::components::layer::image::Handle,
) -> Option<&mut Memory> {
let _ = self.hits.insert(handle.id());
self.map.get_mut(&handle.id())
}
fn insert(
&mut self,
handle: &crate::components::layer::image::Handle,
memory: Memory,
) {
let _ = self.map.insert(handle.id(), memory);
}
fn contains(&self, handle: &crate::components::layer::image::Handle) -> bool {
self.map.contains_key(&handle.id())
}
}