diff options
author | julia <midnight@trainwit.ch> | 2024-05-18 15:38:33 +1000 |
---|---|---|
committer | julia <midnight@trainwit.ch> | 2024-06-16 03:53:00 +0000 |
commit | 0fa289f559708407ab4384739c0f24258c114b44 (patch) | |
tree | 33a4268a8a6951ee7bb816a9537413a051d1d752 /src/libstore/store-api.cc | |
parent | 4734ce7831daf6e7e976029017b1cc2e7e615f30 (diff) |
Harmonise the Store::queryPathInfoUncached interface
This:
- Consistently returns `nullptr` for a non-existent
store path, instead of a mix of `nullptr` and
throwing exceptions.
- If a store returns "bad" store paths in response
to a request (e.g. incorrect hash or name), don't
cache this result. This removes some duplication
of code at the cache-access layer of queryPathInfo()
checking this, and allows us to provide more
specific errors.
Part of #270.
Change-Id: I86612c6499b1a37ab872c712c2304d6a3ff19edb
Diffstat (limited to 'src/libstore/store-api.cc')
-rw-r--r-- | src/libstore/store-api.cc | 34 |
1 files changed, 23 insertions, 11 deletions
diff --git a/src/libstore/store-api.cc b/src/libstore/store-api.cc index 952958d51..e0e842060 100644 --- a/src/libstore/store-api.cc +++ b/src/libstore/store-api.cc @@ -666,11 +666,19 @@ bool Store::isValidPathUncached(const StorePath & path) } -static bool goodStorePath(const StorePath & expected, const StorePath & actual) +static void ensureGoodStorePath(Store * store, const StorePath & expected, const StorePath & actual) { - return - expected.hashPart() == actual.hashPart() - && (expected.name() == Store::MissingName || expected.name() == actual.name()); + if (expected.hashPart() != actual.hashPart()) { + throw Error( + "the queried store path hash '%s' did not match expected '%s' while querying the store path '%s'", + expected.hashPart(), actual.hashPart(), store->printStorePath(expected) + ); + } else if (expected.name() != Store::MissingName && expected.name() != actual.name()) { + throw Error( + "the queried store path name '%s' did not match expected '%s' while querying the store path '%s'", + expected.name(), actual.name(), store->printStorePath(expected) + ); + } } @@ -683,7 +691,7 @@ ref<const ValidPathInfo> Store::queryPathInfo(const StorePath & storePath) if (res && res->isKnownNow()) { stats.narInfoReadAverted++; if (!res->didExist()) - throw InvalidPath("path '%s' is not valid", printStorePath(storePath)); + throw InvalidPath("path '%s' does not exist in the store", printStorePath(storePath)); return ref<const ValidPathInfo>(res->value); } } @@ -696,27 +704,31 @@ ref<const ValidPathInfo> Store::queryPathInfo(const StorePath & storePath) auto state_(state.lock()); state_->pathInfoCache.upsert(std::string(storePath.to_string()), res.first == NarInfoDiskCache::oInvalid ? PathInfoCacheValue{} : PathInfoCacheValue{ .value = res.second }); - if (res.first == NarInfoDiskCache::oInvalid || - !goodStorePath(storePath, res.second->path)) - throw InvalidPath("path '%s' is not valid", printStorePath(storePath)); + if (res.first == NarInfoDiskCache::oInvalid) + throw InvalidPath("path '%s' does not exist in the store", printStorePath(storePath)); } return ref<const ValidPathInfo>(res.second); } } auto info = queryPathInfoUncached(storePath); + if (info) { + // first, before we cache anything, check that the store gave us valid data. + ensureGoodStorePath(this, storePath, info->path); + } - if (diskCache) + if (diskCache) { diskCache->upsertNarInfo(getUri(), hashPart, info); + } { auto state_(state.lock()); state_->pathInfoCache.upsert(std::string(storePath.to_string()), PathInfoCacheValue { .value = info }); } - if (!info || !goodStorePath(storePath, info->path)) { + if (!info) { stats.narInfoMissing++; - throw InvalidPath("path '%s' is not valid", printStorePath(storePath)); + throw InvalidPath("path '%s' does not exist in the store", printStorePath(storePath)); } return ref<const ValidPathInfo>(info); |