From b5a29ec0daf024fde9bd06f76cab8a12fd509aab Mon Sep 17 00:00:00 2001 From: Maksim Denisov Date: Tue, 18 Jun 2024 15:46:56 +0200 Subject: Pass StorageConfig to GarbageCollector::SharedLock --- src/buildtool/serve_api/serve_service/source_tree.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) (limited to 'src/buildtool/serve_api/serve_service/source_tree.cpp') 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); -- cgit v1.2.3