From 619def44c1cca9f3cdf63544d5f24f2c7a7d9b77 Mon Sep 17 00:00:00 2001 From: Klaus Aehlig Date: Tue, 22 Feb 2022 17:03:21 +0100 Subject: Initial self-hosting commit This is the initial version of our tool that is able to build itself. In can be bootstrapped by ./bin/bootstrap.py Co-authored-by: Oliver Reiche Co-authored-by: Victor Moreno --- .../execution_api/bazel/bazel_network.test.cpp | 45 ++++++++++++++++++++++ 1 file changed, 45 insertions(+) create mode 100644 test/buildtool/execution_api/bazel/bazel_network.test.cpp (limited to 'test/buildtool/execution_api/bazel/bazel_network.test.cpp') diff --git a/test/buildtool/execution_api/bazel/bazel_network.test.cpp b/test/buildtool/execution_api/bazel/bazel_network.test.cpp new file mode 100644 index 00000000..6a668406 --- /dev/null +++ b/test/buildtool/execution_api/bazel/bazel_network.test.cpp @@ -0,0 +1,45 @@ +#include + +#include "catch2/catch.hpp" +#include "src/buildtool/execution_api/remote/bazel/bazel_execution_client.hpp" +#include "src/buildtool/execution_api/remote/bazel/bazel_network.hpp" +#include "src/buildtool/execution_api/remote/config.hpp" + +constexpr std::size_t kLargeSize = GRPC_DEFAULT_MAX_RECV_MESSAGE_LENGTH + 1; + +TEST_CASE("Bazel network: write/read blobs", "[execution_api]") { + auto const& info = RemoteExecutionConfig::Instance(); + std::string instance_name{"remote-execution"}; + auto network = BazelNetwork{instance_name, info.Host(), info.Port(), {}}; + + std::string content_foo("foo"); + std::string content_bar("bar"); + std::string content_baz(kLargeSize, 'x'); // single larger blob + + BazelBlob foo{ArtifactDigest::Create(content_foo), content_foo}; + BazelBlob bar{ArtifactDigest::Create(content_bar), content_bar}; + BazelBlob baz{ArtifactDigest::Create(content_baz), content_baz}; + + // Search blobs via digest + REQUIRE(network.UploadBlobs(BlobContainer{{foo, bar, baz}})); + + // Read blobs in order + auto reader = network.ReadBlobs( + {foo.digest, bar.digest, baz.digest, bar.digest, foo.digest}); + std::vector blobs{}; + while (true) { + auto next = reader.Next(); + if (next.empty()) { + break; + } + blobs.insert(blobs.end(), next.begin(), next.end()); + } + + // Check order maintained + REQUIRE(blobs.size() == 5); + CHECK(blobs[0].data == content_foo); + CHECK(blobs[1].data == content_bar); + CHECK(blobs[2].data == content_baz); + CHECK(blobs[3].data == content_bar); + CHECK(blobs[4].data == content_foo); +} -- cgit v1.2.3