From decc061939deee10eb6dcdbbe5813fb510868d1a Mon Sep 17 00:00:00 2001
From: Sergei Zimmerman <sergei@zimmerman.foo>
Date: Sun, 1 Mar 2026 20:09:11 +0300
Subject: [PATCH] libutil: Template SyncBase over condition_variable
 implementation

This will allow us to use boost::fibers with the SyncBase class.
---
 src/libutil/include/nix/util/sync.hh | 29 +++++++++++++++++++---------
 1 file changed, 20 insertions(+), 9 deletions(-)

diff --git a/src/libutil/include/nix/util/sync.hh b/src/libutil/include/nix/util/sync.hh
index ad640410a465..6f3298324ff8 100644
--- a/src/libutil/include/nix/util/sync.hh
+++ b/src/libutil/include/nix/util/sync.hh
@@ -27,7 +27,7 @@ namespace nix {
  * Here, "data" is automatically unlocked when "data_" goes out of
  * scope.
  */
-template<class T, class M, class WL, class RL>
+template<class T, class M, class WL, class RL, class CV>
 class SyncBase
 {
 private:
@@ -76,29 +76,35 @@ public:
 
         ~Lock() {}
 
-        void wait(std::condition_variable & cv)
+        void wait(CV & cv)
         {
             assert(s);
             cv.wait(lk);
         }
 
+        template<class Predicate>
+        void wait(CV & cv, Predicate pred)
+        {
+            assert(s);
+            cv.wait(lk, std::move(pred));
+        }
+
         template<class Rep, class Period>
-        std::cv_status wait_for(std::condition_variable & cv, const std::chrono::duration<Rep, Period> & duration)
+        std::cv_status wait_for(CV & cv, const std::chrono::duration<Rep, Period> & duration)
         {
             assert(s);
             return cv.wait_for(lk, duration);
         }
 
         template<class Rep, class Period, class Predicate>
-        bool wait_for(std::condition_variable & cv, const std::chrono::duration<Rep, Period> & duration, Predicate pred)
+        bool wait_for(CV & cv, const std::chrono::duration<Rep, Period> & duration, Predicate pred)
         {
             assert(s);
             return cv.wait_for(lk, duration, pred);
         }
 
         template<class Clock, class Duration>
-        std::cv_status
-        wait_until(std::condition_variable & cv, const std::chrono::time_point<Clock, Duration> & duration)
+        std::cv_status wait_until(CV & cv, const std::chrono::time_point<Clock, Duration> & duration)
         {
             assert(s);
             return cv.wait_until(lk, duration);
@@ -154,10 +160,15 @@ public:
 };
 
 template<class T>
-using Sync = SyncBase<T, std::mutex, std::unique_lock<std::mutex>, std::unique_lock<std::mutex>>;
+using Sync =
+    SyncBase<T, std::mutex, std::unique_lock<std::mutex>, std::unique_lock<std::mutex>, std::condition_variable>;
 
 template<class T>
-using SharedSync =
-    SyncBase<T, std::shared_mutex, std::unique_lock<std::shared_mutex>, std::shared_lock<std::shared_mutex>>;
+using SharedSync = SyncBase<
+    T,
+    std::shared_mutex,
+    std::unique_lock<std::shared_mutex>,
+    std::shared_lock<std::shared_mutex>,
+    std::condition_variable>;
 
 } // namespace nix