3652326ed2
Previously all includes were anchored in one global mess of header files. This moves the includes into filesystem "namespaces" (if you will) for each sub-package of Nix. Note: This commit does not introduce the relevant build system changes.
111 lines
3 KiB
C++
111 lines
3 KiB
C++
#include <algorithm>
|
|
|
|
#include "libstore/store-api.hh"
|
|
#include "libstore/worker-protocol.hh"
|
|
#include "libutil/archive.hh"
|
|
|
|
namespace nix {
|
|
|
|
struct HashAndWriteSink : Sink {
|
|
Sink& writeSink;
|
|
HashSink hashSink;
|
|
explicit HashAndWriteSink(Sink& writeSink)
|
|
: writeSink(writeSink), hashSink(htSHA256) {}
|
|
void operator()(const unsigned char* data, size_t len) override {
|
|
writeSink(data, len);
|
|
hashSink(data, len);
|
|
}
|
|
Hash currentHash() { return hashSink.currentHash().first; }
|
|
};
|
|
|
|
void Store::exportPaths(const Paths& paths, Sink& sink) {
|
|
Paths sorted = topoSortPaths(PathSet(paths.begin(), paths.end()));
|
|
std::reverse(sorted.begin(), sorted.end());
|
|
|
|
std::string doneLabel("paths exported");
|
|
// logger->incExpected(doneLabel, sorted.size());
|
|
|
|
for (auto& path : sorted) {
|
|
// Activity act(*logger, lvlInfo, format("exporting path '%s'") % path);
|
|
sink << 1;
|
|
exportPath(path, sink);
|
|
// logger->incProgress(doneLabel);
|
|
}
|
|
|
|
sink << 0;
|
|
}
|
|
|
|
void Store::exportPath(const Path& path, Sink& sink) {
|
|
auto info = queryPathInfo(path);
|
|
|
|
HashAndWriteSink hashAndWriteSink(sink);
|
|
|
|
narFromPath(path, hashAndWriteSink);
|
|
|
|
/* Refuse to export paths that have changed. This prevents
|
|
filesystem corruption from spreading to other machines.
|
|
Don't complain if the stored hash is zero (unknown). */
|
|
Hash hash = hashAndWriteSink.currentHash();
|
|
if (hash != info->narHash && info->narHash != Hash(info->narHash.type)) {
|
|
throw Error(format("hash of path '%1%' has changed from '%2%' to '%3%'!") %
|
|
path % info->narHash.to_string() % hash.to_string());
|
|
}
|
|
|
|
hashAndWriteSink << exportMagic << path << info->references << info->deriver
|
|
<< 0;
|
|
}
|
|
|
|
Paths Store::importPaths(Source& source,
|
|
const std::shared_ptr<FSAccessor>& accessor,
|
|
CheckSigsFlag checkSigs) {
|
|
Paths res;
|
|
while (true) {
|
|
auto n = readNum<uint64_t>(source);
|
|
if (n == 0) {
|
|
break;
|
|
}
|
|
if (n != 1) {
|
|
throw Error(
|
|
"input doesn't look like something created by 'nix-store --export'");
|
|
}
|
|
|
|
/* Extract the NAR from the source. */
|
|
TeeSink tee(source);
|
|
parseDump(tee, tee.source);
|
|
|
|
uint32_t magic = readInt(source);
|
|
if (magic != exportMagic) {
|
|
throw Error("Nix archive cannot be imported; wrong format");
|
|
}
|
|
|
|
ValidPathInfo info;
|
|
|
|
info.path = readStorePath(*this, source);
|
|
|
|
// Activity act(*logger, lvlInfo, format("importing path '%s'") %
|
|
// info.path);
|
|
|
|
info.references = readStorePaths<PathSet>(*this, source);
|
|
|
|
info.deriver = readString(source);
|
|
if (!info.deriver.empty()) {
|
|
assertStorePath(info.deriver);
|
|
}
|
|
|
|
info.narHash = hashString(htSHA256, *tee.source.data);
|
|
info.narSize = tee.source.data->size();
|
|
|
|
// Ignore optional legacy signature.
|
|
if (readInt(source) == 1) {
|
|
readString(source);
|
|
}
|
|
|
|
addToStore(info, tee.source.data, NoRepair, checkSigs, accessor);
|
|
|
|
res.push_back(info.path);
|
|
}
|
|
|
|
return res;
|
|
}
|
|
|
|
} // namespace nix
|