nix-super/src/libstore/remote-store.hh

155 lines
4.1 KiB
C++
Raw Normal View History

#pragma once
2006-11-30 20:35:50 +02:00
2016-02-23 17:40:16 +02:00
#include <limits>
2006-11-30 20:35:50 +02:00
#include <string>
#include "store-api.hh"
namespace nix {
class Pipe;
class Pid;
struct FdSink;
struct FdSource;
template<typename T> class Pool;
/* FIXME: RemoteStore is a misnomer - should be something like
DaemonStore. */
class RemoteStore : public virtual Store
2006-11-30 20:35:50 +02:00
{
public:
const Setting<int> maxConnections{(Store*) this, 1,
"max-connections", "maximum number of concurrent connections to the Nix daemon"};
const Setting<unsigned int> maxConnectionAge{(Store*) this, std::numeric_limits<unsigned int>::max(),
"max-connection-age", "number of seconds to reuse a connection"};
RemoteStore(const Params & params);
2006-11-30 20:35:50 +02:00
/* Implementations of abstract store API methods. */
bool isValidPathUncached(const Path & path) override;
2006-11-30 20:35:50 +02:00
PathSet queryValidPaths(const PathSet & paths,
SubstituteFlag maybeSubstitute = NoSubstitute) override;
2015-09-18 02:22:06 +03:00
PathSet queryAllValidPaths() override;
void queryPathInfoUncached(const Path & path,
std::function<void(std::shared_ptr<ValidPathInfo>)> success,
std::function<void(std::exception_ptr exc)> failure) override;
2006-11-30 20:35:50 +02:00
2015-09-18 02:22:06 +03:00
void queryReferrers(const Path & path, PathSet & referrers) override;
2015-09-18 02:22:06 +03:00
PathSet queryValidDerivers(const Path & path) override;
2015-09-18 02:22:06 +03:00
PathSet queryDerivationOutputs(const Path & path) override;
2015-09-18 02:22:06 +03:00
StringSet queryDerivationOutputNames(const Path & path) override;
2015-09-18 02:22:06 +03:00
Path queryPathFromHashPart(const string & hashPart) override;
2015-09-18 02:22:06 +03:00
PathSet querySubstitutablePaths(const PathSet & paths) override;
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-07 02:08:20 +03:00
void querySubstitutablePathInfos(const PathSet & paths,
2015-09-18 02:22:06 +03:00
SubstitutablePathInfos & infos) override;
void addToStore(const ValidPathInfo & info, Source & nar,
RepairFlag repair, CheckSigsFlag checkSigs,
2016-10-21 19:09:30 +03:00
std::shared_ptr<FSAccessor> accessor) override;
Path addToStore(const string & name, const Path & srcPath,
bool recursive = true, HashType hashAlgo = htSHA256,
PathFilter & filter = defaultPathFilter, RepairFlag repair = NoRepair) override;
2006-11-30 20:35:50 +02:00
Path addTextToStore(const string & name, const string & s,
const PathSet & references, RepairFlag repair) override;
2006-11-30 20:35:50 +02:00
2015-09-18 02:22:06 +03:00
void buildPaths(const PathSet & paths, BuildMode buildMode) override;
2006-11-30 20:35:50 +02:00
BuildResult buildDerivation(const Path & drvPath, const BasicDerivation & drv,
BuildMode buildMode) override;
2015-09-18 02:22:06 +03:00
void ensurePath(const Path & path) override;
2006-11-30 20:35:50 +02:00
2015-09-18 02:22:06 +03:00
void addTempRoot(const Path & path) override;
2015-09-18 02:22:06 +03:00
void addIndirectRoot(const Path & path) override;
2015-09-18 02:22:06 +03:00
void syncWithGC() override;
2015-09-18 02:22:06 +03:00
Roots findRoots() override;
2015-09-18 02:22:06 +03:00
void collectGarbage(const GCOptions & options, GCResults & results) override;
2015-09-18 02:22:06 +03:00
void optimiseStore() override;
bool verifyStore(bool checkContents, RepairFlag repair) override;
void addSignatures(const Path & storePath, const StringSet & sigs) override;
void queryMissing(const PathSet & targets,
PathSet & willBuild, PathSet & willSubstitute, PathSet & unknown,
unsigned long long & downloadSize, unsigned long long & narSize) override;
void connect() override;
void flushBadConnections();
protected:
struct Connection
{
FdSink to;
FdSource from;
unsigned int daemonVersion;
std::chrono::time_point<std::chrono::steady_clock> startTime;
2016-09-02 21:31:38 +03:00
virtual ~Connection();
2016-02-23 17:40:16 +02:00
void processStderr(Sink * sink = 0, Source * source = 0);
};
2006-12-04 15:28:14 +02:00
2017-03-03 20:35:34 +02:00
ref<Connection> openConnectionWrapper();
virtual ref<Connection> openConnection() = 0;
void initConnection(Connection & conn);
ref<Pool<Connection>> connections;
virtual void setOptions(Connection & conn);
private:
2017-03-03 20:35:34 +02:00
std::atomic_bool failed{false};
};
class UDSRemoteStore : public LocalFSStore, public RemoteStore
{
public:
UDSRemoteStore(const Params & params);
UDSRemoteStore(std::string path, const Params & params);
std::string getUri() override;
private:
struct Connection : RemoteStore::Connection
{
AutoCloseFD fd;
};
ref<RemoteStore::Connection> openConnection() override;
std::experimental::optional<std::string> path;
2006-11-30 20:35:50 +02:00
};
}