diff options
author | Alex Auvolat <alex@adnab.me> | 2020-04-17 21:59:07 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2020-04-17 21:59:07 +0200 |
commit | 3f40ef149f6dd4d61ceb326b5691e186aec178c3 (patch) | |
tree | f28af6fdb06cbe9b3f91f54aab9c4077bd83276d /src/table.rs | |
parent | f62b54f1dffe9b76aab47d32ba7f47411d5a58af (diff) | |
download | garage-3f40ef149f6dd4d61ceb326b5691e186aec178c3.tar.gz garage-3f40ef149f6dd4d61ceb326b5691e186aec178c3.zip |
Fix sync: use max root checksum level
Diffstat (limited to 'src/table.rs')
-rw-r--r-- | src/table.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/table.rs b/src/table.rs index d2c7de94..3ad08cff 100644 --- a/src/table.rs +++ b/src/table.rs @@ -155,7 +155,7 @@ impl<F: TableSchema + 'static> Table<F> { let hash = e.partition_key().hash(); let ring = self.system.ring.borrow().clone(); let who = ring.walk_ring(&hash, self.param.replication_factor); - eprintln!("insert who: {:?}", who); + //eprintln!("insert who: {:?}", who); let e_enc = Arc::new(ByteBuf::from(rmp_to_vec_all_named(e)?)); let rpc = &TableRPC::<F>::Update(vec![e_enc]); @@ -212,7 +212,7 @@ impl<F: TableSchema + 'static> Table<F> { let hash = partition_key.hash(); let ring = self.system.ring.borrow().clone(); let who = ring.walk_ring(&hash, self.param.replication_factor); - eprintln!("get who: {:?}", who); + //eprintln!("get who: {:?}", who); let rpc = &TableRPC::<F>::ReadEntry(partition_key.clone(), sort_key.clone()); let resps = self |