diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-16 23:13:15 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-16 23:13:15 +0200 |
| commit | 6ce14e2c9eb1ba81add3f61377a5a83854880b42 (patch) | |
| tree | a920499c387af62fa98e87cf8ca942890e573487 /src/table.rs | |
| parent | 4fe8329847fe5d39495e4ffda261373f46d2d547 (diff) | |
| download | garage-6ce14e2c9eb1ba81add3f61377a5a83854880b42.tar.gz garage-6ce14e2c9eb1ba81add3f61377a5a83854880b42.zip | |
Make all requests continue in the background even after we got enough responses.
Diffstat (limited to 'src/table.rs')
| -rw-r--r-- | src/table.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/table.rs b/src/table.rs index 162f98e6..33364514 100644 --- a/src/table.rs +++ b/src/table.rs @@ -280,7 +280,7 @@ impl<F: TableSchema + 'static> Table<F> { let resps = rpc_try_call_many( self.system.clone(), who, - &rpc_msg, + rpc_msg, quorum, self.param.timeout, ) @@ -384,6 +384,7 @@ impl<F: TableSchema + 'static> Table<F> { } pub async fn delete_range(&self, begin: &Hash, end: &Hash) -> Result<(), Error> { + eprintln!("({}) Deleting range {:?} - {:?}", self.name, begin, end); // TODO Ok(()) } |