use crate::{
lookup::Lookup,
nibble::{nibble_ops, BackingByteVec, NibbleSlice, NibbleVec},
node::{
decode_hash, Node as EncodedNode, NodeHandle as EncodedNodeHandle, NodeHandleOwned,
NodeKey, NodeOwned, Value as EncodedValue, ValueOwned,
},
node_codec::NodeCodec,
rstd::{boxed::Box, convert::TryFrom, mem, ops::Index, result, vec::Vec, VecDeque},
Bytes, CError, CachedValue, DBValue, Result, TrieAccess, TrieCache, TrieError, TrieHash,
TrieLayout, TrieMut, TrieRecorder,
};
use hash_db::{HashDB, Hasher, Prefix, EMPTY_PREFIX};
use hashbrown::HashSet;
#[cfg(feature = "std")]
use log::trace;
#[cfg(feature = "std")]
use crate::rstd::fmt::{self, Debug};
#[cfg_attr(feature = "std", derive(Debug))]
struct StorageHandle(usize);
#[cfg_attr(feature = "std", derive(Debug))]
enum NodeHandle<H> {
InMemory(StorageHandle),
Hash(H),
}
impl<H> From<StorageHandle> for NodeHandle<H> {
fn from(handle: StorageHandle) -> Self {
NodeHandle::InMemory(handle)
}
}
fn empty_children<H>() -> Box<[Option<NodeHandle<H>>; nibble_ops::NIBBLE_LENGTH]> {
Box::new([
None, None, None, None, None, None, None, None, None, None, None, None, None, None, None,
None,
])
}
type NibbleFullKey<'key> = NibbleSlice<'key>;
#[derive(Clone, Eq)]
pub enum Value<L: TrieLayout> {
Inline(Bytes),
Node(TrieHash<L>),
NewNode(Option<TrieHash<L>>, Bytes),
}
impl<L: TrieLayout> PartialEq<Self> for Value<L> {
fn eq(&self, other: &Self) -> bool {
match (self, other) {
(Value::Inline(v), Value::Inline(ov)) => v == ov,
(Value::Node(h), Value::Node(oh)) => h == oh,
(Value::NewNode(Some(h), _), Value::NewNode(Some(oh), _)) => h == oh,
(Value::NewNode(_, v), Value::NewNode(_, ov)) => v == ov,
_ => false,
}
}
}
impl<'a, L: TrieLayout> From<EncodedValue<'a>> for Value<L> {
fn from(v: EncodedValue<'a>) -> Self {
match v {
EncodedValue::Inline(value) => Value::Inline(value.into()),
EncodedValue::Node(hash) => {
let mut h = TrieHash::<L>::default();
h.as_mut().copy_from_slice(hash);
Value::Node(h)
},
}
}
}
impl<L: TrieLayout> From<&ValueOwned<TrieHash<L>>> for Value<L> {
fn from(val: &ValueOwned<TrieHash<L>>) -> Self {
match val {
ValueOwned::Inline(data, _) => Self::Inline(data.clone()),
ValueOwned::Node(hash) => Self::Node(*hash),
}
}
}
impl<L: TrieLayout> From<(Bytes, Option<u32>)> for Value<L> {
fn from((v, threshold): (Bytes, Option<u32>)) -> Self {
match v {
value =>
if threshold.map(|threshold| value.len() >= threshold as usize).unwrap_or(false) {
Value::NewNode(None, value)
} else {
Value::Inline(value)
},
}
}
}
enum NodeToEncode<'a, H> {
Node(&'a [u8]),
TrieNode(NodeHandle<H>),
}
impl<L: TrieLayout> Value<L> {
fn new(value: Bytes, new_threshold: Option<u32>) -> Self {
(value, new_threshold).into()
}
fn into_encoded<'a, F>(
&'a mut self,
partial: Option<&NibbleSlice>,
f: &mut F,
) -> EncodedValue<'a>
where
F: FnMut(
NodeToEncode<TrieHash<L>>,
Option<&NibbleSlice>,
Option<u8>,
) -> ChildReference<TrieHash<L>>,
{
if let Value::NewNode(hash, value) = self {
let new_hash =
if let ChildReference::Hash(hash) = f(NodeToEncode::Node(&value), partial, None) {
hash
} else {
unreachable!("Value node can never be inlined; qed")
};
if let Some(h) = hash.as_ref() {
debug_assert!(h == &new_hash);
} else {
*hash = Some(new_hash);
}
}
let value = match &*self {
Value::Inline(value) => EncodedValue::Inline(&value),
Value::Node(hash) => EncodedValue::Node(hash.as_ref()),
Value::NewNode(Some(hash), _value) => EncodedValue::Node(hash.as_ref()),
Value::NewNode(None, _value) =>
unreachable!("New external value are always added before encoding anode"),
};
value
}
fn in_memory_fetched_value(
&self,
prefix: Prefix,
db: &dyn HashDB<L::Hash, DBValue>,
recorder: &Option<core::cell::RefCell<&mut dyn TrieRecorder<TrieHash<L>>>>,
full_key: &[u8],
) -> Result<Option<DBValue>, TrieHash<L>, CError<L>> {
Ok(Some(match self {
Value::Inline(value) => value.to_vec(),
Value::NewNode(_, value) => value.to_vec(),
Value::Node(hash) =>
if let Some(value) = db.get(hash, prefix) {
recorder.as_ref().map(|r| {
r.borrow_mut().record(TrieAccess::Value {
hash: *hash,
value: value.as_slice().into(),
full_key,
})
});
value
} else {
return Err(Box::new(TrieError::IncompleteDatabase(hash.clone())))
},
}))
}
}
enum Node<L: TrieLayout> {
Empty,
Leaf(NodeKey, Value<L>),
Extension(NodeKey, NodeHandle<TrieHash<L>>),
Branch(Box<[Option<NodeHandle<TrieHash<L>>>; nibble_ops::NIBBLE_LENGTH]>, Option<Value<L>>),
NibbledBranch(
NodeKey,
Box<[Option<NodeHandle<TrieHash<L>>>; nibble_ops::NIBBLE_LENGTH]>,
Option<Value<L>>,
),
}
#[cfg(feature = "std")]
struct ToHex<'a>(&'a [u8]);
#[cfg(feature = "std")]
impl<'a> Debug for ToHex<'a> {
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
let hex = rustc_hex::ToHexIter::new(self.0.iter());
for b in hex {
write!(fmt, "{}", b)?;
}
Ok(())
}
}
#[cfg(feature = "std")]
impl<L: TrieLayout> Debug for Value<L> {
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
match self {
Self::Inline(value) => write!(fmt, "Some({:?})", ToHex(value)),
Self::Node(hash) => write!(fmt, "Hash({:?})", ToHex(hash.as_ref())),
Self::NewNode(Some(hash), _) => write!(fmt, "Hash({:?})", ToHex(hash.as_ref())),
Self::NewNode(_hash, value) => write!(fmt, "Some({:?})", ToHex(value)),
}
}
}
#[cfg(feature = "std")]
impl<L: TrieLayout> Debug for Node<L>
where
L::Hash: Debug,
{
fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
match *self {
Self::Empty => write!(fmt, "Empty"),
Self::Leaf((ref a, ref b), ref c) =>
write!(fmt, "Leaf({:?}, {:?})", (a, ToHex(&*b)), c),
Self::Extension((ref a, ref b), ref c) =>
write!(fmt, "Extension({:?}, {:?})", (a, ToHex(&*b)), c),
Self::Branch(ref a, ref b) => write!(fmt, "Branch({:?}, {:?}", a, b),
Self::NibbledBranch((ref a, ref b), ref c, ref d) =>
write!(fmt, "NibbledBranch({:?}, {:?}, {:?})", (a, ToHex(&*b)), c, d),
}
}
}
impl<L: TrieLayout> Node<L> {
fn inline_or_hash(
parent_hash: TrieHash<L>,
child: EncodedNodeHandle,
storage: &mut NodeStorage<L>,
) -> Result<NodeHandle<TrieHash<L>>, TrieHash<L>, CError<L>> {
let handle = match child {
EncodedNodeHandle::Hash(data) => {
let hash = decode_hash::<L::Hash>(data)
.ok_or_else(|| Box::new(TrieError::InvalidHash(parent_hash, data.to_vec())))?;
NodeHandle::Hash(hash)
},
EncodedNodeHandle::Inline(data) => {
let child = Node::from_encoded(parent_hash, data, storage)?;
NodeHandle::InMemory(storage.alloc(Stored::New(child)))
},
};
Ok(handle)
}
fn inline_or_hash_owned(
child: &NodeHandleOwned<TrieHash<L>>,
storage: &mut NodeStorage<L>,
) -> NodeHandle<TrieHash<L>> {
match child {
NodeHandleOwned::Hash(hash) => NodeHandle::Hash(*hash),
NodeHandleOwned::Inline(node) => {
let child = Node::from_node_owned(&**node, storage);
NodeHandle::InMemory(storage.alloc(Stored::New(child)))
},
}
}
fn from_encoded<'a, 'b>(
node_hash: TrieHash<L>,
data: &'a [u8],
storage: &'b mut NodeStorage<L>,
) -> Result<Self, TrieHash<L>, CError<L>> {
let encoded_node =
L::Codec::decode(data).map_err(|e| Box::new(TrieError::DecoderError(node_hash, e)))?;
let node = match encoded_node {
EncodedNode::Empty => Node::Empty,
EncodedNode::Leaf(k, v) => Node::Leaf(k.into(), v.into()),
EncodedNode::Extension(key, cb) =>
Node::Extension(key.into(), Self::inline_or_hash(node_hash, cb, storage)?),
EncodedNode::Branch(encoded_children, val) => {
let mut child = |i: usize| match encoded_children[i] {
Some(child) => Self::inline_or_hash(node_hash, child, storage).map(Some),
None => Ok(None),
};
let children = Box::new([
child(0)?,
child(1)?,
child(2)?,
child(3)?,
child(4)?,
child(5)?,
child(6)?,
child(7)?,
child(8)?,
child(9)?,
child(10)?,
child(11)?,
child(12)?,
child(13)?,
child(14)?,
child(15)?,
]);
Node::Branch(children, val.map(Into::into))
},
EncodedNode::NibbledBranch(k, encoded_children, val) => {
let mut child = |i: usize| match encoded_children[i] {
Some(child) => Self::inline_or_hash(node_hash, child, storage).map(Some),
None => Ok(None),
};
let children = Box::new([
child(0)?,
child(1)?,
child(2)?,
child(3)?,
child(4)?,
child(5)?,
child(6)?,
child(7)?,
child(8)?,
child(9)?,
child(10)?,
child(11)?,
child(12)?,
child(13)?,
child(14)?,
child(15)?,
]);
Node::NibbledBranch(k.into(), children, val.map(Into::into))
},
};
Ok(node)
}
fn from_node_owned(node_owned: &NodeOwned<TrieHash<L>>, storage: &mut NodeStorage<L>) -> Self {
match node_owned {
NodeOwned::Empty => Node::Empty,
NodeOwned::Leaf(k, v) => Node::Leaf(k.into(), v.into()),
NodeOwned::Extension(key, cb) =>
Node::Extension(key.into(), Self::inline_or_hash_owned(cb, storage)),
NodeOwned::Branch(encoded_children, val) => {
let mut child = |i: usize| {
encoded_children[i]
.as_ref()
.map(|child| Self::inline_or_hash_owned(child, storage))
};
let children = Box::new([
child(0),
child(1),
child(2),
child(3),
child(4),
child(5),
child(6),
child(7),
child(8),
child(9),
child(10),
child(11),
child(12),
child(13),
child(14),
child(15),
]);
Node::Branch(children, val.as_ref().map(Into::into))
},
NodeOwned::NibbledBranch(k, encoded_children, val) => {
let mut child = |i: usize| {
encoded_children[i]
.as_ref()
.map(|child| Self::inline_or_hash_owned(child, storage))
};
let children = Box::new([
child(0),
child(1),
child(2),
child(3),
child(4),
child(5),
child(6),
child(7),
child(8),
child(9),
child(10),
child(11),
child(12),
child(13),
child(14),
child(15),
]);
Node::NibbledBranch(k.into(), children, val.as_ref().map(Into::into))
},
NodeOwned::Value(_, _) =>
unreachable!("`NodeOwned::Value` can only be returned for the hash of a value."),
}
}
fn into_encoded<F>(self, mut child_cb: F) -> Vec<u8>
where
F: FnMut(
NodeToEncode<TrieHash<L>>,
Option<&NibbleSlice>,
Option<u8>,
) -> ChildReference<TrieHash<L>>,
{
match self {
Node::Empty => L::Codec::empty_node().to_vec(),
Node::Leaf(partial, mut value) => {
let pr = NibbleSlice::new_offset(&partial.1[..], partial.0);
let value = value.into_encoded::<F>(Some(&pr), &mut child_cb);
L::Codec::leaf_node(pr.right_iter(), pr.len(), value)
},
Node::Extension(partial, child) => {
let pr = NibbleSlice::new_offset(&partial.1[..], partial.0);
let it = pr.right_iter();
let c = child_cb(NodeToEncode::TrieNode(child), Some(&pr), None);
L::Codec::extension_node(it, pr.len(), c)
},
Node::Branch(mut children, mut value) => {
let value = value.as_mut().map(|v| v.into_encoded::<F>(None, &mut child_cb));
L::Codec::branch_node(
children.iter_mut().map(Option::take).enumerate().map(|(i, maybe_child)| {
maybe_child.map(|child| {
child_cb(NodeToEncode::TrieNode(child), None, Some(i as u8))
})
}),
value,
)
},
Node::NibbledBranch(partial, mut children, mut value) => {
let pr = NibbleSlice::new_offset(&partial.1[..], partial.0);
let value = value.as_mut().map(|v| v.into_encoded::<F>(Some(&pr), &mut child_cb));
let it = pr.right_iter();
L::Codec::branch_node_nibbled(
it,
pr.len(),
children.iter_mut().map(Option::take).enumerate().map(|(i, maybe_child)| {
maybe_child.map(|child| {
let pr = NibbleSlice::new_offset(&partial.1[..], partial.0);
child_cb(NodeToEncode::TrieNode(child), Some(&pr), Some(i as u8))
})
}),
value,
)
},
}
}
fn partial_key(&self) -> Option<&NodeKey> {
match &self {
Self::Empty => None,
Self::Leaf(key, _) => Some(key),
Self::Branch(_, _) => None,
Self::NibbledBranch(key, _, _) => Some(key),
Self::Extension(key, _) => Some(key),
}
}
}
enum Action<L: TrieLayout> {
Replace(Node<L>),
Restore(Node<L>),
Delete,
}
enum InsertAction<L: TrieLayout> {
Replace(Node<L>),
Restore(Node<L>),
}
impl<L: TrieLayout> InsertAction<L> {
fn into_action(self) -> Action<L> {
match self {
InsertAction::Replace(n) => Action::Replace(n),
InsertAction::Restore(n) => Action::Restore(n),
}
}
fn unwrap_node(self) -> Node<L> {
match self {
InsertAction::Replace(n) | InsertAction::Restore(n) => n,
}
}
}
enum Stored<L: TrieLayout> {
New(Node<L>),
Cached(Node<L>, TrieHash<L>),
}
#[derive(Clone, Copy)]
#[cfg_attr(feature = "std", derive(Debug))]
pub enum ChildReference<HO> {
Hash(HO),
Inline(HO, usize), }
impl<'a, HO> TryFrom<EncodedNodeHandle<'a>> for ChildReference<HO>
where
HO: AsRef<[u8]> + AsMut<[u8]> + Default + Clone + Copy,
{
type Error = Vec<u8>;
fn try_from(handle: EncodedNodeHandle<'a>) -> result::Result<Self, Vec<u8>> {
match handle {
EncodedNodeHandle::Hash(data) => {
let mut hash = HO::default();
if data.len() != hash.as_ref().len() {
return Err(data.to_vec())
}
hash.as_mut().copy_from_slice(data);
Ok(ChildReference::Hash(hash))
},
EncodedNodeHandle::Inline(data) => {
let mut hash = HO::default();
if data.len() > hash.as_ref().len() {
return Err(data.to_vec())
}
hash.as_mut()[..data.len()].copy_from_slice(data);
Ok(ChildReference::Inline(hash, data.len()))
},
}
}
}
struct NodeStorage<L: TrieLayout> {
nodes: Vec<Stored<L>>,
free_indices: VecDeque<usize>,
}
impl<L: TrieLayout> NodeStorage<L> {
fn empty() -> Self {
NodeStorage { nodes: Vec::new(), free_indices: VecDeque::new() }
}
fn alloc(&mut self, stored: Stored<L>) -> StorageHandle {
if let Some(idx) = self.free_indices.pop_front() {
self.nodes[idx] = stored;
StorageHandle(idx)
} else {
self.nodes.push(stored);
StorageHandle(self.nodes.len() - 1)
}
}
fn destroy(&mut self, handle: StorageHandle) -> Stored<L> {
let idx = handle.0;
self.free_indices.push_back(idx);
mem::replace(&mut self.nodes[idx], Stored::New(Node::Empty))
}
}
impl<'a, L: TrieLayout> Index<&'a StorageHandle> for NodeStorage<L> {
type Output = Node<L>;
fn index(&self, handle: &'a StorageHandle) -> &Node<L> {
match self.nodes[handle.0] {
Stored::New(ref node) => node,
Stored::Cached(ref node, _) => node,
}
}
}
pub struct TrieDBMutBuilder<'db, L: TrieLayout> {
db: &'db mut dyn HashDB<L::Hash, DBValue>,
root: &'db mut TrieHash<L>,
cache: Option<&'db mut dyn TrieCache<L::Codec>>,
recorder: Option<&'db mut dyn TrieRecorder<TrieHash<L>>>,
}
impl<'db, L: TrieLayout> TrieDBMutBuilder<'db, L> {
pub fn new(db: &'db mut dyn HashDB<L::Hash, DBValue>, root: &'db mut TrieHash<L>) -> Self {
*root = L::Codec::hashed_null_node();
Self { root, db, cache: None, recorder: None }
}
pub fn from_existing(
db: &'db mut dyn HashDB<L::Hash, DBValue>,
root: &'db mut TrieHash<L>,
) -> Self {
Self { db, root, cache: None, recorder: None }
}
pub fn with_cache(mut self, cache: &'db mut dyn TrieCache<L::Codec>) -> Self {
self.cache = Some(cache);
self
}
pub fn with_optional_cache<'cache: 'db>(
mut self,
cache: Option<&'cache mut dyn TrieCache<L::Codec>>,
) -> Self {
self.cache = cache.map(|c| c as _);
self
}
pub fn with_recorder(mut self, recorder: &'db mut dyn TrieRecorder<TrieHash<L>>) -> Self {
self.recorder = Some(recorder);
self
}
pub fn with_optional_recorder<'recorder: 'db>(
mut self,
recorder: Option<&'recorder mut dyn TrieRecorder<TrieHash<L>>>,
) -> Self {
self.recorder = recorder.map(|r| r as _);
self
}
pub fn build(self) -> TrieDBMut<'db, L> {
let root_handle = NodeHandle::Hash(*self.root);
TrieDBMut {
db: self.db,
root: self.root,
cache: self.cache,
recorder: self.recorder.map(core::cell::RefCell::new),
hash_count: 0,
storage: NodeStorage::empty(),
death_row: Default::default(),
root_handle,
}
}
}
pub struct TrieDBMut<'a, L>
where
L: TrieLayout,
{
storage: NodeStorage<L>,
db: &'a mut dyn HashDB<L::Hash, DBValue>,
root: &'a mut TrieHash<L>,
root_handle: NodeHandle<TrieHash<L>>,
death_row: HashSet<(TrieHash<L>, (BackingByteVec, Option<u8>))>,
hash_count: usize,
cache: Option<&'a mut dyn TrieCache<L::Codec>>,
recorder: Option<core::cell::RefCell<&'a mut dyn TrieRecorder<TrieHash<L>>>>,
}
impl<'a, L> TrieDBMut<'a, L>
where
L: TrieLayout,
{
pub fn db(&self) -> &dyn HashDB<L::Hash, DBValue> {
self.db
}
pub fn db_mut(&mut self) -> &mut dyn HashDB<L::Hash, DBValue> {
self.db
}
fn cache(
&mut self,
hash: TrieHash<L>,
key: Prefix,
) -> Result<StorageHandle, TrieHash<L>, CError<L>> {
let node = match self.cache.as_mut().and_then(|c| c.get_node(&hash)) {
Some(node) => {
if let Some(recorder) = self.recorder.as_mut() {
recorder.borrow_mut().record(TrieAccess::NodeOwned { hash, node_owned: &node });
}
Node::from_node_owned(&node, &mut self.storage)
},
None => {
let node_encoded = self
.db
.get(&hash, key)
.ok_or_else(|| Box::new(TrieError::IncompleteDatabase(hash)))?;
if let Some(recorder) = self.recorder.as_mut() {
recorder.borrow_mut().record(TrieAccess::EncodedNode {
hash,
encoded_node: node_encoded.as_slice().into(),
});
}
Node::from_encoded(hash, &node_encoded, &mut self.storage)?
},
};
Ok(self.storage.alloc(Stored::Cached(node, hash)))
}
fn inspect<F>(
&mut self,
stored: Stored<L>,
key: &mut NibbleFullKey,
inspector: F,
) -> Result<Option<(Stored<L>, bool)>, TrieHash<L>, CError<L>>
where
F: FnOnce(
&mut Self,
Node<L>,
&mut NibbleFullKey,
) -> Result<Action<L>, TrieHash<L>, CError<L>>,
{
let current_key = *key;
Ok(match stored {
Stored::New(node) => match inspector(self, node, key)? {
Action::Restore(node) => Some((Stored::New(node), false)),
Action::Replace(node) => Some((Stored::New(node), true)),
Action::Delete => None,
},
Stored::Cached(node, hash) => match inspector(self, node, key)? {
Action::Restore(node) => Some((Stored::Cached(node, hash), false)),
Action::Replace(node) => {
self.death_row.insert((hash, current_key.left_owned()));
Some((Stored::New(node), true))
},
Action::Delete => {
self.death_row.insert((hash, current_key.left_owned()));
None
},
},
})
}
fn lookup(
&self,
full_key: &[u8],
mut partial: NibbleSlice,
handle: &NodeHandle<TrieHash<L>>,
) -> Result<Option<DBValue>, TrieHash<L>, CError<L>> {
let mut handle = handle;
let prefix = (full_key, None);
loop {
let (mid, child) = match handle {
NodeHandle::Hash(hash) => {
let mut recorder = self.recorder.as_ref().map(|r| r.borrow_mut());
return Lookup::<L, _> {
db: &self.db,
query: |v: &[u8]| v.to_vec(),
hash: *hash,
cache: None,
recorder: recorder
.as_mut()
.map(|r| &mut ***r as &mut dyn TrieRecorder<TrieHash<L>>),
}
.look_up(full_key, partial)
},
NodeHandle::InMemory(handle) => match &self.storage[handle] {
Node::Empty => return Ok(None),
Node::Leaf(key, value) =>
if NibbleSlice::from_stored(key) == partial {
return Ok(value.in_memory_fetched_value(
prefix,
self.db,
&self.recorder,
full_key,
)?)
} else {
return Ok(None)
},
Node::Extension(slice, child) => {
let slice = NibbleSlice::from_stored(slice);
if partial.starts_with(&slice) {
(slice.len(), child)
} else {
return Ok(None)
}
},
Node::Branch(children, value) =>
if partial.is_empty() {
return Ok(if let Some(v) = value.as_ref() {
v.in_memory_fetched_value(
prefix,
self.db,
&self.recorder,
full_key,
)?
} else {
None
})
} else {
let idx = partial.at(0);
match children[idx as usize].as_ref() {
Some(child) => (1, child),
None => return Ok(None),
}
},
Node::NibbledBranch(slice, children, value) => {
let slice = NibbleSlice::from_stored(slice);
if slice == partial {
return Ok(if let Some(v) = value.as_ref() {
v.in_memory_fetched_value(
prefix,
self.db,
&self.recorder,
full_key,
)?
} else {
None
})
} else if partial.starts_with(&slice) {
let idx = partial.at(0);
match children[idx as usize].as_ref() {
Some(child) => (1 + slice.len(), child),
None => return Ok(None),
}
} else {
return Ok(None)
}
},
},
};
partial = partial.mid(mid);
handle = child;
}
}
fn insert_at(
&mut self,
handle: NodeHandle<TrieHash<L>>,
key: &mut NibbleFullKey,
value: Bytes,
old_val: &mut Option<Value<L>>,
) -> Result<(StorageHandle, bool), TrieHash<L>, CError<L>> {
let h = match handle {
NodeHandle::InMemory(h) => h,
NodeHandle::Hash(h) => self.cache(h, key.left())?,
};
let stored = self.storage.destroy(h);
let (new_stored, changed) = self
.inspect(stored, key, move |trie, stored, key| {
trie.insert_inspector(stored, key, value, old_val).map(|a| a.into_action())
})?
.expect("Insertion never deletes.");
Ok((self.storage.alloc(new_stored), changed))
}
fn replace_old_value(
&mut self,
old_value: &mut Option<Value<L>>,
stored_value: Option<Value<L>>,
prefix: Prefix,
) {
match &stored_value {
Some(Value::NewNode(Some(hash), _)) | Some(Value::Node(hash)) => {
self.death_row.insert((
hash.clone(),
(prefix.0.into(), prefix.1),
));
},
_ => (),
}
*old_value = stored_value;
}
fn insert_inspector(
&mut self,
node: Node<L>,
key: &mut NibbleFullKey,
value: Bytes,
old_val: &mut Option<Value<L>>,
) -> Result<InsertAction<L>, TrieHash<L>, CError<L>> {
let partial = *key;
#[cfg(feature = "std")]
trace!(target: "trie", "augmented (partial: {:?}, value: {:?})", partial, ToHex(&value));
Ok(match node {
Node::Empty => {
#[cfg(feature = "std")]
trace!(target: "trie", "empty: COMPOSE");
let value = Value::new(value, L::MAX_INLINE_VALUE);
InsertAction::Replace(Node::Leaf(partial.to_stored(), value))
},
Node::Branch(mut children, stored_value) => {
debug_assert!(L::USE_EXTENSION);
#[cfg(feature = "std")]
trace!(target: "trie", "branch: ROUTE,AUGMENT");
if partial.is_empty() {
let value = Some(Value::new(value, L::MAX_INLINE_VALUE));
let unchanged = stored_value == value;
let branch = Node::Branch(children, value);
self.replace_old_value(old_val, stored_value, key.left());
if unchanged {
InsertAction::Restore(branch)
} else {
InsertAction::Replace(branch)
}
} else {
let idx = partial.at(0) as usize;
key.advance(1);
if let Some(child) = children[idx].take() {
let (new_child, changed) = self.insert_at(child, key, value, old_val)?;
children[idx] = Some(new_child.into());
if !changed {
return Ok(InsertAction::Restore(Node::Branch(children, stored_value)))
}
} else {
let value = Value::new(value, L::MAX_INLINE_VALUE);
let leaf =
self.storage.alloc(Stored::New(Node::Leaf(key.to_stored(), value)));
children[idx] = Some(leaf.into());
}
InsertAction::Replace(Node::Branch(children, stored_value))
}
},
Node::NibbledBranch(encoded, mut children, stored_value) => {
debug_assert!(!L::USE_EXTENSION);
#[cfg(feature = "std")]
trace!(target: "trie", "branch: ROUTE,AUGMENT");
let existing_key = NibbleSlice::from_stored(&encoded);
let common = partial.common_prefix(&existing_key);
if common == existing_key.len() && common == partial.len() {
let value = Some(Value::new(value, L::MAX_INLINE_VALUE));
let unchanged = stored_value == value;
let branch = Node::NibbledBranch(existing_key.to_stored(), children, value);
let mut key_val = key.clone();
key_val.advance(existing_key.len());
self.replace_old_value(old_val, stored_value, key_val.left());
if unchanged {
InsertAction::Restore(branch)
} else {
InsertAction::Replace(branch)
}
} else if common < existing_key.len() {
#[cfg(feature = "std")]
trace!(
target: "trie",
"partially-shared-prefix (exist={:?}; new={:?}; common={:?}):\
AUGMENT-AT-END",
existing_key.len(),
partial.len(),
common,
);
let nbranch_partial = existing_key.mid(common + 1).to_stored();
let low = Node::NibbledBranch(nbranch_partial, children, stored_value);
let ix = existing_key.at(common);
let mut children = empty_children();
let alloc_storage = self.storage.alloc(Stored::New(low));
children[ix as usize] = Some(alloc_storage.into());
let value = Value::new(value, L::MAX_INLINE_VALUE);
if partial.len() - common == 0 {
InsertAction::Replace(Node::NibbledBranch(
existing_key.to_stored_range(common),
children,
Some(value),
))
} else {
let ix = partial.at(common);
let stored_leaf = Node::Leaf(partial.mid(common + 1).to_stored(), value);
let leaf = self.storage.alloc(Stored::New(stored_leaf));
children[ix as usize] = Some(leaf.into());
InsertAction::Replace(Node::NibbledBranch(
existing_key.to_stored_range(common),
children,
None,
))
}
} else {
#[cfg(feature = "std")]
trace!(target: "trie", "branch: ROUTE,AUGMENT");
let idx = partial.at(common) as usize;
key.advance(common + 1);
if let Some(child) = children[idx].take() {
let (new_child, changed) = self.insert_at(child, key, value, old_val)?;
children[idx] = Some(new_child.into());
if !changed {
let n_branch = Node::NibbledBranch(
existing_key.to_stored(),
children,
stored_value,
);
return Ok(InsertAction::Restore(n_branch))
}
} else {
let value = Value::new(value, L::MAX_INLINE_VALUE);
let leaf =
self.storage.alloc(Stored::New(Node::Leaf(key.to_stored(), value)));
children[idx] = Some(leaf.into());
}
InsertAction::Replace(Node::NibbledBranch(
existing_key.to_stored(),
children,
stored_value,
))
}
},
Node::Leaf(encoded, stored_value) => {
let existing_key = NibbleSlice::from_stored(&encoded);
let common = partial.common_prefix(&existing_key);
if common == existing_key.len() && common == partial.len() {
#[cfg(feature = "std")]
trace!(target: "trie", "equivalent-leaf: REPLACE");
let value = Value::new(value, L::MAX_INLINE_VALUE);
let unchanged = stored_value == value;
let mut key_val = key.clone();
key_val.advance(existing_key.len());
self.replace_old_value(old_val, Some(stored_value), key_val.left());
if unchanged {
InsertAction::Restore(Node::Leaf(encoded.clone(), value))
} else {
InsertAction::Replace(Node::Leaf(encoded.clone(), value))
}
} else if (L::USE_EXTENSION && common == 0) ||
(!L::USE_EXTENSION && common < existing_key.len())
{
#[cfg(feature = "std")]
trace!(
target: "trie",
"lesser-common-prefix, not-both-empty (exist={:?}; new={:?}):\
TRANSMUTE,AUGMENT",
existing_key.len(),
partial.len(),
);
let mut children = empty_children();
let branch = if L::USE_EXTENSION && existing_key.is_empty() {
Node::Branch(children, Some(stored_value))
} else {
let idx = existing_key.at(common) as usize;
let new_leaf =
Node::Leaf(existing_key.mid(common + 1).to_stored(), stored_value);
children[idx] = Some(self.storage.alloc(Stored::New(new_leaf)).into());
if L::USE_EXTENSION {
Node::Branch(children, None)
} else {
Node::NibbledBranch(partial.to_stored_range(common), children, None)
}
};
let branch_action =
self.insert_inspector(branch, key, value, old_val)?.unwrap_node();
InsertAction::Replace(branch_action)
} else if !L::USE_EXTENSION {
#[cfg(feature = "std")]
trace!(target: "trie", "complete-prefix (common={:?}): AUGMENT-AT-END", common);
let branch = Node::NibbledBranch(
existing_key.to_stored(),
empty_children(),
Some(stored_value),
);
let branch = self.insert_inspector(branch, key, value, old_val)?.unwrap_node();
InsertAction::Replace(branch)
} else if common == existing_key.len() {
debug_assert!(L::USE_EXTENSION);
#[cfg(feature = "std")]
trace!(target: "trie", "complete-prefix (common={:?}): AUGMENT-AT-END", common);
let branch = Node::Branch(empty_children(), Some(stored_value));
key.advance(common);
let branch = self.insert_inspector(branch, key, value, old_val)?.unwrap_node();
let leaf = self.storage.alloc(Stored::New(branch));
InsertAction::Replace(Node::Extension(existing_key.to_stored(), leaf.into()))
} else {
debug_assert!(L::USE_EXTENSION);
#[cfg(feature = "std")]
trace!(
target: "trie",
"partially-shared-prefix (exist={:?}; new={:?}; common={:?}):\
AUGMENT-AT-END",
existing_key.len(),
partial.len(),
common,
);
let low = Node::Leaf(existing_key.mid(common).to_stored(), stored_value);
key.advance(common);
let augmented_low =
self.insert_inspector(low, key, value, old_val)?.unwrap_node();
InsertAction::Replace(Node::Extension(
existing_key.to_stored_range(common),
self.storage.alloc(Stored::New(augmented_low)).into(),
))
}
},
Node::Extension(encoded, child_branch) => {
debug_assert!(L::USE_EXTENSION);
let existing_key = NibbleSlice::from_stored(&encoded);
let common = partial.common_prefix(&existing_key);
if common == 0 {
#[cfg(feature = "std")]
trace!(
target: "trie",
"no-common-prefix, not-both-empty (exist={:?}; new={:?}):\
TRANSMUTE,AUGMENT",
existing_key.len(),
partial.len(),
);
assert!(!existing_key.is_empty());
let idx = existing_key.at(0) as usize;
let mut children = empty_children();
children[idx] = if existing_key.len() == 1 {
Some(child_branch)
} else {
let ext = Node::Extension(existing_key.mid(1).to_stored(), child_branch);
Some(self.storage.alloc(Stored::New(ext)).into())
};
let branch_action = self
.insert_inspector(Node::Branch(children, None), key, value, old_val)?
.unwrap_node();
InsertAction::Replace(branch_action)
} else if common == existing_key.len() {
#[cfg(feature = "std")]
trace!(target: "trie", "complete-prefix (common={:?}): AUGMENT-AT-END", common);
key.advance(common);
let (new_child, changed) = self.insert_at(child_branch, key, value, old_val)?;
let new_ext = Node::Extension(existing_key.to_stored(), new_child.into());
if changed {
InsertAction::Replace(new_ext)
} else {
InsertAction::Restore(new_ext)
}
} else {
#[cfg(feature = "std")]
trace!(
target: "trie",
"partially-shared-prefix (exist={:?}; new={:?}; common={:?}):\
AUGMENT-AT-END",
existing_key.len(),
partial.len(),
common,
);
let low = Node::Extension(existing_key.mid(common).to_stored(), child_branch);
key.advance(common);
let augmented_low =
self.insert_inspector(low, key, value, old_val)?.unwrap_node();
InsertAction::Replace(Node::Extension(
existing_key.to_stored_range(common),
self.storage.alloc(Stored::New(augmented_low)).into(),
))
}
},
})
}
fn remove_at(
&mut self,
handle: NodeHandle<TrieHash<L>>,
key: &mut NibbleFullKey,
old_val: &mut Option<Value<L>>,
) -> Result<Option<(StorageHandle, bool)>, TrieHash<L>, CError<L>> {
let stored = match handle {
NodeHandle::InMemory(h) => self.storage.destroy(h),
NodeHandle::Hash(h) => {
let handle = self.cache(h, key.left())?;
self.storage.destroy(handle)
},
};
let opt = self.inspect(stored, key, move |trie, node, key| {
trie.remove_inspector(node, key, old_val)
})?;
Ok(opt.map(|(new, changed)| (self.storage.alloc(new), changed)))
}
fn remove_inspector(
&mut self,
node: Node<L>,
key: &mut NibbleFullKey,
old_val: &mut Option<Value<L>>,
) -> Result<Action<L>, TrieHash<L>, CError<L>> {
let partial = *key;
Ok(match (node, partial.is_empty()) {
(Node::Empty, _) => Action::Delete,
(Node::Branch(c, None), true) => Action::Restore(Node::Branch(c, None)),
(Node::NibbledBranch(n, c, None), true) =>
Action::Restore(Node::NibbledBranch(n, c, None)),
(Node::Branch(children, val), true) => {
self.replace_old_value(old_val, val, key.left());
Action::Replace(self.fix(Node::Branch(children, None), *key)?)
},
(Node::NibbledBranch(n, children, val), true) => {
self.replace_old_value(old_val, val, key.left());
Action::Replace(self.fix(Node::NibbledBranch(n, children, None), *key)?)
},
(Node::Branch(mut children, value), false) => {
let idx = partial.at(0) as usize;
if let Some(child) = children[idx].take() {
#[cfg(feature = "std")]
trace!(
target: "trie",
"removing value out of branch child, partial={:?}",
partial,
);
let prefix = *key;
key.advance(1);
match self.remove_at(child, key, old_val)? {
Some((new, changed)) => {
children[idx] = Some(new.into());
let branch = Node::Branch(children, value);
match changed {
true => Action::Replace(branch),
false => Action::Restore(branch),
}
},
None => {
#[cfg(feature = "std")]
trace!(target: "trie", "branch child deleted, partial={:?}", partial);
Action::Replace(self.fix(Node::Branch(children, value), prefix)?)
},
}
} else {
Action::Restore(Node::Branch(children, value))
}
},
(Node::NibbledBranch(encoded, mut children, value), false) => {
let (common, existing_length) = {
let existing_key = NibbleSlice::from_stored(&encoded);
(existing_key.common_prefix(&partial), existing_key.len())
};
if common == existing_length && common == partial.len() {
if let Some(value) = value {
let mut key_val = key.clone();
key_val.advance(existing_length);
self.replace_old_value(old_val, Some(value), key_val.left());
let f = self.fix(Node::NibbledBranch(encoded, children, None), *key);
Action::Replace(f?)
} else {
Action::Restore(Node::NibbledBranch(encoded, children, None))
}
} else if common < existing_length {
Action::Restore(Node::NibbledBranch(encoded, children, value))
} else {
let idx = partial.at(common) as usize;
if let Some(child) = children[idx].take() {
#[cfg(feature = "std")]
trace!(
target: "trie",
"removing value out of branch child, partial={:?}",
partial,
);
let prefix = *key;
key.advance(common + 1);
match self.remove_at(child, key, old_val)? {
Some((new, changed)) => {
children[idx] = Some(new.into());
let branch = Node::NibbledBranch(encoded, children, value);
match changed {
true => Action::Replace(branch),
false => Action::Restore(branch),
}
},
None => {
#[cfg(feature = "std")]
trace!(
target: "trie",
"branch child deleted, partial={:?}",
partial,
);
Action::Replace(
self.fix(
Node::NibbledBranch(encoded, children, value),
prefix,
)?,
)
},
}
} else {
Action::Restore(Node::NibbledBranch(encoded, children, value))
}
}
},
(Node::Leaf(encoded, value), _) => {
let existing_key = NibbleSlice::from_stored(&encoded);
if existing_key == partial {
let mut key_val = key.clone();
key_val.advance(existing_key.len());
self.replace_old_value(old_val, Some(value), key_val.left());
Action::Delete
} else {
#[cfg(feature = "std")]
trace!(
target: "trie",
"restoring leaf wrong partial, partial={:?}, existing={:?}",
partial,
NibbleSlice::from_stored(&encoded),
);
Action::Restore(Node::Leaf(encoded, value))
}
},
(Node::Extension(encoded, child_branch), _) => {
let (common, existing_length) = {
let existing_key = NibbleSlice::from_stored(&encoded);
(existing_key.common_prefix(&partial), existing_key.len())
};
if common == existing_length {
#[cfg(feature = "std")]
trace!(target: "trie", "removing from extension child, partial={:?}", partial);
let prefix = *key;
key.advance(common);
match self.remove_at(child_branch, key, old_val)? {
Some((new_child, changed)) => {
match changed {
true => Action::Replace(
self.fix(Node::Extension(encoded, new_child.into()), prefix)?,
),
false =>
Action::Restore(Node::Extension(encoded, new_child.into())),
}
},
None => {
Action::Delete
},
}
} else {
Action::Restore(Node::Extension(encoded, child_branch))
}
},
})
}
fn fix(&mut self, node: Node<L>, key: NibbleSlice) -> Result<Node<L>, TrieHash<L>, CError<L>> {
self.fix_inner(node, key, false)
}
fn fix_inner(
&mut self,
node: Node<L>,
key: NibbleSlice,
recurse_extension: bool,
) -> Result<Node<L>, TrieHash<L>, CError<L>> {
match node {
Node::Branch(mut children, value) => {
#[cfg_attr(feature = "std", derive(Debug))]
enum UsedIndex {
None,
One(u8),
Many,
}
let mut used_index = UsedIndex::None;
for i in 0..16 {
match (children[i].is_none(), &used_index) {
(false, &UsedIndex::None) => used_index = UsedIndex::One(i as u8),
(false, &UsedIndex::One(_)) => {
used_index = UsedIndex::Many;
break
},
_ => continue,
}
}
match (used_index, value) {
(UsedIndex::None, None) => {
panic!("Branch with no subvalues. Something went wrong.")
},
(UsedIndex::One(a), None) => {
let new_partial = NibbleSlice::new_offset(&[a], 1).to_stored();
let child = children[a as usize]
.take()
.expect("used_index only set if occupied; qed");
let new_node = Node::Extension(new_partial, child);
self.fix(new_node, key)
},
(UsedIndex::None, Some(value)) => {
#[cfg(feature = "std")]
trace!(target: "trie", "fixing: branch -> leaf");
Ok(Node::Leaf(NibbleSlice::new(&[]).to_stored(), value))
},
(_, value) => {
#[cfg(feature = "std")]
trace!(target: "trie", "fixing: restoring branch");
Ok(Node::Branch(children, value))
},
}
},
Node::NibbledBranch(enc_nibble, mut children, value) => {
#[cfg_attr(feature = "std", derive(Debug))]
enum UsedIndex {
None,
One(u8),
Many,
}
let mut used_index = UsedIndex::None;
for i in 0..16 {
match (children[i].is_none(), &used_index) {
(false, &UsedIndex::None) => used_index = UsedIndex::One(i as u8),
(false, &UsedIndex::One(_)) => {
used_index = UsedIndex::Many;
break
},
_ => continue,
}
}
match (used_index, value) {
(UsedIndex::None, None) => {
panic!("Branch with no subvalues. Something went wrong.")
},
(UsedIndex::One(a), None) => {
let child = children[a as usize]
.take()
.expect("used_index only set if occupied; qed");
let mut key2 = key.clone();
key2.advance(
(enc_nibble.1.len() * nibble_ops::NIBBLE_PER_BYTE) - enc_nibble.0,
);
let (start, alloc_start, prefix_end) = match key2.left() {
(start, None) => (start, None, Some(nibble_ops::push_at_left(0, a, 0))),
(start, Some(v)) => {
let mut so: BackingByteVec = start.into();
so.push(nibble_ops::pad_left(v) | a);
(start, Some(so), None)
},
};
let child_prefix = (
alloc_start.as_ref().map(|start| &start[..]).unwrap_or(start),
prefix_end,
);
let stored = match child {
NodeHandle::InMemory(h) => self.storage.destroy(h),
NodeHandle::Hash(h) => {
let handle = self.cache(h, child_prefix)?;
self.storage.destroy(handle)
},
};
let child_node = match stored {
Stored::New(node) => node,
Stored::Cached(node, hash) => {
self.death_row
.insert((hash, (child_prefix.0[..].into(), child_prefix.1)));
node
},
};
match child_node {
Node::Leaf(sub_partial, value) => {
let mut enc_nibble = enc_nibble;
combine_key(
&mut enc_nibble,
(nibble_ops::NIBBLE_PER_BYTE - 1, &[a][..]),
);
combine_key(&mut enc_nibble, (sub_partial.0, &sub_partial.1[..]));
Ok(Node::Leaf(enc_nibble, value))
},
Node::NibbledBranch(sub_partial, ch_children, ch_value) => {
let mut enc_nibble = enc_nibble;
combine_key(
&mut enc_nibble,
(nibble_ops::NIBBLE_PER_BYTE - 1, &[a][..]),
);
combine_key(&mut enc_nibble, (sub_partial.0, &sub_partial.1[..]));
Ok(Node::NibbledBranch(enc_nibble, ch_children, ch_value))
},
_ => unreachable!(),
}
},
(UsedIndex::None, Some(value)) => {
#[cfg(feature = "std")]
trace!(target: "trie", "fixing: branch -> leaf");
Ok(Node::Leaf(enc_nibble, value))
},
(_, value) => {
#[cfg(feature = "std")]
trace!(target: "trie", "fixing: restoring branch");
Ok(Node::NibbledBranch(enc_nibble, children, value))
},
}
},
Node::Extension(partial, child) => {
let mut key2 = key.clone();
let (start, alloc_start, prefix_end) = if !recurse_extension {
let last = partial.1[partial.1.len() - 1] & (255 >> 4);
key2.advance((partial.1.len() * nibble_ops::NIBBLE_PER_BYTE) - partial.0 - 1);
match key2.left() {
(start, None) => (start, None, Some(nibble_ops::push_at_left(0, last, 0))),
(start, Some(v)) => {
let mut so: BackingByteVec = start.into();
so.push(nibble_ops::pad_left(v) | last);
(start, Some(so), None)
},
}
} else {
let k2 = key2.left();
let mut so: NibbleVec = Default::default();
so.append_optional_slice_and_nibble(Some(&NibbleSlice::new(k2.0)), None);
if let Some(n) = k2.1 {
so.push(n >> nibble_ops::BIT_PER_NIBBLE);
}
so.append_optional_slice_and_nibble(
Some(&NibbleSlice::from_stored(&partial)),
None,
);
let so = so.as_prefix();
(k2.0, Some(so.0.into()), so.1)
};
let child_prefix =
(alloc_start.as_ref().map(|start| &start[..]).unwrap_or(start), prefix_end);
let stored = match child {
NodeHandle::InMemory(h) => self.storage.destroy(h),
NodeHandle::Hash(h) => {
let handle = self.cache(h, child_prefix)?;
self.storage.destroy(handle)
},
};
let (child_node, maybe_hash) = match stored {
Stored::New(node) => (node, None),
Stored::Cached(node, hash) => (node, Some(hash)),
};
match child_node {
Node::Extension(sub_partial, sub_child) => {
if let Some(hash) = maybe_hash {
self.death_row
.insert((hash, (child_prefix.0[..].into(), child_prefix.1)));
}
let mut partial = partial;
combine_key(&mut partial, (sub_partial.0, &sub_partial.1[..]));
#[cfg(feature = "std")]
trace!(
target: "trie",
"fixing: extension combination. new_partial={:?}",
partial,
);
self.fix_inner(Node::Extension(partial, sub_child), key.into(), true)
},
Node::Leaf(sub_partial, value) => {
if let Some(hash) = maybe_hash {
self.death_row
.insert((hash, (child_prefix.0[..].into(), child_prefix.1)));
}
let mut partial = partial;
combine_key(&mut partial, (sub_partial.0, &sub_partial.1[..]));
#[cfg(feature = "std")]
trace!(
target: "trie",
"fixing: extension -> leaf. new_partial={:?}",
partial,
);
Ok(Node::Leaf(partial, value))
},
child_node => {
#[cfg(feature = "std")]
trace!(target: "trie", "fixing: restoring extension");
let stored = if let Some(hash) = maybe_hash {
Stored::Cached(child_node, hash)
} else {
Stored::New(child_node)
};
Ok(Node::Extension(partial, self.storage.alloc(stored).into()))
},
}
},
other => Ok(other), }
}
pub fn commit(&mut self) {
#[cfg(feature = "std")]
trace!(target: "trie", "Committing trie changes to db.");
#[cfg(feature = "std")]
trace!(target: "trie", "{:?} nodes to remove from db", self.death_row.len());
for (hash, prefix) in self.death_row.drain() {
self.db.remove(&hash, (&prefix.0[..], prefix.1));
}
let handle = match self.root_handle() {
NodeHandle::Hash(_) => return, NodeHandle::InMemory(h) => h,
};
match self.storage.destroy(handle) {
Stored::New(node) => {
let full_key = self.cache.as_ref().and_then(|_| {
node.partial_key().and_then(|k| Some(NibbleSlice::from_stored(k).into()))
});
let mut k = NibbleVec::new();
let encoded_root = node.into_encoded(|node, o_slice, o_index| {
let mov = k.append_optional_slice_and_nibble(o_slice, o_index);
match node {
NodeToEncode::Node(value) => {
let value_hash = self.db.insert(k.as_prefix(), value);
self.cache_value(k.inner(), value, value_hash);
k.drop_lasts(mov);
ChildReference::Hash(value_hash)
},
NodeToEncode::TrieNode(child) => {
let result = self.commit_child(child, &mut k);
k.drop_lasts(mov);
result
},
}
});
#[cfg(feature = "std")]
trace!(target: "trie", "encoded root node: {:?}", ToHex(&encoded_root[..]));
*self.root = self.db.insert(EMPTY_PREFIX, &encoded_root);
self.hash_count += 1;
self.cache_node(*self.root, &encoded_root, full_key);
self.root_handle = NodeHandle::Hash(*self.root);
},
Stored::Cached(node, hash) => {
*self.root = hash;
self.root_handle =
NodeHandle::InMemory(self.storage.alloc(Stored::Cached(node, hash)));
},
}
}
fn cache_node(&mut self, hash: TrieHash<L>, encoded: &[u8], full_key: Option<NibbleVec>) {
if let Some(cache) = self.cache.as_mut() {
let node = cache.get_or_insert_node(hash, &mut || {
Ok(L::Codec::decode(&encoded)
.ok()
.and_then(|n| n.to_owned_node::<L>().ok())
.expect("Just encoded the node, so it should decode without any errors; qed"))
});
let node = if let Ok(node) = node { node } else { return };
let mut values_to_cache = Vec::new();
if let Some(full_key) = full_key {
node.data().and_then(|v| node.data_hash().map(|h| (&full_key, v, h))).map(
|(k, v, h)| {
values_to_cache.push((k.inner().to_vec(), (v.clone(), h).into()));
},
);
fn cache_child_values<L: TrieLayout>(
node: &NodeOwned<TrieHash<L>>,
values_to_cache: &mut Vec<(Vec<u8>, CachedValue<TrieHash<L>>)>,
full_key: NibbleVec,
) {
node.child_iter().flat_map(|(n, c)| c.as_inline().map(|c| (n, c))).for_each(
|(n, c)| {
let mut key = full_key.clone();
n.map(|n| key.push(n));
c.partial_key().map(|p| key.append(p));
if let Some((hash, data)) =
c.data().and_then(|d| c.data_hash().map(|h| (h, d)))
{
values_to_cache
.push((key.inner().to_vec(), (data.clone(), hash).into()));
}
cache_child_values::<L>(c, values_to_cache, key);
},
);
}
cache_child_values::<L>(&node, &mut values_to_cache, full_key.clone());
}
drop(node);
values_to_cache.into_iter().for_each(|(k, v)| cache.cache_value_for_key(&k, v));
}
}
fn cache_value(&mut self, full_key: &[u8], value: impl Into<Bytes>, hash: TrieHash<L>) {
if let Some(cache) = self.cache.as_mut() {
let value = value.into();
let value = if let Ok(value) = cache
.get_or_insert_node(hash, &mut || Ok(NodeOwned::Value(value.clone(), hash)))
.map(|n| n.data().cloned())
{
value
} else {
None
};
if let Some(value) = value {
cache.cache_value_for_key(full_key, (value, hash).into())
}
}
}
fn commit_child(
&mut self,
handle: NodeHandle<TrieHash<L>>,
prefix: &mut NibbleVec,
) -> ChildReference<TrieHash<L>> {
match handle {
NodeHandle::Hash(hash) => ChildReference::Hash(hash),
NodeHandle::InMemory(storage_handle) => {
match self.storage.destroy(storage_handle) {
Stored::Cached(_, hash) => ChildReference::Hash(hash),
Stored::New(node) => {
let full_key = self.cache.as_ref().and_then(|_| {
let mut prefix = prefix.clone();
if let Some(partial) = node.partial_key() {
prefix.append_partial(NibbleSlice::from_stored(partial).right());
}
Some(prefix)
});
let encoded = {
let commit_child = |node: NodeToEncode<TrieHash<L>>,
o_slice: Option<&NibbleSlice>,
o_index: Option<u8>| {
let mov = prefix.append_optional_slice_and_nibble(o_slice, o_index);
match node {
NodeToEncode::Node(value) => {
let value_hash = self.db.insert(prefix.as_prefix(), value);
self.cache_value(prefix.inner(), value, value_hash);
prefix.drop_lasts(mov);
ChildReference::Hash(value_hash)
},
NodeToEncode::TrieNode(node_handle) => {
let result = self.commit_child(node_handle, prefix);
prefix.drop_lasts(mov);
result
},
}
};
node.into_encoded(commit_child)
};
if encoded.len() >= L::Hash::LENGTH {
let hash = self.db.insert(prefix.as_prefix(), &encoded);
self.hash_count += 1;
self.cache_node(hash, &encoded, full_key);
ChildReference::Hash(hash)
} else {
let mut h = <TrieHash<L>>::default();
let len = encoded.len();
h.as_mut()[..len].copy_from_slice(&encoded[..len]);
ChildReference::Inline(h, len)
}
},
}
},
}
}
fn root_handle(&self) -> NodeHandle<TrieHash<L>> {
match self.root_handle {
NodeHandle::Hash(h) => NodeHandle::Hash(h),
NodeHandle::InMemory(StorageHandle(x)) => NodeHandle::InMemory(StorageHandle(x)),
}
}
}
impl<'a, L> TrieMut<L> for TrieDBMut<'a, L>
where
L: TrieLayout,
{
fn root(&mut self) -> &TrieHash<L> {
self.commit();
self.root
}
fn is_empty(&self) -> bool {
match self.root_handle {
NodeHandle::Hash(h) => h == L::Codec::hashed_null_node(),
NodeHandle::InMemory(ref h) => match self.storage[h] {
Node::Empty => true,
_ => false,
},
}
}
fn get<'x, 'key>(&'x self, key: &'key [u8]) -> Result<Option<DBValue>, TrieHash<L>, CError<L>>
where
'x: 'key,
{
self.lookup(key, NibbleSlice::new(key), &self.root_handle)
}
fn insert(
&mut self,
key: &[u8],
value: &[u8],
) -> Result<Option<Value<L>>, TrieHash<L>, CError<L>> {
if !L::ALLOW_EMPTY && value.is_empty() {
return self.remove(key)
}
let mut old_val = None;
#[cfg(feature = "std")]
trace!(target: "trie", "insert: key={:?}, value={:?}", ToHex(key), ToHex(&value));
let value = Bytes::from(value);
let root_handle = self.root_handle();
let (new_handle, _changed) =
self.insert_at(root_handle, &mut NibbleSlice::new(key), value, &mut old_val)?;
#[cfg(feature = "std")]
trace!(target: "trie", "insert: altered trie={}", _changed);
self.root_handle = NodeHandle::InMemory(new_handle);
Ok(old_val)
}
fn remove(&mut self, key: &[u8]) -> Result<Option<Value<L>>, TrieHash<L>, CError<L>> {
#[cfg(feature = "std")]
trace!(target: "trie", "remove: key={:?}", ToHex(key));
let root_handle = self.root_handle();
let mut key_slice = NibbleSlice::new(key);
let mut old_val = None;
match self.remove_at(root_handle, &mut key_slice, &mut old_val)? {
Some((handle, _changed)) => {
#[cfg(feature = "std")]
trace!(target: "trie", "remove: altered trie={}", _changed);
self.root_handle = NodeHandle::InMemory(handle);
},
None => {
#[cfg(feature = "std")]
trace!(target: "trie", "remove: obliterated trie");
self.root_handle = NodeHandle::Hash(L::Codec::hashed_null_node());
*self.root = L::Codec::hashed_null_node();
},
}
Ok(old_val)
}
}
impl<'a, L> Drop for TrieDBMut<'a, L>
where
L: TrieLayout,
{
fn drop(&mut self) {
self.commit();
}
}
fn combine_key(start: &mut NodeKey, end: (usize, &[u8])) {
debug_assert!(start.0 < nibble_ops::NIBBLE_PER_BYTE);
debug_assert!(end.0 < nibble_ops::NIBBLE_PER_BYTE);
let final_offset = (start.0 + end.0) % nibble_ops::NIBBLE_PER_BYTE;
let _shifted = nibble_ops::shift_key(start, final_offset);
let st = if end.0 > 0 {
let sl = start.1.len();
start.1[sl - 1] |= nibble_ops::pad_right(end.1[0]);
1
} else {
0
};
(st..end.1.len()).for_each(|i| start.1.push(end.1[i]));
}
#[cfg(test)]
mod tests {
use crate::nibble::BackingByteVec;
#[test]
fn combine_test() {
let a: BackingByteVec = [0x12, 0x34][..].into();
let b: &[u8] = [0x56, 0x78][..].into();
let test_comb = |a: (_, &BackingByteVec), b, c| {
let mut a = (a.0, a.1.clone());
super::combine_key(&mut a, b);
assert_eq!((a.0, &a.1[..]), c);
};
test_comb((0, &a), (0, &b), (0, &[0x12, 0x34, 0x56, 0x78][..]));
test_comb((1, &a), (0, &b), (1, &[0x12, 0x34, 0x56, 0x78][..]));
test_comb((0, &a), (1, &b), (1, &[0x01, 0x23, 0x46, 0x78][..]));
test_comb((1, &a), (1, &b), (0, &[0x23, 0x46, 0x78][..]));
}
}