use emath::Vec2;
use super::{
BytesLoader as _, Context, HashMap, ImagePoll, Mutex, SizeHint, SizedTexture, TextureHandle,
TextureLoadResult, TextureLoader, TextureOptions, TexturePoll,
};
#[derive(Clone, Debug, PartialEq, Eq, Hash)]
struct PrimaryKey {
uri: String,
texture_options: TextureOptions,
}
type Bucket = HashMap<Option<SizeHint>, Entry>;
struct Entry {
last_used: u64,
source_size: Vec2,
handle: TextureHandle,
}
#[derive(Default)]
struct State {
pass_index: u64,
cache: HashMap<PrimaryKey, Bucket>,
}
#[derive(Default)]
pub struct DefaultTextureLoader {
state: Mutex<State>,
}
impl TextureLoader for DefaultTextureLoader {
fn id(&self) -> &'static str {
crate::generate_loader_id!(DefaultTextureLoader)
}
fn load(
&self,
ctx: &Context,
uri: &str,
texture_options: TextureOptions,
size_hint: SizeHint,
) -> TextureLoadResult {
let svg_size_hint = if is_svg(uri) {
Some(size_hint)
} else {
None
};
let mut state = self.state.lock();
let State { pass_index, cache } = &mut *state;
let bucket = cache
.entry(PrimaryKey {
uri: uri.to_owned(),
texture_options,
})
.or_default();
if let Some(texture) = bucket.get_mut(&svg_size_hint) {
texture.last_used = *pass_index;
let texture = SizedTexture::new(texture.handle.id(), texture.source_size);
Ok(TexturePoll::Ready { texture })
} else {
match ctx.try_load_image(uri, size_hint)? {
ImagePoll::Pending { size } => Ok(TexturePoll::Pending { size }),
ImagePoll::Ready { image } => {
let source_size = image.source_size;
let handle = ctx.load_texture(uri, image, texture_options);
let texture = SizedTexture::new(handle.id(), source_size);
bucket.insert(
svg_size_hint,
Entry {
last_used: *pass_index,
source_size,
handle,
},
);
let reduce_texture_memory = ctx.options(|o| o.reduce_texture_memory);
if reduce_texture_memory {
let loaders = ctx.loaders();
loaders.include.forget(uri);
for loader in loaders.bytes.lock().iter().rev() {
loader.forget(uri);
}
for loader in loaders.image.lock().iter().rev() {
loader.forget(uri);
}
}
Ok(TexturePoll::Ready { texture })
}
}
}
}
fn forget(&self, uri: &str) {
log::trace!("forget {uri:?}");
self.state.lock().cache.retain(|key, _value| key.uri != uri);
}
fn forget_all(&self) {
log::trace!("forget all");
self.state.lock().cache.clear();
}
fn end_pass(&self, pass_index: u64) {
let mut state = self.state.lock();
state.pass_index = pass_index;
let State { pass_index, cache } = &mut *state;
cache.retain(|_key, bucket| {
if 2 <= bucket.len() {
bucket.retain(|_, texture| *pass_index <= texture.last_used + 1);
}
!bucket.is_empty()
});
}
fn byte_size(&self) -> usize {
self.state
.lock()
.cache
.values()
.map(|bucket| {
bucket
.values()
.map(|texture| texture.handle.byte_size())
.sum::<usize>()
})
.sum()
}
}
fn is_svg(uri: &str) -> bool {
uri.ends_with(".svg")
}