diff options
Diffstat (limited to 'src/libstore')
-rw-r--r-- | src/libstore/remote-store.cc | 23 | ||||
-rw-r--r-- | src/libstore/worker-protocol.hh | 8 |
2 files changed, 23 insertions, 8 deletions
diff --git a/src/libstore/remote-store.cc b/src/libstore/remote-store.cc index f59fe8b98..99f9589be 100644 --- a/src/libstore/remote-store.cc +++ b/src/libstore/remote-store.cc @@ -2,6 +2,7 @@ #include "util.hh" #include "remote-store.hh" #include "worker-protocol.hh" +#include "archive.hh" #include <iostream> #include <unistd.h> @@ -111,33 +112,45 @@ void RemoteStore::queryReferrers(const Path & storePath, Path RemoteStore::addToStore(const Path & srcPath) { - throw Error("not implemented"); + writeInt(wopAddToStore, to); + writeString(baseNameOf(srcPath), to); + dumpPath(srcPath, to); + Path path = readString(from); + return path; } Path RemoteStore::addToStoreFixed(bool recursive, string hashAlgo, const Path & srcPath) { - throw Error("not implemented"); + throw Error("not implemented 4"); } Path RemoteStore::addTextToStore(const string & suffix, const string & s, const PathSet & references) { - throw Error("not implemented"); + writeInt(wopAddTextToStore, to); + writeString(suffix, to); + writeString(s, to); + writeInt(references.size(), to); + for (PathSet::iterator i = references.begin(); i != references.end(); ++i) + writeString(*i, to); + + Path path = readString(from); + return path; } void RemoteStore::buildDerivations(const PathSet & drvPaths) { - throw Error("not implemented"); + throw Error("not implemented 6"); } void RemoteStore::ensurePath(const Path & storePath) { - throw Error("not implemented"); + throw Error("not implemented 7"); } diff --git a/src/libstore/worker-protocol.hh b/src/libstore/worker-protocol.hh index 0ba0c374e..dd711f330 100644 --- a/src/libstore/worker-protocol.hh +++ b/src/libstore/worker-protocol.hh @@ -7,9 +7,11 @@ typedef enum { - wopQuit = 0, - wopIsValidPath = 1, - wopQuerySubstitutes = 2, + wopQuit, + wopIsValidPath, + wopQuerySubstitutes, + wopAddToStore, + wopAddTextToStore, } WorkerOp; |