summaryrefslogtreecommitdiff
path: root/test/buildtool/execution_api/local/local_cas.test.cpp
diff options
context:
space:
mode:
authorOliver Reiche <oliver.reiche@huawei.com>2023-02-24 15:49:14 +0100
committerOliver Reiche <oliver.reiche@huawei.com>2023-03-13 17:28:59 +0100
commit42b452e72f536b63bac080880b8daa481099793c (patch)
tree0af1a60e5e0fefb5572df38e092def3d8ac74c05 /test/buildtool/execution_api/local/local_cas.test.cpp
parent546bf5beebf2eb75e7b325f8f18969b4dd34a169 (diff)
downloadjustbuild-42b452e72f536b63bac080880b8daa481099793c.tar.gz
Storage: Reworked storage and garbage collection
The improved GC implementation uses refactored storage classes instead of directly accessing "unknown" file paths. The required storage class refactoring is quite substantial and outlined in the following paragraphs. The module `buildtool/file_system` was extended by: - `ObjectCAS`: a plain CAS implementation for reading/writing blobs and computing digests for a given `ObjectType`. Depending on that type, files written to the file system may have different properties (e.g., the x-bit set) or the digest may be computed differently (e.g., tree digests in non-compatible mode). A new module `buildtool/storage` was introduced containing: - `LocalCAS`: provides a common interface for the "logical CAS", which internally combines three `ObjectCAS`s, one for each `ObjectType` (file, executable, tree). - `LocalAC`: implements the action cache, which needs the `LocalCAS` for storing cache values. - `TargetCache`: implements the high-level target cache, which also needs the `LocalCAS` for storing cache values. - `LocalStorage`: combines the storage classes `LocalCAS`, `LocalAC`, and `TargetCache`. Those are initialized with settings from `StorageConfig`, such as the build root base path or number of generations for the garbage collector. `LocalStorage` is templated with a Boolean parameter `kDoGlobalUplink`, which indicates that, on every read/write access, the garbage collector should be used for uplinking across all generations (global). - `GarbageCollector`: responsible for garbage collection and the global uplinking across all generations. To do so, it employs instances of `LocalStorage` with `kDoGlobalUplink` set to false, in order to avoid endless recursion. The actual (local) uplinking within two single generations is performed by the corresponding storage class (e.g., `TargetCache` implements uplinking of target cache entries between two target cache generations etc.). Thereby, the actual knowledge how data should be uplinked is implemented by the instance that is responsible for creating the data in the first place.
Diffstat (limited to 'test/buildtool/execution_api/local/local_cas.test.cpp')
-rw-r--r--test/buildtool/execution_api/local/local_cas.test.cpp102
1 files changed, 0 insertions, 102 deletions
diff --git a/test/buildtool/execution_api/local/local_cas.test.cpp b/test/buildtool/execution_api/local/local_cas.test.cpp
deleted file mode 100644
index 14a86628..00000000
--- a/test/buildtool/execution_api/local/local_cas.test.cpp
+++ /dev/null
@@ -1,102 +0,0 @@
-// Copyright 2022 Huawei Cloud Computing Technology Co., Ltd.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-#include <string>
-
-#include "catch2/catch.hpp"
-#include "src/buildtool/crypto/hash_function.hpp"
-#include "src/buildtool/execution_api/local/local_cas.hpp"
-#include "src/buildtool/file_system/file_system_manager.hpp"
-#include "test/utils/hermeticity/local.hpp"
-
-TEST_CASE_METHOD(HermeticLocalTestFixture, "LocalCAS", "[execution_api]") {
- std::string test_content{"test"};
- auto test_digest = ArtifactDigest::Create<ObjectType::File>(test_content);
-
- SECTION("CAS for files") {
- LocalCAS<ObjectType::File> cas{};
- CHECK(not cas.BlobPath(test_digest));
-
- SECTION("Add blob from bytes and verify") {
- // add blob
- auto cas_digest = cas.StoreBlobFromBytes(test_content);
- CHECK(cas_digest);
- CHECK(std::equal_to<bazel_re::Digest>{}(*cas_digest, test_digest));
-
- // verify blob
- auto blob_path = cas.BlobPath(*cas_digest);
- REQUIRE(blob_path);
- auto const cas_content = FileSystemManager::ReadFile(*blob_path);
- CHECK(cas_content.has_value());
- CHECK(cas_content == test_content);
- CHECK(not FileSystemManager::IsExecutable(*blob_path));
- }
-
- SECTION("Add blob from file") {
- CHECK(FileSystemManager::CreateDirectory("tmp"));
- CHECK(FileSystemManager::WriteFile(test_content, "tmp/test"));
-
- // add blob
- auto cas_digest = cas.StoreBlobFromFile("tmp/test");
- CHECK(cas_digest);
- CHECK(std::equal_to<bazel_re::Digest>{}(*cas_digest, test_digest));
-
- // verify blob
- auto blob_path = cas.BlobPath(*cas_digest);
- REQUIRE(blob_path);
- auto const cas_content = FileSystemManager::ReadFile(*blob_path);
- CHECK(cas_content.has_value());
- CHECK(cas_content == test_content);
- CHECK(not FileSystemManager::IsExecutable(*blob_path));
- }
- }
-
- SECTION("CAS for executables") {
- LocalCAS<ObjectType::Executable> cas{};
- CHECK(not cas.BlobPath(test_digest));
-
- SECTION("Add blob from bytes and verify") {
- // add blob
- auto cas_digest = cas.StoreBlobFromBytes(test_content);
- CHECK(cas_digest);
- CHECK(std::equal_to<bazel_re::Digest>{}(*cas_digest, test_digest));
-
- // verify blob
- auto blob_path = cas.BlobPath(*cas_digest);
- REQUIRE(blob_path);
- auto const cas_content = FileSystemManager::ReadFile(*blob_path);
- CHECK(cas_content.has_value());
- CHECK(cas_content == test_content);
- CHECK(FileSystemManager::IsExecutable(*blob_path));
- }
-
- SECTION("Add blob from file") {
- CHECK(FileSystemManager::CreateDirectory("tmp"));
- CHECK(FileSystemManager::WriteFile(test_content, "tmp/test"));
-
- // add blob
- auto cas_digest = cas.StoreBlobFromFile("tmp/test");
- CHECK(cas_digest);
- CHECK(std::equal_to<bazel_re::Digest>{}(*cas_digest, test_digest));
-
- // verify blob
- auto blob_path = cas.BlobPath(*cas_digest);
- REQUIRE(blob_path);
- auto const cas_content = FileSystemManager::ReadFile(*blob_path);
- CHECK(cas_content.has_value());
- CHECK(cas_content == test_content);
- CHECK(FileSystemManager::IsExecutable(*blob_path));
- }
- }
-}