diff options
author | Vincent Ambo <mail@tazj.in> | 2020-08-20T01·32+0100 |
---|---|---|
committer | tazjin <mail@tazj.in> | 2020-08-20T11·48+0000 |
commit | 19e874a9854c0d7f49d79fa98177a84b6997ce9a (patch) | |
tree | f6e68f233b45c6e596ee0719d09abf651e7d083f /third_party/nix/src/libstore/rpc-store.cc | |
parent | 883de9b8d71b9cb984d8ff315b4dcc30e0ca9082 (diff) |
feat(tvix): Introduce build event streams in worker protocol r/1685
Introduces a new `BuildEvent` proto type which is streamed in response to calls that trigger builds of derivations. This type can currently supply build statuses, log lines and information about builds starting. This is in preparation for threading build logs through the processes. Since we have nowhere to send the logs (yet), a null sink is used instead. Co-authored-by: Griffin Smith <grfn@gws.fyi> Change-Id: If7332337b89506c7e404cd20174acdaa1a3be4e8 Reviewed-on: https://cl.tvl.fyi/c/depot/+/1793 Tested-by: BuildkiteCI Reviewed-by: glittershark <grfn@gws.fyi> Reviewed-by: kanepyork <rikingcoding@gmail.com>
Diffstat (limited to 'third_party/nix/src/libstore/rpc-store.cc')
-rw-r--r-- | third_party/nix/src/libstore/rpc-store.cc | 51 |
1 files changed, 45 insertions, 6 deletions
diff --git a/third_party/nix/src/libstore/rpc-store.cc b/third_party/nix/src/libstore/rpc-store.cc index 2d1278f40c78..f3fc5582f3ef 100644 --- a/third_party/nix/src/libstore/rpc-store.cc +++ b/third_party/nix/src/libstore/rpc-store.cc @@ -3,6 +3,7 @@ #include <algorithm> #include <filesystem> #include <memory> +#include <optional> #include <absl/status/status.h> #include <absl/strings/str_cat.h> @@ -326,8 +327,32 @@ absl::Status RpcStore::buildPaths(const PathSet& paths, BuildMode buildMode) { google::protobuf::Empty response; request.set_mode(nix::BuildModeToProto(buildMode)); - return nix::util::proto::GRPCStatusToAbsl( - stub_->BuildPaths(&ctx, request, &response)); + + // TODO(tazjin): Temporary no-op sink used to discard build output, + // but satisfy the compiler. A real one is needed. + // + // Maybe this should just be stderr, considering that this is the + // *client*, but I'm not sure. + std::ostream discard_logs = DiscardLogsSink(); + + std::unique_ptr<grpc::ClientReader<proto::BuildEvent>> reader = + stub_->BuildPaths(&ctx, request); + + proto::BuildEvent event; + while (reader->Read(&event)) { + if (event.has_build_log()) { + // TODO(tazjin): Include .path()? + discard_logs << event.build_log().line(); + } else { + discard_logs << std::endl + << "Building path: " << event.building_path().path() + << std::endl; + } + + // has_result() is not in use in this call (for now) + } + + return nix::util::proto::GRPCStatusToAbsl(reader->Finish()); } BuildResult RpcStore::buildDerivation(const Path& drvPath, @@ -339,11 +364,25 @@ BuildResult RpcStore::buildDerivation(const Path& drvPath, auto proto_drv = drv.to_proto(); request.set_allocated_derivation(&proto_drv); request.set_build_mode(BuildModeToProto(buildMode)); - proto::BuildDerivationResponse response; - SuccessOrThrow(stub_->BuildDerivation(&ctx, request, &response), - __FUNCTION__); - const auto result = BuildResult::FromProto(response); + // Same note as in ::buildPaths ... + std::ostream discard_logs = DiscardLogsSink(); + + std::unique_ptr<grpc::ClientReader<proto::BuildEvent>> reader = + stub_->BuildDerivation(&ctx, request); + + std::optional<BuildResult> result; + + proto::BuildEvent event; + while (reader->Read(&event)) { + if (event.has_build_log()) { + discard_logs << event.build_log().line(); + } else if (event.has_result()) { + result = BuildResult::FromProto(event.result()); + } + } + SuccessOrThrow(reader->Finish(), __FUNCTION__); + if (!result.has_value()) { throw Error("Invalid response from daemon for buildDerivation"); } |