From 57a8fc37fc99491fa2559694f78af52a597bc501 Mon Sep 17 00:00:00 2001 From: Divy Srivastava Date: Wed, 20 Apr 2022 18:16:44 +0530 Subject: perf(http): optimize `ReadableStream`s backed by a resource (#14284) --- serde_v8/magic/buffer.rs | 12 ++++++++++++ 1 file changed, 12 insertions(+) (limited to 'serde_v8/magic') diff --git a/serde_v8/magic/buffer.rs b/serde_v8/magic/buffer.rs index 484984ac5..a0a1c974b 100644 --- a/serde_v8/magic/buffer.rs +++ b/serde_v8/magic/buffer.rs @@ -14,19 +14,28 @@ use crate::magic::transl8::impl_magic; pub enum MagicBuffer { FromV8(ZeroCopyBuf), ToV8(Mutex>>), + // Variant of the MagicBuffer than is never exposed to the JS. + // Generally used to pass Vec backed buffers to resource methods. + Temp(Vec), } + impl_magic!(MagicBuffer); impl MagicBuffer { pub fn empty() -> Self { MagicBuffer::ToV8(Mutex::new(Some(vec![0_u8; 0].into_boxed_slice()))) } + + pub fn new_temp(vec: Vec) -> Self { + MagicBuffer::Temp(vec) + } } impl Clone for MagicBuffer { fn clone(&self) -> Self { match self { Self::FromV8(zbuf) => Self::FromV8(zbuf.clone()), + Self::Temp(vec) => Self::Temp(vec.clone()), Self::ToV8(_) => panic!("Don't Clone a MagicBuffer sent to v8"), } } @@ -49,6 +58,7 @@ impl Deref for MagicBuffer { fn deref(&self) -> &[u8] { match self { Self::FromV8(buf) => &*buf, + Self::Temp(vec) => &*vec, Self::ToV8(_) => panic!("Don't Deref a MagicBuffer sent to v8"), } } @@ -58,6 +68,7 @@ impl DerefMut for MagicBuffer { fn deref_mut(&mut self) -> &mut [u8] { match self { Self::FromV8(buf) => &mut *buf, + Self::Temp(vec) => &mut *vec, Self::ToV8(_) => panic!("Don't Deref a MagicBuffer sent to v8"), } } @@ -85,6 +96,7 @@ impl ToV8 for MagicBuffer { let value: &[u8] = buf; value.into() } + Self::Temp(_) => unreachable!(), Self::ToV8(x) => x.lock().unwrap().take().expect("MagicBuffer was empty"), }; -- cgit v1.2.3