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. */
|
2020-12-20 15:33:12 +00:00
|
|
|
class RemoteStore : public virtual RemoteStoreConfig, public virtual Store
|
2020-09-10 08:55:51 +00:00
|
|
|
{
|
|
|
|
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-18 09:58:45 +00:00
|
|
|
/* Add a content-addressable store path. `dump` will be drained. */
|
2020-09-22 09:40:19 +00:00
|
|
|
ref<const ValidPathInfo> addCAToStore(
|
|
|
|
Source & dump,
|
|
|
|
const string & name,
|
|
|
|
ContentAddressMethod caMethod,
|
|
|
|
const StorePathSet & references,
|
|
|
|
RepairFlag repair);
|
2020-09-17 18:19:15 +00:00
|
|
|
|
2020-09-18 09:58:45 +00:00
|
|
|
/* Add a content-addressable store path. Does not support references. `dump` will be drained. */
|
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
|
|
|
|
2021-07-26 11:31:09 +00:00
|
|
|
void addMultipleToStore(
|
|
|
|
Source & source,
|
|
|
|
RepairFlag repair,
|
|
|
|
CheckSigsFlag checkSigs) override;
|
|
|
|
|
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
|
|
|
|
2020-10-08 15:36:51 +00:00
|
|
|
void registerDrvOutput(const Realisation & info) override;
|
|
|
|
|
|
|
|
std::optional<const Realisation> queryRealisation(const DrvOutput &) override;
|
|
|
|
|
2021-07-19 13:43:08 +00:00
|
|
|
void buildPaths(const std::vector<DerivedPath> & paths, BuildMode buildMode, std::shared_ptr<Store> evalStore) 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
|
|
|
|
2021-04-05 13:48:18 +00:00
|
|
|
void queryMissing(const std::vector<DerivedPath> & targets,
|
2019-12-05 18:11:09 +00:00
|
|
|
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
|
|
|
|
{
|
|
|
|
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
|
|
|
|
2021-09-23 16:01:04 +00:00
|
|
|
virtual void closeWrite() = 0;
|
|
|
|
|
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
|
|
|
|
2006-11-30 18:35:50 +00:00
|
|
|
|
|
|
|
}
|