diff options
| author | Alex Auvolat <alex@adnab.me> | 2023-01-03 15:27:36 +0100 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2023-01-03 15:27:36 +0100 |
| commit | 8d5505514f950dc1ca1249a3385c9913b5b5e8e0 (patch) | |
| tree | a74c043fe76deab6cb0919c6f002f0a4e87be19d /src/table/sync.rs | |
| parent | 426d8784dac0e39879af52d980887d3692fc907c (diff) | |
| download | garage-8d5505514f950dc1ca1249a3385c9913b5b5e8e0.tar.gz garage-8d5505514f950dc1ca1249a3385c9913b5b5e8e0.zip | |
Make it explicit when using nonversioned encoding
Diffstat (limited to 'src/table/sync.rs')
| -rw-r--r-- | src/table/sync.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/table/sync.rs b/src/table/sync.rs index 29e7aa89..c66c863f 100644 --- a/src/table/sync.rs +++ b/src/table/sync.rs @@ -14,6 +14,7 @@ use tokio::sync::{mpsc, watch}; use garage_util::background::*; use garage_util::data::*; +use garage_util::encode::nonversioned_encode; use garage_util::error::{Error, OkOrMessage}; use garage_rpc::ring::*; @@ -615,7 +616,7 @@ impl<F: TableSchema, R: TableReplication> Worker for SyncWorker<F, R> { // ---- UTIL ---- fn hash_of_merkle_node(x: &MerkleNode) -> Result<Hash, Error> { - Ok(blake2sum(&rmp_to_vec_all_named(x)?[..])) + Ok(blake2sum(&nonversioned_encode(x)?[..])) } fn join_ordered<'a, K: Ord + Eq, V1, V2>( |