2012-07-18 18:59:03 +00:00
|
|
|
#pragma once
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2016-02-23 15:40:16 +00:00
|
|
|
#include <limits>
|
2006-11-30 18:35:50 +00:00
|
|
|
#include <string>
|
|
|
|
|
|
|
|
#include "store-api.hh"
|
|
|
|
|
|
|
|
|
|
|
|
namespace nix {
|
|
|
|
|
|
|
|
|
2006-11-30 19:54:43 +00:00
|
|
|
class Pipe;
|
|
|
|
class Pid;
|
|
|
|
struct FdSink;
|
|
|
|
struct FdSource;
|
2016-02-23 14:00:59 +00:00
|
|
|
template<typename T> class Pool;
|
2018-10-16 21:36:15 +00:00
|
|
|
struct ConnectionHandle;
|
2006-11-30 19:54:43 +00:00
|
|
|
|
2020-09-10 08:55:51 +00:00
|
|
|
struct RemoteStoreConfig : virtual StoreConfig
|
2006-11-30 18:35:50 +00:00
|
|
|
{
|
2020-09-10 08:55:51 +00:00
|
|
|
using StoreConfig::StoreConfig;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2020-09-10 08:55:51 +00:00
|
|
|
const Setting<int> maxConnections{(StoreConfig*) this, 1,
|
2017-04-13 13:55:38 +00:00
|
|
|
"max-connections", "maximum number of concurrent connections to the Nix daemon"};
|
|
|
|
|
2020-09-10 08:55:51 +00:00
|
|
|
const Setting<unsigned int> maxConnectionAge{(StoreConfig*) this, std::numeric_limits<unsigned int>::max(),
|
2017-09-14 16:10:38 +00:00
|
|
|
"max-connection-age", "number of seconds to reuse a connection"};
|
2020-09-10 08:55:51 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
/* FIXME: RemoteStore is a misnomer - should be something like
|
|
|
|
DaemonStore. */
|
|
|
|
class RemoteStore : public virtual Store, public virtual RemoteStoreConfig
|
|
|
|
{
|
|
|
|
public:
|
2017-09-14 16:10:38 +00:00
|
|
|
|
2019-10-11 16:48:59 +00:00
|
|
|
virtual bool sameMachine() = 0;
|
|
|
|
|
2017-03-03 18:05:50 +00:00
|
|
|
RemoteStore(const Params & params);
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2006-11-30 18:35:50 +00:00
|
|
|
/* Implementations of abstract store API methods. */
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
bool isValidPathUncached(const StorePath & path) override;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet queryValidPaths(const StorePathSet & paths,
|
2017-06-28 16:11:01 +00:00
|
|
|
SubstituteFlag maybeSubstitute = NoSubstitute) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet queryAllValidPaths() override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void queryPathInfoUncached(const StorePath & path,
|
2018-09-25 16:54:16 +00:00
|
|
|
Callback<std::shared_ptr<const ValidPathInfo>> callback) noexcept override;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void queryReferrers(const StorePath & path, StorePathSet & referrers) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet queryValidDerivers(const StorePath & path) override;
|
2012-12-20 17:41:44 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet queryDerivationOutputs(const StorePath & path) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2020-08-20 14:12:51 +00:00
|
|
|
std::map<std::string, std::optional<StorePath>> queryPartialDerivationOutputMap(const StorePath & path) override;
|
2019-12-05 18:11:09 +00:00
|
|
|
std::optional<StorePath> queryPathFromHashPart(const std::string & hashPart) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePathSet querySubstitutablePaths(const StorePathSet & paths) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2020-06-17 19:03:05 +00:00
|
|
|
void querySubstitutablePathInfos(const StorePathCAMap & paths,
|
|
|
|
SubstitutablePathInfos & infos) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2020-09-17 18:19:15 +00:00
|
|
|
StorePath addCAToStore(Source & dump, const string & name, ContentAddressMethod caMethod, StorePathSet references);
|
|
|
|
|
2020-09-17 17:27:11 +00:00
|
|
|
StorePath addToStoreFromDump(Source & dump, const string & name,
|
|
|
|
FileIngestionMethod method = FileIngestionMethod::Recursive, HashType hashAlgo = htSHA256, RepairFlag repair = NoRepair) override;
|
|
|
|
|
2018-03-21 22:42:21 +00:00
|
|
|
void addToStore(const ValidPathInfo & info, Source & nar,
|
2020-07-13 15:37:44 +00:00
|
|
|
RepairFlag repair, CheckSigsFlag checkSigs) override;
|
2016-05-04 11:36:54 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
StorePath addTextToStore(const string & name, const string & s,
|
|
|
|
const StorePathSet & references, RepairFlag repair) override;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void buildPaths(const std::vector<StorePathWithOutputs> & paths, BuildMode buildMode) override;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
BuildResult buildDerivation(const StorePath & drvPath, const BasicDerivation & drv,
|
Allow remote builds without sending the derivation closure
Previously, to build a derivation remotely, we had to copy the entire
closure of the .drv file to the remote machine, even though we only
need the top-level derivation. This is very wasteful: the closure can
contain thousands of store paths, and in some Hydra use cases, include
source paths that are very large (e.g. Git/Mercurial checkouts).
So now there is a new operation, StoreAPI::buildDerivation(), that
performs a build from an in-memory representation of a derivation
(BasicDerivation) rather than from a on-disk .drv file. The only files
that need to be in the Nix store are the sources of the derivation
(drv.inputSrcs), and the needed output paths of the dependencies (as
described by drv.inputDrvs). "nix-store --serve" exposes this
interface.
Note that this is a privileged operation, because you can construct a
derivation that builds any store path whatsoever. Fixing this will
require changing the hashing scheme (i.e., the output paths should be
computed from the other fields in BasicDerivation, allowing them to be
verified without access to other derivations). However, this would be
quite nice because it would allow .drv-free building (e.g. "nix-env
-i" wouldn't have to write any .drv files to disk).
Fixes #173.
2015-07-17 15:57:40 +00:00
|
|
|
BuildMode buildMode) override;
|
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void ensurePath(const StorePath & path) override;
|
2006-11-30 18:35:50 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void addTempRoot(const StorePath & path) override;
|
2006-12-02 16:41:36 +00:00
|
|
|
|
2015-09-17 23:22:06 +00:00
|
|
|
void addIndirectRoot(const Path & path) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2015-09-17 23:22:06 +00:00
|
|
|
void syncWithGC() override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2019-03-14 12:50:07 +00:00
|
|
|
Roots findRoots(bool censor) override;
|
2006-12-05 02:18:46 +00:00
|
|
|
|
2015-09-17 23:22:06 +00:00
|
|
|
void collectGarbage(const GCOptions & options, GCResults & results) override;
|
2015-03-25 16:06:12 +00:00
|
|
|
|
2015-09-17 23:22:06 +00:00
|
|
|
void optimiseStore() override;
|
|
|
|
|
2017-06-28 16:11:01 +00:00
|
|
|
bool verifyStore(bool checkContents, RepairFlag repair) override;
|
2014-09-01 20:21:42 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void addSignatures(const StorePath & storePath, const StringSet & sigs) override;
|
2016-04-05 13:30:22 +00:00
|
|
|
|
2019-12-05 18:11:09 +00:00
|
|
|
void 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) override;
|
2017-04-06 16:40:19 +00:00
|
|
|
|
2017-05-02 12:18:46 +00:00
|
|
|
void connect() override;
|
|
|
|
|
2018-08-30 21:28:47 +00:00
|
|
|
unsigned int getProtocol() override;
|
|
|
|
|
2017-09-14 16:10:38 +00:00
|
|
|
void flushBadConnections();
|
|
|
|
|
2016-02-23 14:00:59 +00:00
|
|
|
struct Connection
|
|
|
|
{
|
2018-10-16 20:58:01 +00:00
|
|
|
AutoCloseFD fd;
|
2016-02-23 14:00:59 +00:00
|
|
|
FdSink to;
|
|
|
|
FdSource from;
|
|
|
|
unsigned int daemonVersion;
|
2017-09-14 16:10:38 +00:00
|
|
|
std::chrono::time_point<std::chrono::steady_clock> startTime;
|
2006-12-03 02:08:13 +00:00
|
|
|
|
2016-09-02 18:31:38 +00:00
|
|
|
virtual ~Connection();
|
2016-02-23 15:40:16 +00:00
|
|
|
|
2020-08-27 12:48:08 +00:00
|
|
|
std::exception_ptr processStderr(Sink * sink = 0, Source * source = 0, bool flush = true);
|
2016-02-23 14:00:59 +00:00
|
|
|
};
|
2006-12-04 13:28:14 +00:00
|
|
|
|
2017-03-03 18:35:34 +00:00
|
|
|
ref<Connection> openConnectionWrapper();
|
|
|
|
|
2020-08-19 19:34:47 +00:00
|
|
|
protected:
|
|
|
|
|
2016-09-02 18:15:04 +00:00
|
|
|
virtual ref<Connection> openConnection() = 0;
|
|
|
|
|
|
|
|
void initConnection(Connection & conn);
|
|
|
|
|
2016-02-23 14:00:59 +00:00
|
|
|
ref<Pool<Connection>> connections;
|
2007-09-18 09:11:20 +00:00
|
|
|
|
2018-03-05 12:42:15 +00:00
|
|
|
virtual void setOptions(Connection & conn);
|
|
|
|
|
2018-10-16 21:36:15 +00:00
|
|
|
ConnectionHandle getConnection();
|
|
|
|
|
2018-10-26 17:34:29 +00:00
|
|
|
friend struct ConnectionHandle;
|
2018-10-16 21:36:15 +00:00
|
|
|
|
2020-09-07 09:26:09 +00:00
|
|
|
virtual ref<FSAccessor> getFSAccessor() override;
|
|
|
|
|
|
|
|
virtual void narFromPath(const StorePath & path, Sink & sink) override;
|
|
|
|
|
2016-09-02 18:15:04 +00:00
|
|
|
private:
|
|
|
|
|
2017-03-03 18:35:34 +00:00
|
|
|
std::atomic_bool failed{false};
|
|
|
|
|
2016-09-02 18:15:04 +00:00
|
|
|
};
|
2007-09-18 09:11:20 +00:00
|
|
|
|
2020-09-10 08:55:51 +00:00
|
|
|
struct UDSRemoteStoreConfig : virtual LocalFSStoreConfig, virtual RemoteStoreConfig
|
|
|
|
{
|
|
|
|
UDSRemoteStoreConfig(const Store::Params & params)
|
2020-09-11 09:06:18 +00:00
|
|
|
: StoreConfig(params)
|
|
|
|
, LocalFSStoreConfig(params)
|
2020-09-10 08:55:51 +00:00
|
|
|
, RemoteStoreConfig(params)
|
|
|
|
{
|
|
|
|
}
|
|
|
|
|
|
|
|
UDSRemoteStoreConfig()
|
|
|
|
: UDSRemoteStoreConfig(Store::Params({}))
|
|
|
|
{
|
|
|
|
}
|
2020-09-14 12:04:02 +00:00
|
|
|
|
|
|
|
const std::string name() override { return "Local Daemon Store"; }
|
2020-09-10 08:55:51 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
class UDSRemoteStore : public LocalFSStore, public RemoteStore, public virtual UDSRemoteStoreConfig
|
2016-09-02 18:15:04 +00:00
|
|
|
{
|
|
|
|
public:
|
|
|
|
|
2017-03-03 18:05:50 +00:00
|
|
|
UDSRemoteStore(const Params & params);
|
2020-09-11 09:11:05 +00:00
|
|
|
UDSRemoteStore(const std::string scheme, std::string path, const Params & params);
|
2016-09-02 18:15:04 +00:00
|
|
|
|
|
|
|
std::string getUri() override;
|
|
|
|
|
2020-09-11 09:11:05 +00:00
|
|
|
static std::set<std::string> uriSchemes()
|
2020-09-08 12:50:23 +00:00
|
|
|
{ return {"unix"}; }
|
|
|
|
|
2019-11-26 20:07:44 +00:00
|
|
|
bool sameMachine() override
|
2019-10-11 16:48:59 +00:00
|
|
|
{ return true; }
|
|
|
|
|
2020-09-07 09:26:09 +00:00
|
|
|
ref<FSAccessor> getFSAccessor() override
|
|
|
|
{ return LocalFSStore::getFSAccessor(); }
|
|
|
|
|
|
|
|
void narFromPath(const StorePath & path, Sink & sink) override
|
|
|
|
{ LocalFSStore::narFromPath(path, sink); }
|
|
|
|
|
2016-09-02 18:15:04 +00:00
|
|
|
private:
|
|
|
|
|
|
|
|
ref<RemoteStore::Connection> openConnection() override;
|
2019-02-12 12:43:32 +00:00
|
|
|
std::optional<std::string> path;
|
2006-11-30 18:35:50 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
}
|