Fix build

DeterminateSystems · Jan 15, 2025 · b23ef1b · b23ef1b
1 parent 4bf9371
commit b23ef1b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 8 deletions.
diff --git a/src/libfetchers/git-utils.cc b/src/libfetchers/git-utils.cc
@@ -1152,12 +1152,10 @@ struct GitFileSystemObjectSinkImpl : GitFileSystemObjectSink
             }
         }
 
-        ThreadPool workers2{concurrency};
-
         auto & root = _state.lock()->root;
 
         processGraph<Directory *>(
-            workers2,
+            //workers2,
             {&root},
             [&](Directory * const & node) -> std::set<Directory *>
             {
@@ -1188,7 +1186,8 @@ struct GitFileSystemObjectSinkImpl : GitFileSystemObjectSink
                     throw Error("creating a tree object: %s", git_error_last()->message);
                 node->oid = oid;
             },
-            true);
+            true,
+            concurrency);
 
         #if 0
         repo->flush();

diff --git a/src/libutil/thread-pool.hh b/src/libutil/thread-pool.hh
@@ -86,7 +86,8 @@ void processGraph(
     const std::set<T> & nodes,
     std::function<std::set<T>(const T &)> getEdges,
     std::function<void(const T &)> processNode,
-    bool discoverNodes = false)
+    bool discoverNodes = false,
+    size_t maxThreads = 0)
 {
     struct Graph {
         std::set<T> known;
@@ -98,9 +99,9 @@ void processGraph(
 
     std::function<void(const T &)> worker;
 
-    /* Create pool last to ensure threads are stopped before other destructors
-     * run */
-    ThreadPool pool;
+    /* Create pool last to ensure threads are stopped before other
+       destructors run. */
+    ThreadPool pool(maxThreads);
 
     worker = [&](const T & node) {