heavyweaponsgal/jae-blog
1
0
Fork 0
forked from slonk/bingus-blog
Code Pull requests Activity

more efficient serialization/deserialization for Cache

Browse source
This commit is contained in:
slonkazoid 2024-04-18 19:35:08 +03:00
parent acaf55f7ea
commit 44a4b6a365
Signed by: slonk
SSH key fingerprint: SHA256:tbZfJX4IOvZ0LGWOWu5Ijo8jfMPi78TU7x1VoEeCIjM
1 changed files with 11 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/post/cache.rs
View file

@ -1,8 +1,9 @@
use std::hash::{DefaultHasher, Hash, Hasher}; use std::hash::{DefaultHasher, Hash, Hasher};
use scc::HashMap; use scc::HashMap;
use serde::de::{SeqAccess, Visitor}; use serde::de::Visitor;
use serde::{ser::SerializeSeq, Deserialize, Deserializer, Serialize, Serializer}; use serde::ser::SerializeMap;
use serde::{Deserialize, Deserializer, Serialize, Serializer};
use crate::config::RenderConfig; use crate::config::RenderConfig;
use crate::post::PostMetadata; use crate::post::PostMetadata;
@ -113,15 +114,13 @@ impl Serialize for Cache {
S: Serializer, S: Serializer,
{ {
let cache = self.clone().into_inner(); let cache = self.clone().into_inner();
let mut seq = serializer.serialize_seq(Some(cache.len()))?; let mut map = serializer.serialize_map(Some(cache.len()))?;
let mut entry = cache.first_entry(); let mut entry = cache.first_entry();
while let Some(occupied) = entry { while let Some(occupied) = entry {
let key = occupied.key().clone(); map.serialize_entry(occupied.key(), occupied.get())?;
let value = occupied.get().clone();
seq.serialize_element(&(key, value))?;
entry = occupied.next(); entry = occupied.next();
} }
seq.end() map.end()
} }
} }
@ -138,16 +137,16 @@ impl<'de> Deserialize<'de> for Cache {
write!(formatter, "meow") write!(formatter, "meow")
} }
fn visit_seq<A>(self, mut seq: A) -> Result<Self::Value, A::Error> fn visit_map<A>(self, mut map: A) -> Result<Self::Value, A::Error>
where where
A: SeqAccess<'de>, A: serde::de::MapAccess<'de>,
{ {
let cache = match seq.size_hint() { let cache = match map.size_hint() {
Some(size) => HashMap::with_capacity(size), Some(size) => HashMap::with_capacity(size),
None => HashMap::new(), None => HashMap::new(),
}; };
while let Some((key, value)) = seq.next_element::<(String, CacheValue)>()? { while let Some((key, value)) = map.next_entry::<String, CacheValue>()? {
cache.insert(key, value).ok(); cache.insert(key, value).ok();
} }
@ -155,6 +154,6 @@ impl<'de> Deserialize<'de> for Cache {
} }
} }
deserializer.deserialize_seq(CoolVisitor) deserializer.deserialize_map(CoolVisitor)
} }
} }