diff options
| author | Alex Auvolat <alex@adnab.me> | 2020-04-16 14:50:49 +0200 |
|---|---|---|
| committer | Alex Auvolat <alex@adnab.me> | 2020-04-16 14:50:49 +0200 |
| commit | f01c1e71b5421d8941d1484e224cd6fd75525651 (patch) | |
| tree | ce076bbd0a5c63506bece06184942712b79f2ee5 /src/rpc_server.rs | |
| parent | 43ce5e4ab4ebe317bb9263de5d56b90dc68ea7eb (diff) | |
| download | garage-f01c1e71b5421d8941d1484e224cd6fd75525651.tar.gz garage-f01c1e71b5421d8941d1484e224cd6fd75525651.zip | |
Begin work on sync...
Diffstat (limited to 'src/rpc_server.rs')
| -rw-r--r-- | src/rpc_server.rs | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/rpc_server.rs b/src/rpc_server.rs index b75d67fd..16ea0ca8 100644 --- a/src/rpc_server.rs +++ b/src/rpc_server.rs @@ -76,9 +76,7 @@ async fn handler( // and the request handler simply sits there waiting for the task to finish. // (if it's cancelled, that's not an issue) // (TODO FIXME except if garage happens to shut down at that point) - let write_fut = async move { - garage.block_manager.write_block(&m.hash, &m.data).await - }; + let write_fut = async move { garage.block_manager.write_block(&m.hash, &m.data).await }; tokio::spawn(write_fut).await? } Message::GetBlock(h) => garage.block_manager.read_block(&h).await, |