aboutsummaryrefslogtreecommitdiff
path: root/src/libstore/remote-fs-accessor.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/libstore/remote-fs-accessor.cc')
-rw-r--r--src/libstore/remote-fs-accessor.cc24
1 files changed, 16 insertions, 8 deletions
diff --git a/src/libstore/remote-fs-accessor.cc b/src/libstore/remote-fs-accessor.cc
index da4e30b22..939691204 100644
--- a/src/libstore/remote-fs-accessor.cc
+++ b/src/libstore/remote-fs-accessor.cc
@@ -11,6 +11,19 @@ RemoteFSAccessor::RemoteFSAccessor(ref<Store> store, const Path & cacheDir)
createDirs(cacheDir);
}
+Path RemoteFSAccessor::makeCacheFile(const Path & storePath)
+{
+ assert(cacheDir != "");
+ return fmt("%s/%s.nar", cacheDir, storePathToHash(storePath));
+}
+
+void RemoteFSAccessor::addToCache(const Path & storePath, const std::string & nar)
+{
+ if (cacheDir != "")
+ /* FIXME: do this asynchronously. */
+ writeFile(makeCacheFile(storePath), nar);
+}
+
std::pair<ref<FSAccessor>, Path> RemoteFSAccessor::fetch(const Path & path_)
{
auto path = canonPath(path_);
@@ -26,19 +39,14 @@ std::pair<ref<FSAccessor>, Path> RemoteFSAccessor::fetch(const Path & path_)
StringSink sink;
- Path cacheFile = cacheDir != "" ? fmt("%s/%s.nar", cacheDir, storePathToHash(storePath)) : "";
-
try {
- if (cacheFile != "")
- *sink.s = nix::readFile(cacheFile);
+ if (cacheDir != "")
+ *sink.s = nix::readFile(makeCacheFile(storePath));
} catch (SysError &) { }
if (sink.s->empty()) {
store->narFromPath(storePath, sink);
-
- if (cacheFile != "")
- /* FIXME: do this asynchronously. */
- writeFile(cacheFile, *sink.s);
+ addToCache(storePath, *sink.s);
}
auto accessor = makeNarAccessor(sink.s);