diff options
author | Maksim Denisov <denisov.maksim@huawei.com> | 2024-03-12 17:46:36 +0100 |
---|---|---|
committer | Maksim Denisov <denisov.maksim@huawei.com> | 2024-04-02 15:30:03 +0200 |
commit | d8f7216156aadf292cd0dc5284a6c9267a349112 (patch) | |
tree | 2d8f53573b5238a17469c52fba06a353fc214f06 /src/buildtool/execution_api/execution_service/cas_server.cpp | |
parent | 1dc455d965dc36cd1ba2f4851d72bb4ac085bcef (diff) | |
download | justbuild-d8f7216156aadf292cd0dc5284a6c9267a349112.tar.gz |
LargeBlobs: Use LocalCAS methods to implement split-splice logic of CASUtils.
Diffstat (limited to 'src/buildtool/execution_api/execution_service/cas_server.cpp')
-rw-r--r-- | src/buildtool/execution_api/execution_service/cas_server.cpp | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/src/buildtool/execution_api/execution_service/cas_server.cpp b/src/buildtool/execution_api/execution_service/cas_server.cpp index 1fbea75b..da585851 100644 --- a/src/buildtool/execution_api/execution_service/cas_server.cpp +++ b/src/buildtool/execution_api/execution_service/cas_server.cpp @@ -141,8 +141,8 @@ auto CASServiceImpl::BatchUpdateBlobs( if (NativeSupport::IsTree(hash)) { // In native mode: for trees, check whether the tree invariant holds // before storing the actual tree object. - if (auto err = - CASUtils::EnsureTreeInvariant(x.data(), hash, *storage_)) { + if (auto err = CASUtils::EnsureTreeInvariant( + x.digest(), x.data(), *storage_)) { auto str = fmt::format("BatchUpdateBlobs: {}", *err); logger_.Emit(LogLevel::Error, str); return ::grpc::Status{grpc::StatusCode::FAILED_PRECONDITION, @@ -346,10 +346,8 @@ auto CASServiceImpl::SpliceBlob(::grpc::ServerContext* /*context*/, std::copy(request->chunk_digests().cbegin(), request->chunk_digests().cend(), std::back_inserter(chunk_digests)); - auto splice_result = CASUtils::SpliceBlob(blob_digest, - chunk_digests, - *storage_, - /* check_tree_invariant= */ true); + auto splice_result = + CASUtils::SpliceBlob(blob_digest, chunk_digests, *storage_); if (std::holds_alternative<grpc::Status>(splice_result)) { auto status = std::get<grpc::Status>(splice_result); auto str = fmt::format("SpliceBlob: {}", status.error_message()); |