diff options
Diffstat (limited to 'src/buildtool/execution_api')
3 files changed, 44 insertions, 1 deletions
diff --git a/src/buildtool/execution_api/local/local_action.cpp b/src/buildtool/execution_api/local/local_action.cpp index 331aaaa5..3a2beb64 100644 --- a/src/buildtool/execution_api/local/local_action.cpp +++ b/src/buildtool/execution_api/local/local_action.cpp @@ -45,7 +45,7 @@ auto LocalAction::Execute(Logger const* logger) noexcept "start execution\n" " - exec_dir digest: {}\n" " - action digest: {}", - root_digest_.hash(), + static_cast<bazel_re::Digest>(root_digest_).hash(), action.hash()); } diff --git a/src/buildtool/execution_api/remote/bazel/bazel_api.cpp b/src/buildtool/execution_api/remote/bazel/bazel_api.cpp index c2893917..766549bc 100644 --- a/src/buildtool/execution_api/remote/bazel/bazel_api.cpp +++ b/src/buildtool/execution_api/remote/bazel/bazel_api.cpp @@ -166,6 +166,14 @@ auto BazelApi::CreateAction( Logger::Log(LogLevel::Debug, "failed to create digest for tree."); return std::nullopt; } + + Logger::Log(LogLevel::Trace, [&digest]() { + std::ostringstream oss{}; + oss << "upload root directory" << std::endl; + oss << fmt::format(" - root digest: {}", digest->hash()) << std::endl; + return oss.str(); + }); + if (not Upload(blobs, /*skip_find_missing=*/false)) { Logger::Log(LogLevel::Debug, "failed to upload blobs for tree."); return std::nullopt; 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 da8b518c..20743c3e 100644 --- a/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp +++ b/src/buildtool/execution_api/remote/bazel/bazel_cas_client.cpp @@ -131,6 +131,13 @@ auto BazelCasClient::GetTree(std::string const& instance_name, auto BazelCasClient::UpdateSingleBlob(std::string const& instance_name, BazelBlob const& blob) noexcept -> bool { + logger_.Emit(LogLevel::Trace, [&blob]() { + std::ostringstream oss{}; + oss << "upload single blob" << std::endl; + oss << fmt::format(" - {}", blob.digest.hash()) << std::endl; + return oss.str(); + }); + thread_local static std::string uuid{}; if (uuid.empty()) { auto id = CreateProcessUniqueId(); @@ -185,6 +192,20 @@ auto BazelCasClient::FindMissingBlobs(std::string const& instance_name, LogStatus(&logger_, LogLevel::Debug, status); } + logger_.Emit(LogLevel::Trace, [&start, &end, &result]() { + std::ostringstream oss{}; + oss << "find missing blobs" << std::endl; + std::for_each(start, end, [&oss](auto const& digest) { + oss << fmt::format(" - {}", digest.hash()) << std::endl; + }); + oss << "missing blobs" << std::endl; + std::for_each( + result.cbegin(), result.cend(), [&oss](auto const& digest) { + oss << fmt::format(" - {}", digest.hash()) << std::endl; + }); + return oss.str(); + }); + return result; } @@ -225,6 +246,20 @@ auto BazelCasClient::DoBatchUpdateBlobs(std::string const& instance_name, } } + logger_.Emit(LogLevel::Trace, [&start, &end, &result]() { + std::ostringstream oss{}; + oss << "upload blobs" << std::endl; + std::for_each(start, end, [&oss](auto const& blob) { + oss << fmt::format(" - {}", blob.digest.hash()) << std::endl; + }); + oss << "received blobs" << std::endl; + std::for_each( + result.cbegin(), result.cend(), [&oss](auto const& digest) { + oss << fmt::format(" - {}", digest.hash()) << std::endl; + }); + return oss.str(); + }); + return result; } |