aboutsummaryrefslogtreecommitdiff
path: root/src/table.rs
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2020-04-17 21:59:07 +0200
committerAlex Auvolat <alex@adnab.me>2020-04-17 21:59:07 +0200
commit3f40ef149f6dd4d61ceb326b5691e186aec178c3 (patch)
treef28af6fdb06cbe9b3f91f54aab9c4077bd83276d /src/table.rs
parentf62b54f1dffe9b76aab47d32ba7f47411d5a58af (diff)
downloadgarage-3f40ef149f6dd4d61ceb326b5691e186aec178c3.tar.gz
garage-3f40ef149f6dd4d61ceb326b5691e186aec178c3.zip
Fix sync: use max root checksum level
Diffstat (limited to 'src/table.rs')
-rw-r--r--src/table.rs4
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