aboutsummaryrefslogtreecommitdiff
path: root/src/libstore/http-binary-cache-store.cc
diff options
context:
space:
mode:
authorEelco Dolstra <edolstra@gmail.com>2018-03-27 22:16:01 +0200
committerEelco Dolstra <edolstra@gmail.com>2018-05-30 13:34:37 +0200
commit81ea8bd5ceb3dcae6af0b79c81a39ecbf2ba97a8 (patch)
tree2e96cec431e4ec67d8cfb50328a9da1b0c931145 /src/libstore/http-binary-cache-store.cc
parent1672bcd230447f1ce0c3291950bdd9a662cee974 (diff)
Simplify the callback mechanism
Diffstat (limited to 'src/libstore/http-binary-cache-store.cc')
-rw-r--r--src/libstore/http-binary-cache-store.cc18
1 files changed, 7 insertions, 11 deletions
diff --git a/src/libstore/http-binary-cache-store.cc b/src/libstore/http-binary-cache-store.cc
index b9e9cd5da..b8d670417 100644
--- a/src/libstore/http-binary-cache-store.cc
+++ b/src/libstore/http-binary-cache-store.cc
@@ -78,27 +78,23 @@ protected:
}
void getFile(const std::string & path,
- std::function<void(std::shared_ptr<std::string>)> success,
- std::function<void(std::exception_ptr exc)> failure) override
+ Callback<std::shared_ptr<std::string>> callback) override
{
DownloadRequest request(cacheUri + "/" + path);
request.tries = 8;
getDownloader()->enqueueDownload(request,
- [success](const DownloadResult & result) {
- success(result.data);
- },
- [success, failure](std::exception_ptr exc) {
+ {[callback](std::future<DownloadResult> result) {
try {
- std::rethrow_exception(exc);
+ callback(result.get().data);
} catch (DownloadError & e) {
if (e.error == Downloader::NotFound || e.error == Downloader::Forbidden)
- return success(0);
- failure(exc);
+ return callback(std::shared_ptr<std::string>());
+ callback.rethrow();
} catch (...) {
- failure(exc);
+ callback.rethrow();
}
- });
+ }});
}
};