use serde::{de::Deserializer, ser::Serializer};
use serde::{Deserialize, Serialize};
use std::{fmt, ops::Deref, result::Result as StdResult, sync::Arc};
const CUTOFF: usize = std::mem::size_of::<&[u8]>() - 1;
type Inner = [u8; CUTOFF];
#[derive(Clone)]
pub struct IVec(IVecInner);
#[derive(Clone)]
enum IVecInner {
Inline(u8, Inner),
Remote(Arc<[u8]>),
}
impl Serialize for IVec {
fn serialize<S: Serializer>(
&self,
serializer: S,
) -> StdResult<S::Ok, S::Error> {
serde_bytes::serialize(self.as_ref(), serializer)
}
}
impl<'de> Deserialize<'de> for IVec {
fn deserialize<D: Deserializer<'de>>(
deserializer: D,
) -> StdResult<Self, D::Error> {
let bytes: StdResult<Box<[u8]>, D::Error> =
serde_bytes::deserialize(deserializer);
bytes.map(IVec::from)
}
}
const fn is_inline_candidate(length: usize) -> bool {
length <= CUTOFF
}
impl IVec {
fn inline(slice: &[u8]) -> IVec {
assert!(is_inline_candidate(slice.len()));
let mut data = Inner::default();
unsafe {
std::ptr::copy_nonoverlapping(
slice.as_ptr(),
data.as_mut_ptr(),
slice.len(),
);
}
IVec(IVecInner::Inline(slice.len() as u8, data))
}
fn remote(arc: Arc<[u8]>) -> IVec {
IVec(IVecInner::Remote(arc))
}
#[inline]
pub(crate) fn size_in_bytes(&self) -> u64 {
if let IVecInner::Inline(..) = self.0 {
std::mem::size_of::<IVec>() as u64
} else {
let sz = std::mem::size_of::<IVec>() as u64;
sz.saturating_add(self.len() as u64)
}
}
}
impl From<Box<[u8]>> for IVec {
fn from(b: Box<[u8]>) -> IVec {
if is_inline_candidate(b.len()) {
IVec::inline(&b)
} else {
IVec::remote(Arc::from(b))
}
}
}
impl From<&[u8]> for IVec {
fn from(slice: &[u8]) -> IVec {
if is_inline_candidate(slice.len()) {
IVec::inline(slice)
} else {
IVec::remote(Arc::from(slice))
}
}
}
impl From<Arc<[u8]>> for IVec {
fn from(arc: Arc<[u8]>) -> IVec {
IVec::remote(arc)
}
}
impl From<&str> for IVec {
fn from(s: &str) -> IVec {
IVec::from(s.as_bytes())
}
}
impl From<&IVec> for IVec {
fn from(v: &IVec) -> IVec {
v.clone()
}
}
impl From<Vec<u8>> for IVec {
fn from(v: Vec<u8>) -> IVec {
if is_inline_candidate(v.len()) {
IVec::inline(&v)
} else {
IVec::remote(Arc::from(v))
}
}
}
macro_rules! from_array {
($($s:expr)*) => {
$(
impl From<&[u8; $s]> for IVec {
fn from(v: &[u8; $s]) -> IVec {
IVec::from(&v[..])
}
}
)*
}
}
from_array!(0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15);
from_array!(16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32);
impl Into<Arc<[u8]>> for IVec {
fn into(self) -> Arc<[u8]> {
match self.0 {
IVecInner::Inline(..) => Arc::from(self.as_ref()),
IVecInner::Remote(arc) => arc,
}
}
}
impl Deref for IVec {
type Target = [u8];
#[inline]
fn deref(&self) -> &[u8] {
self.as_ref()
}
}
impl AsRef<[u8]> for IVec {
#[inline]
fn as_ref(&self) -> &[u8] {
match &self.0 {
IVecInner::Inline(sz, buf) => {
unsafe { buf.get_unchecked(..*sz as usize) }
},
IVecInner::Remote(buf) => buf,
}
}
}
impl Ord for IVec {
fn cmp(&self, other: &IVec) -> std::cmp::Ordering {
self.as_ref().cmp(other.as_ref())
}
}
impl PartialOrd for IVec {
fn partial_cmp(&self, other: &IVec) -> Option<std::cmp::Ordering> {
Some(self.cmp(other))
}
}
impl<T: AsRef<[u8]>> PartialEq<T> for IVec {
fn eq(&self, other: &T) -> bool {
self.as_ref() == other.as_ref()
}
}
impl PartialEq<[u8]> for IVec {
fn eq(&self, other: &[u8]) -> bool {
self.as_ref() == other
}
}
impl Eq for IVec { }
impl fmt::Debug for IVec {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
self.as_ref().fmt(f)
}
}
#[test]
fn ivec_usage() {
let iv1 = IVec::from(vec![1, 2, 3]);
assert_eq!(iv1, vec![1, 2, 3]);
let iv2 = IVec::from(&[4; 128][..]);
assert_eq!(iv2, vec![4; 128]);
}