Ticket #57109: shared_timed_mutex.patch

src/import_manager.cc

@@ -3 +3 @@
 bool ImportManager::IsInitialImport(const std::string& path) {
   // Try reading the value
   {
-    std::shared_lock<std::shared_timed_mutex> lock(initial_import_mutex_);
+    std::lock_guard<std::mutex> lock(initial_import_mutex_);
     if (initial_import_.find(path) != initial_import_.end())
       return false;
   }
 
   // Try inserting the value
   {
-    std::unique_lock<std::shared_timed_mutex> lock(initial_import_mutex_);
+    std::unique_lock<std::mutex> lock(initial_import_mutex_);
     return initial_import_.insert(path).second;
   }
 }
@@ -18 +18 @@
 bool ImportManager::TryMarkDependencyImported(const std::string& path) {
   // Try reading the value
   {
-    std::shared_lock<std::shared_timed_mutex> lock(dependency_mutex_);
+    std::lock_guard<std::mutex> lock(dependency_mutex_);
     if (dependency_imported_.find(path) != dependency_imported_.end())
       return false;
   }
 
   // Try inserting the value
   {
-    std::unique_lock<std::shared_timed_mutex> lock(dependency_mutex_);
+    std::unique_lock<std::mutex> lock(dependency_mutex_);
     return dependency_imported_.insert(path).second;
   }
 }

src/import_manager.h

@@ -1 +1 @@
 #pragma once
 
-#include <shared_mutex>
+#include <mutex>
 #include <string>
 #include <unordered_set>
 
@@ -27 +27 @@
   std::unordered_set<std::string> querydb_processing_;
 
   // TODO: use shared_mutex
-  std::shared_timed_mutex dependency_mutex_;
+  std::mutex dependency_mutex_;
   std::unordered_set<std::string> dependency_imported_;
 
   // TODO: use shared_mutex
-  std::shared_timed_mutex initial_import_mutex_;
+  std::mutex initial_import_mutex_;
   std::unordered_set<std::string> initial_import_;
-};
- No newline at end of file
+};