summaryrefslogtreecommitdiff
path: root/src/buildtool/serve_api/serve_service/source_tree.cpp
diff options
context:
space:
mode:
authorMaksim Denisov <denisov.maksim@huawei.com>2024-06-18 15:46:56 +0200
committerMaksim Denisov <denisov.maksim@huawei.com>2024-07-05 12:58:35 +0200
commitb5a29ec0daf024fde9bd06f76cab8a12fd509aab (patch)
treeb1786fc20a5033aa6789ab37b916e072c4d3937a /src/buildtool/serve_api/serve_service/source_tree.cpp
parentc88585ddf9386fb14154a4f3baa702569d55584a (diff)
downloadjustbuild-b5a29ec0daf024fde9bd06f76cab8a12fd509aab.tar.gz
Pass StorageConfig to GarbageCollector::SharedLock
Diffstat (limited to 'src/buildtool/serve_api/serve_service/source_tree.cpp')
-rw-r--r--src/buildtool/serve_api/serve_service/source_tree.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/buildtool/serve_api/serve_service/source_tree.cpp b/src/buildtool/serve_api/serve_service/source_tree.cpp
index b7e5d59c..8be074fc 100644
--- a/src/buildtool/serve_api/serve_service/source_tree.cpp
+++ b/src/buildtool/serve_api/serve_service/source_tree.cpp
@@ -775,7 +775,7 @@ auto SourceTreeService::ServeArchiveTree(
return ::grpc::Status::OK;
}
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(ServeArchiveTreeResponse::INTERNAL_ERROR);
@@ -985,7 +985,7 @@ auto SourceTreeService::ServeDistdirTree(
const ::justbuild::just_serve::ServeDistdirTreeRequest* request,
ServeDistdirTreeResponse* response) -> ::grpc::Status {
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(ServeDistdirTreeResponse::INTERNAL_ERROR);
@@ -1276,7 +1276,7 @@ auto SourceTreeService::ServeContent(
ServeContentResponse* response) -> ::grpc::Status {
auto const& content{request->content()};
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(ServeContentResponse::INTERNAL_ERROR);
@@ -1386,7 +1386,7 @@ auto SourceTreeService::ServeTree(
ServeTreeResponse* response) -> ::grpc::Status {
auto const& tree_id{request->tree()};
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(ServeTreeResponse::INTERNAL_ERROR);
@@ -1520,7 +1520,7 @@ auto SourceTreeService::CheckRootTree(
CheckRootTreeResponse* response) -> ::grpc::Status {
auto const& tree_id{request->tree()};
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(CheckRootTreeResponse::INTERNAL_ERROR);
@@ -1622,7 +1622,7 @@ auto SourceTreeService::GetRemoteTree(
GetRemoteTreeResponse* response) -> ::grpc::Status {
auto const& tree_id{request->tree()};
// acquire lock for CAS
- auto lock = GarbageCollector::SharedLock();
+ auto lock = GarbageCollector::SharedLock(StorageConfig::Instance());
if (!lock) {
logger_->Emit(LogLevel::Error, "Could not acquire gc SharedLock");
response->set_status(GetRemoteTreeResponse::INTERNAL_ERROR);