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/api_server.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/api_server.rs')
| -rw-r--r-- | src/api_server.rs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/api_server.rs b/src/api_server.rs index 441fbe1c..f3f7165b 100644 --- a/src/api_server.rs +++ b/src/api_server.rs @@ -219,7 +219,7 @@ async fn put_block(garage: Arc<Garage>, hash: Hash, data: Vec<u8>) -> Result<(), rpc_try_call_many( garage.system.clone(), &who[..], - &Message::PutBlock(PutBlockMessage { hash, data }), + Message::PutBlock(PutBlockMessage { hash, data }), (garage.system.config.data_replication_factor + 1) / 2, BLOCK_RW_TIMEOUT, ) @@ -366,7 +366,7 @@ async fn get_block(garage: Arc<Garage>, hash: &Hash) -> Result<Vec<u8>, Error> { let resps = rpc_try_call_many( garage.system.clone(), &who[..], - &Message::GetBlock(hash.clone()), + Message::GetBlock(hash.clone()), 1, BLOCK_RW_TIMEOUT, ) |