2016-02-24 13:48:16 +00:00
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include "crypto.hh"
|
|
|
|
#include "store-api.hh"
|
|
|
|
|
|
|
|
#include "lru-cache.hh"
|
|
|
|
#include "sync.hh"
|
|
|
|
#include "pool.hh"
|
|
|
|
|
|
|
|
#include <atomic>
|
|
|
|
|
|
|
|
namespace nix {
|
|
|
|
|
|
|
|
struct NarInfo;
|
|
|
|
|
|
|
|
class BinaryCacheStore : public Store
|
|
|
|
{
|
|
|
|
private:
|
|
|
|
|
|
|
|
std::unique_ptr<SecretKey> secretKey;
|
|
|
|
std::unique_ptr<PublicKeys> publicKeys;
|
|
|
|
|
|
|
|
std::shared_ptr<Store> localStore;
|
|
|
|
|
|
|
|
struct State
|
|
|
|
{
|
|
|
|
LRUCache<Path, ref<NarInfo>> narInfoCache{32 * 1024};
|
|
|
|
};
|
|
|
|
|
|
|
|
Sync<State> state;
|
|
|
|
|
|
|
|
protected:
|
|
|
|
|
2016-03-04 16:08:30 +00:00
|
|
|
BinaryCacheStore(std::shared_ptr<Store> localStore, const Path & secretKeyFile);
|
2016-02-24 13:48:16 +00:00
|
|
|
|
2016-02-24 13:57:30 +00:00
|
|
|
[[noreturn]] void notImpl();
|
|
|
|
|
2016-02-24 13:48:16 +00:00
|
|
|
virtual bool fileExists(const std::string & path) = 0;
|
|
|
|
|
|
|
|
virtual void upsertFile(const std::string & path, const std::string & data) = 0;
|
|
|
|
|
|
|
|
virtual std::string getFile(const std::string & path) = 0;
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
|
|
|
virtual void init();
|
|
|
|
|
|
|
|
struct Stats
|
|
|
|
{
|
|
|
|
std::atomic<uint64_t> narInfoRead{0};
|
|
|
|
std::atomic<uint64_t> narInfoReadAverted{0};
|
|
|
|
std::atomic<uint64_t> narInfoWrite{0};
|
|
|
|
std::atomic<uint64_t> narInfoCacheSize{0};
|
|
|
|
std::atomic<uint64_t> narRead{0};
|
|
|
|
std::atomic<uint64_t> narReadBytes{0};
|
|
|
|
std::atomic<uint64_t> narReadCompressedBytes{0};
|
|
|
|
std::atomic<uint64_t> narWrite{0};
|
|
|
|
std::atomic<uint64_t> narWriteAverted{0};
|
|
|
|
std::atomic<uint64_t> narWriteBytes{0};
|
|
|
|
std::atomic<uint64_t> narWriteCompressedBytes{0};
|
|
|
|
std::atomic<uint64_t> narWriteCompressionTimeMs{0};
|
|
|
|
};
|
|
|
|
|
|
|
|
const Stats & getStats();
|
|
|
|
|
|
|
|
private:
|
|
|
|
|
|
|
|
Stats stats;
|
|
|
|
|
2016-02-24 15:52:28 +00:00
|
|
|
std::string narMagic;
|
|
|
|
|
2016-02-24 13:48:16 +00:00
|
|
|
std::string narInfoFileFor(const Path & storePath);
|
|
|
|
|
|
|
|
void addToCache(const ValidPathInfo & info, const string & nar);
|
|
|
|
|
|
|
|
protected:
|
|
|
|
|
|
|
|
NarInfo readNarInfo(const Path & storePath);
|
|
|
|
|
|
|
|
public:
|
|
|
|
|
|
|
|
bool isValidPath(const Path & path) override;
|
|
|
|
|
|
|
|
PathSet queryValidPaths(const PathSet & paths) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
PathSet queryAllValidPaths() override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
ValidPathInfo queryPathInfo(const Path & path) override;
|
|
|
|
|
|
|
|
Hash queryPathHash(const Path & path) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void queryReferrers(const Path & path,
|
|
|
|
PathSet & referrers) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
Path queryDeriver(const Path & path) override
|
2016-02-24 15:52:28 +00:00
|
|
|
{ return ""; }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
PathSet queryValidDerivers(const Path & path) override
|
2016-02-24 15:52:28 +00:00
|
|
|
{ return {}; }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
PathSet queryDerivationOutputs(const Path & path) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
StringSet queryDerivationOutputNames(const Path & path) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
Path queryPathFromHashPart(const string & hashPart) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
PathSet querySubstitutablePaths(const PathSet & paths) override
|
2016-02-24 15:52:28 +00:00
|
|
|
{ return {}; }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void querySubstitutablePathInfos(const PathSet & paths,
|
|
|
|
SubstitutablePathInfos & infos) override;
|
|
|
|
|
|
|
|
Path addToStore(const string & name, const Path & srcPath,
|
|
|
|
bool recursive = true, HashType hashAlgo = htSHA256,
|
2016-02-24 15:52:28 +00:00
|
|
|
PathFilter & filter = defaultPathFilter, bool repair = false) override;
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
Path addTextToStore(const string & name, const string & s,
|
2016-02-24 15:52:28 +00:00
|
|
|
const PathSet & references, bool repair = false) override;
|
2016-02-24 13:48:16 +00:00
|
|
|
|
2016-03-22 13:21:45 +00:00
|
|
|
void narFromPath(const Path & path, Sink & sink) override;
|
2016-03-21 16:55:57 +00:00
|
|
|
|
2016-02-25 16:43:19 +00:00
|
|
|
void exportPath(const Path & path, bool sign, Sink & sink) override;
|
2016-02-24 13:48:16 +00:00
|
|
|
|
2016-02-26 14:20:10 +00:00
|
|
|
Paths importPaths(bool requireSignature, Source & source,
|
|
|
|
std::shared_ptr<FSAccessor> accessor) override;
|
2016-02-24 13:48:16 +00:00
|
|
|
|
2016-02-26 14:20:10 +00:00
|
|
|
Path importPath(Source & source, std::shared_ptr<FSAccessor> accessor);
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void buildPaths(const PathSet & paths, BuildMode buildMode = bmNormal) override;
|
|
|
|
|
|
|
|
BuildResult buildDerivation(const Path & drvPath, const BasicDerivation & drv,
|
|
|
|
BuildMode buildMode = bmNormal) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void ensurePath(const Path & path) override;
|
|
|
|
|
|
|
|
void addTempRoot(const Path & path) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void addIndirectRoot(const Path & path) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void syncWithGC() override
|
|
|
|
{ }
|
|
|
|
|
|
|
|
Roots findRoots() override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void collectGarbage(const GCOptions & options, GCResults & results) override
|
2016-02-24 13:57:30 +00:00
|
|
|
{ notImpl(); }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
PathSet queryFailedPaths() override
|
2016-02-24 15:52:28 +00:00
|
|
|
{ return {}; }
|
2016-02-24 13:48:16 +00:00
|
|
|
|
|
|
|
void clearFailedPaths(const PathSet & paths) override
|
|
|
|
{ }
|
|
|
|
|
|
|
|
void optimiseStore() override
|
|
|
|
{ }
|
|
|
|
|
|
|
|
bool verifyStore(bool checkContents, bool repair) override
|
|
|
|
{ return true; }
|
|
|
|
|
2016-02-25 16:43:19 +00:00
|
|
|
ref<FSAccessor> getFSAccessor() override;
|
|
|
|
|
2016-02-24 13:48:16 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
}
|