diff --git a/src/persistency/versioning/version_vector.rs b/src/persistency/versioning/version_vector.rs index 6f89897..5948dee 100644 --- a/src/persistency/versioning/version_vector.rs +++ b/src/persistency/versioning/version_vector.rs @@ -78,7 +78,8 @@ impl VersionVector { where F: FnMut(&ProcessId, &Version, &Version), { - let mut process_ids: Vec<&u128> = lhs.versions.keys().chain(rhs.versions.keys()).collect(); + let mut process_ids: Vec<&ProcessId> = + lhs.versions.keys().chain(rhs.versions.keys()).collect(); process_ids.sort(); process_ids.dedup(); let process_ids = process_ids.into_iter(); @@ -148,7 +149,7 @@ impl VersionVector { /// returns the expected serialized size of the given [`VersionVector`] instance pub fn serialized_size(&self) -> usize { - size_of::() + self.versions.len() * 2 * size_of::() + size_of::() + self.versions.len() * 2 * size_of::() } /// Deserializes [bytes::Bytes] into [`VersionVector`] @@ -160,7 +161,7 @@ impl VersionVector { } let n_items = serialized_vv.get_u32() as usize; - let expected_size = n_items * 2 * size_of::(); + let expected_size = n_items * 2 * size_of::(); if serialized_vv.len() != expected_size { return Err(Error::Internal(crate::error::Internal::Unknown { reason: format!( "buffer provided to deserialize into VersionVector has the wrong size. Expected {}, got {}", expected_size, serialized_vv.len())})); @@ -330,7 +331,7 @@ mod tests { let serialized = vv.serialize(); assert_eq!( serialized.len(), - size_of::() + (vv.versions.len() * 2 * size_of::()) + size_of::() + (vv.versions.len() * 2 * size_of::()) ); let deserialized = VersionVector::deserialize(vv.id, serialized).unwrap();