diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-17 20:58:10 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-17 20:58:10 +0200 |
| commit | 40c48e6a590c887586664957da2dca0f368cdcb2 (patch) | |
| tree | 6b99550c514e99bdd4b045a32863a9e8804cced8 /src/table.rs | |
| parent | 29a1e94f233af943243e4334447db6209e3e80f1 (diff) | |
| download | garage-40c48e6a590c887586664957da2dca0f368cdcb2.tar.gz garage-40c48e6a590c887586664957da2dca0f368cdcb2.zip | |
Several resync workers; add delay on retry resync
Diffstat (limited to 'src/table.rs')
| -rw-r--r-- | src/table.rs | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/table.rs b/src/table.rs index 9b67ad94..d2c7de94 100644 --- a/src/table.rs +++ b/src/table.rs @@ -326,7 +326,7 @@ impl<F: TableSchema + 'static> Table<F> { rpc: &TableRPC<F>, quorum: usize, ) -> Result<Vec<TableRPC<F>>, Error> { - eprintln!("Table RPC to {:?}: {}", who, serde_json::to_string(&rpc)?); + //eprintln!("Table RPC to {:?}: {}", who, serde_json::to_string(&rpc)?); let rpc_bytes = rmp_to_vec_all_named(rpc)?; let rpc_msg = Message::TableRPC(self.name.to_string(), rpc_bytes); @@ -353,10 +353,10 @@ impl<F: TableSchema + 'static> Table<F> { resp ))); } - eprintln!( - "Table RPC responses: {}", - serde_json::to_string(&resps_vals)? - ); + //eprintln!( + // "Table RPC responses: {}", + // serde_json::to_string(&resps_vals)? + //); Ok(resps_vals) } |