Eliminate the "store" global variable
Also, move a few free-standing functions into StoreAPI and Derivation.
Also, introduce a non-nullable smart pointer, ref<T>, which is just a
wrapper around std::shared_ptr ensuring that the pointer is never
null. (For reference-counted values, this is better than passing a
"T&", because the latter doesn't maintain the refcount. Usually, the
caller will have a shared_ptr keeping the value alive, but that's not
always the case, e.g., when passing a reference to a std::thread via
std::bind.)
2016-02-04 13:28:26 +00:00
|
|
|
#include "derivations.hh"
|
2019-09-03 14:02:12 +00:00
|
|
|
#include "parsed-derivations.hh"
|
2012-04-30 23:15:34 +00:00
|
|
|
#include "globals.hh"
|
Eliminate the "store" global variable
Also, move a few free-standing functions into StoreAPI and Derivation.
Also, introduce a non-nullable smart pointer, ref<T>, which is just a
wrapper around std::shared_ptr ensuring that the pointer is never
null. (For reference-counted values, this is better than passing a
"T&", because the latter doesn't maintain the refcount. Usually, the
caller will have a shared_ptr keeping the value alive, but that's not
always the case, e.g., when passing a reference to a std::thread via
std::bind.)
2016-02-04 13:28:26 +00:00
|
|
|
#include "local-store.hh"
|
|
|
|
#include "store-api.hh"
|
2016-07-21 12:13:35 +00:00
|
|
|
#include "thread-pool.hh"
|
2020-07-27 20:45:34 +00:00
|
|
|
#include "topo-sort.hh"
|
2006-09-04 21:06:23 +00:00
|
|
|
|
|
|
|
|
|
|
|
namespace nix {
|
2004-06-18 18:09:32 +00:00
|
|
|
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void Store::computeFSClosure(const StorePathSet & startPaths,
|
|
|
|
StorePathSet & paths_, bool flipDirection, bool includeOutputs, bool includeDerivers)
|
2005-01-19 11:16:11 +00:00
|
|
|
{
|
2016-09-16 16:54:14 +00:00
|
|
|
struct State
|
|
|
|
{
|
|
|
|
size_t pending;
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet & paths;
|
2016-09-16 16:54:14 +00:00
|
|
|
std::exception_ptr exc;
|
|
|
|
};
|
|
|
|
|
|
|
|
Sync<State> state_(State{0, paths_, 0});
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
std::function<void(const Path &)> enqueue;
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
std::condition_variable done;
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
enqueue = [&](const Path & path) -> void {
|
2016-07-21 12:13:35 +00:00
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
2016-09-16 16:54:14 +00:00
|
|
|
if (state->exc) return;
|
2019-12-05 18:11:09 +00:00
|
|
|
if (!state->paths.insert(parseStorePath(path)).second) return;
|
2016-09-16 16:54:14 +00:00
|
|
|
state->pending++;
|
2012-12-20 17:41:44 +00:00
|
|
|
}
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
queryPathInfo(parseStorePath(path), {[&, pathS(path)](std::future<ref<const ValidPathInfo>> fut) {
|
2018-03-27 20:16:01 +00:00
|
|
|
// FIXME: calls to isValidPath() should be async
|
|
|
|
|
|
|
|
try {
|
|
|
|
auto info = fut.get();
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
auto path = parseStorePath(pathS);
|
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
if (flipDirection) {
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet referrers;
|
2016-09-16 16:54:14 +00:00
|
|
|
queryReferrers(path, referrers);
|
|
|
|
for (auto & ref : referrers)
|
|
|
|
if (ref != path)
|
2019-12-05 18:11:09 +00:00
|
|
|
enqueue(printStorePath(ref));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
if (includeOutputs)
|
|
|
|
for (auto & i : queryValidDerivers(path))
|
2019-12-05 18:11:09 +00:00
|
|
|
enqueue(printStorePath(i));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
if (includeDerivers && path.isDerivation())
|
2016-09-16 16:54:14 +00:00
|
|
|
for (auto & i : queryDerivationOutputs(path))
|
|
|
|
if (isValidPath(i) && queryPathInfo(i)->deriver == path)
|
2019-12-05 18:11:09 +00:00
|
|
|
enqueue(printStorePath(i));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
} else {
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
for (auto & ref : info->references)
|
|
|
|
if (ref != path)
|
2019-12-05 18:11:09 +00:00
|
|
|
enqueue(printStorePath(ref));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
if (includeOutputs && path.isDerivation())
|
2016-09-16 16:54:14 +00:00
|
|
|
for (auto & i : queryDerivationOutputs(path))
|
2019-12-05 18:11:09 +00:00
|
|
|
if (isValidPath(i)) enqueue(printStorePath(i));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
if (includeDerivers && info->deriver && isValidPath(*info->deriver))
|
|
|
|
enqueue(printStorePath(*info->deriver));
|
2016-07-21 12:13:35 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
|
|
|
assert(state->pending);
|
|
|
|
if (!--state->pending) done.notify_one();
|
|
|
|
}
|
|
|
|
|
2018-03-27 20:16:01 +00:00
|
|
|
} catch (...) {
|
2016-09-16 16:54:14 +00:00
|
|
|
auto state(state_.lock());
|
2018-03-27 20:16:01 +00:00
|
|
|
if (!state->exc) state->exc = std::current_exception();
|
2016-09-16 16:54:14 +00:00
|
|
|
assert(state->pending);
|
|
|
|
if (!--state->pending) done.notify_one();
|
2018-03-27 20:16:01 +00:00
|
|
|
};
|
|
|
|
}});
|
2016-07-21 12:13:35 +00:00
|
|
|
};
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2016-11-10 16:45:04 +00:00
|
|
|
for (auto & startPath : startPaths)
|
2019-12-05 18:11:09 +00:00
|
|
|
enqueue(printStorePath(startPath));
|
2010-01-25 17:18:44 +00:00
|
|
|
|
2016-09-16 16:54:14 +00:00
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
|
|
|
while (state->pending) state.wait(done);
|
|
|
|
if (state->exc) std::rethrow_exception(state->exc);
|
|
|
|
}
|
2005-02-14 17:35:10 +00:00
|
|
|
}
|
2006-03-06 11:21:15 +00:00
|
|
|
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void Store::computeFSClosure(const StorePath & startPath,
|
|
|
|
StorePathSet & paths_, bool flipDirection, bool includeOutputs, bool includeDerivers)
|
2016-11-10 16:45:04 +00:00
|
|
|
{
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet paths;
|
2020-06-16 20:20:18 +00:00
|
|
|
paths.insert(startPath);
|
2019-12-05 18:11:09 +00:00
|
|
|
computeFSClosure(paths, paths_, flipDirection, includeOutputs, includeDerivers);
|
2016-11-10 16:45:04 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2020-06-22 17:08:11 +00:00
|
|
|
std::optional<ContentAddress> getDerivationCA(const BasicDerivation & drv)
|
2020-06-12 14:49:09 +00:00
|
|
|
{
|
2020-06-22 17:08:11 +00:00
|
|
|
auto out = drv.outputs.find("out");
|
2020-07-30 17:38:24 +00:00
|
|
|
if (out != drv.outputs.end()) {
|
2020-08-05 14:44:39 +00:00
|
|
|
if (auto v = std::get_if<DerivationOutputCAFixed>(&out->second.output))
|
2020-07-30 17:38:24 +00:00
|
|
|
return v->hash;
|
|
|
|
}
|
2020-06-12 14:49:09 +00:00
|
|
|
return std::nullopt;
|
|
|
|
}
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void Store::queryMissing(const std::vector<StorePathWithOutputs> & targets,
|
|
|
|
StorePathSet & willBuild_, StorePathSet & willSubstitute_, StorePathSet & unknown_,
|
2020-07-30 11:10:49 +00:00
|
|
|
uint64_t & downloadSize_, uint64_t & narSize_)
|
2006-03-06 11:21:15 +00:00
|
|
|
{
|
2017-08-31 14:02:36 +00:00
|
|
|
Activity act(*logger, lvlDebug, actUnknown, "querying info about missing paths");
|
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
downloadSize_ = narSize_ = 0;
|
2006-03-06 11:21:15 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
ThreadPool pool;
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
struct State
|
|
|
|
{
|
2019-12-05 18:11:09 +00:00
|
|
|
std::unordered_set<std::string> done;
|
|
|
|
StorePathSet & unknown, & willSubstitute, & willBuild;
|
2020-07-30 11:10:49 +00:00
|
|
|
uint64_t & downloadSize;
|
|
|
|
uint64_t & narSize;
|
2016-07-21 15:40:40 +00:00
|
|
|
};
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
struct DrvState
|
|
|
|
{
|
|
|
|
size_t left;
|
|
|
|
bool done = false;
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet outPaths;
|
2016-07-21 15:40:40 +00:00
|
|
|
DrvState(size_t left) : left(left) { }
|
|
|
|
};
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
Sync<State> state_(State{{}, unknown_, willSubstitute_, willBuild_, downloadSize_, narSize_});
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
std::function<void(StorePathWithOutputs)> doPath;
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
auto mustBuildDrv = [&](const StorePath & drvPath, const Derivation & drv) {
|
2016-07-21 15:40:40 +00:00
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
2020-06-16 20:20:18 +00:00
|
|
|
state->willBuild.insert(drvPath);
|
2016-07-21 15:40:40 +00:00
|
|
|
}
|
2012-07-30 23:55:41 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
for (auto & i : drv.inputDrvs)
|
2020-06-16 20:20:18 +00:00
|
|
|
pool.enqueue(std::bind(doPath, StorePathWithOutputs { i.first, i.second }));
|
2016-07-21 15:40:40 +00:00
|
|
|
};
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
auto checkOutput = [&](
|
2019-12-05 18:11:09 +00:00
|
|
|
const Path & drvPathS, ref<Derivation> drv, const Path & outPathS, ref<Sync<DrvState>> drvState_)
|
2016-07-21 15:40:40 +00:00
|
|
|
{
|
|
|
|
if (drvState_->lock()->done) return;
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
auto drvPath = parseStorePath(drvPathS);
|
|
|
|
auto outPath = parseStorePath(outPathS);
|
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
SubstitutablePathInfos infos;
|
2020-06-17 19:03:05 +00:00
|
|
|
querySubstitutablePathInfos({{outPath, getDerivationCA(*drv)}}, infos);
|
2012-11-26 14:39:10 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
if (infos.empty()) {
|
|
|
|
drvState_->lock()->done = true;
|
|
|
|
mustBuildDrv(drvPath, *drv);
|
|
|
|
} else {
|
|
|
|
{
|
|
|
|
auto drvState(drvState_->lock());
|
|
|
|
if (drvState->done) return;
|
|
|
|
assert(drvState->left);
|
|
|
|
drvState->left--;
|
2020-06-16 20:20:18 +00:00
|
|
|
drvState->outPaths.insert(outPath);
|
2016-07-21 15:40:40 +00:00
|
|
|
if (!drvState->left) {
|
|
|
|
for (auto & path : drvState->outPaths)
|
2020-06-16 20:20:18 +00:00
|
|
|
pool.enqueue(std::bind(doPath, StorePathWithOutputs { path } ));
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
}
|
2008-08-04 11:44:50 +00:00
|
|
|
}
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
}
|
2016-07-21 15:40:40 +00:00
|
|
|
};
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
doPath = [&](const StorePathWithOutputs & path) {
|
2012-07-30 23:55:41 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
2019-12-05 18:11:09 +00:00
|
|
|
if (!state->done.insert(path.to_string(*this)).second) return;
|
2016-07-21 15:40:40 +00:00
|
|
|
}
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
if (path.path.isDerivation()) {
|
|
|
|
if (!isValidPath(path.path)) {
|
2016-07-21 15:40:40 +00:00
|
|
|
// FIXME: we could try to substitute the derivation.
|
|
|
|
auto state(state_.lock());
|
2020-06-16 20:20:18 +00:00
|
|
|
state->unknown.insert(path.path);
|
2016-07-21 15:40:40 +00:00
|
|
|
return;
|
|
|
|
}
|
2012-11-26 16:15:09 +00:00
|
|
|
|
2020-08-07 19:09:26 +00:00
|
|
|
PathSet invalid;
|
|
|
|
/* true for regular derivations, and CA derivations for which we
|
|
|
|
have a trust mapping for all wanted outputs. */
|
|
|
|
auto knownOutputPaths = true;
|
|
|
|
for (auto & [outputName, pathOpt] : queryDerivationOutputMap(path.path)) {
|
|
|
|
if (!pathOpt) {
|
|
|
|
knownOutputPaths = false;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
if (wantOutput(outputName, path.outputs) && !isValidPath(*pathOpt))
|
|
|
|
invalid.insert(printStorePath(*pathOpt));
|
|
|
|
}
|
|
|
|
if (knownOutputPaths && invalid.empty()) return;
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
auto drv = make_ref<Derivation>(derivationFromPath(path.path));
|
2020-06-16 20:20:18 +00:00
|
|
|
ParsedDerivation parsedDrv(StorePath(path.path), *drv);
|
2006-03-06 11:21:15 +00:00
|
|
|
|
2020-08-07 19:09:26 +00:00
|
|
|
if (knownOutputPaths && settings.useSubstitutes && parsedDrv.substitutesAllowed()) {
|
2016-07-21 15:40:40 +00:00
|
|
|
auto drvState = make_ref<Sync<DrvState>>(DrvState(invalid.size()));
|
|
|
|
for (auto & output : invalid)
|
2019-12-05 18:11:09 +00:00
|
|
|
pool.enqueue(std::bind(checkOutput, printStorePath(path.path), drv, output, drvState));
|
download-from-binary-cache: parallelise fetching of NAR info files
Getting substitute information using the binary cache substituter has
non-trivial latency overhead. A package or NixOS system configuration
can have hundreds of dependencies, and in the worst case (when the
local info cache is empty) we have to do a separate HTTP request for
each of these. If the ping time to the server is t, getting N info
files will take tN seconds; e.g., with a ping time of 0.1s to
nixos.org, sequentially downloading 1000 info files (a typical NixOS
config) will take at least 100 seconds.
To fix this problem, the binary cache substituter can now perform
requests in parallel. This required changing the substituter
interface to support a function querySubstitutablePathInfos() that
queries multiple paths at the same time, and rewriting queryMissing()
to take advantage of parallelism. (Due to local caching,
parallelising queryMissing() is sufficient for most use cases, since
it's almost always called before building a derivation and thus fills
the local info cache.)
For example, parallelism speeds up querying all 1056 paths in a
particular NixOS system configuration from 116s to 2.6s. It works so
well because the eccentricity of the top-level derivation in the
dependency graph is only 9. So we only need 10 round-trips (when
using an unlimited number of parallel connections) to get everything.
Currently we do a maximum of 150 parallel connections to the server.
Thus it's important that the binary cache server (e.g. nixos.org) has
a high connection limit. Alternatively we could use HTTP pipelining,
but WWW::Curl doesn't support it and libcurl has a hard-coded limit of
5 requests per pipeline.
2012-07-06 23:08:20 +00:00
|
|
|
} else
|
2019-12-05 18:11:09 +00:00
|
|
|
mustBuildDrv(path.path, *drv);
|
2006-03-06 11:21:15 +00:00
|
|
|
|
2016-07-21 15:40:40 +00:00
|
|
|
} else {
|
2012-07-30 23:55:41 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
if (isValidPath(path.path)) return;
|
2016-07-21 15:40:40 +00:00
|
|
|
|
|
|
|
SubstitutablePathInfos infos;
|
2020-06-17 19:03:05 +00:00
|
|
|
querySubstitutablePathInfos({{path.path, std::nullopt}}, infos);
|
2016-07-21 15:40:40 +00:00
|
|
|
|
|
|
|
if (infos.empty()) {
|
|
|
|
auto state(state_.lock());
|
2020-06-16 20:20:18 +00:00
|
|
|
state->unknown.insert(path.path);
|
2016-07-21 15:40:40 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
auto info = infos.find(path.path);
|
2016-07-21 15:40:40 +00:00
|
|
|
assert(info != infos.end());
|
|
|
|
|
|
|
|
{
|
|
|
|
auto state(state_.lock());
|
2020-06-16 20:20:18 +00:00
|
|
|
state->willSubstitute.insert(path.path);
|
2016-07-21 15:40:40 +00:00
|
|
|
state->downloadSize += info->second.downloadSize;
|
|
|
|
state->narSize += info->second.narSize;
|
|
|
|
}
|
|
|
|
|
|
|
|
for (auto & ref : info->second.references)
|
2020-06-16 20:20:18 +00:00
|
|
|
pool.enqueue(std::bind(doPath, StorePathWithOutputs { ref }));
|
2006-03-06 11:21:15 +00:00
|
|
|
}
|
2016-07-21 15:40:40 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
for (auto & path : targets)
|
|
|
|
pool.enqueue(std::bind(doPath, path));
|
|
|
|
|
|
|
|
pool.process();
|
2006-03-06 11:21:15 +00:00
|
|
|
}
|
2006-09-04 21:06:23 +00:00
|
|
|
|
2012-07-30 23:55:41 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePaths Store::topoSortPaths(const StorePathSet & paths)
|
2011-12-30 15:02:50 +00:00
|
|
|
{
|
2020-07-27 20:45:34 +00:00
|
|
|
return topoSort(paths,
|
|
|
|
{[&](const StorePath & path) {
|
|
|
|
StorePathSet references;
|
|
|
|
try {
|
|
|
|
references = queryPathInfo(path)->references;
|
|
|
|
} catch (InvalidPath &) {
|
|
|
|
}
|
|
|
|
return references;
|
|
|
|
}},
|
|
|
|
{[&](const StorePath & path, const StorePath & parent) {
|
|
|
|
return BuildError(
|
|
|
|
"cycle detected in the references of '%s' from '%s'",
|
|
|
|
printStorePath(path),
|
|
|
|
printStorePath(parent));
|
|
|
|
}});
|
2011-12-30 15:02:50 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
2006-09-04 21:06:23 +00:00
|
|
|
}
|