From dad86d8da48f4bf0524379f3fe7db92e1f78afd9 Mon Sep 17 00:00:00 2001
From: Sascha Roloff <sascha.roloff@huawei.com>
Date: Tue, 12 Dec 2023 12:40:32 +0100
Subject: Add debug output for blob splitting

---
 src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

(limited to 'src/buildtool/execution_api/remote')

diff --git a/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp b/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp
index 1ba7d7f1..ae6d6da1 100644
--- a/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp
+++ b/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp
@@ -16,6 +16,7 @@
 
 #include <mutex>
 #include <shared_mutex>
+#include <sstream>
 #include <unordered_map>
 
 #include "grpcpp/grpcpp.h"
@@ -79,8 +80,8 @@ namespace {
 // Cached version of blob-split support request.
 [[nodiscard]] auto BlobSplitSupportCached(
     std::string const& instance_name,
-    std::unique_ptr<bazel_re::ContentAddressableStorage::Stub> const&
-        stub) noexcept -> bool {
+    std::unique_ptr<bazel_re::ContentAddressableStorage::Stub> const& stub,
+    Logger const* logger) noexcept -> bool {
     static auto mutex = std::shared_mutex{};
     static auto blob_split_support_map =
         std::unordered_map<std::string, bool>{};
@@ -91,6 +92,10 @@ namespace {
         }
     }
     auto supported = BlobSplitSupport(instance_name, stub);
+    logger->Emit(LogLevel::Debug,
+                 "Blob split support for \"{}\": {}",
+                 instance_name,
+                 supported);
     auto lock = std::unique_lock(mutex);
     blob_split_support_map[instance_name] = supported;
     return supported;
@@ -265,7 +270,7 @@ auto BazelCasClient::ReadSingleBlob(std::string const& instance_name,
 auto BazelCasClient::SplitBlob(std::string const& instance_name,
                                bazel_re::Digest const& digest) noexcept
     -> std::optional<std::vector<bazel_re::Digest>> {
-    if (not BlobSplitSupportCached(instance_name, stub_)) {
+    if (not BlobSplitSupportCached(instance_name, stub_, &logger_)) {
         return std::nullopt;
     }
     grpc::ClientContext context{};
-- 
cgit v1.2.3