Replace unnecessary Sync<uint64_t> with std::atomic<uint64_t>

NixOS · Apr 1, 2023 · 2b905d1 · 2b905d1
1 parent cf76b38
commit 2b905d1
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/src/libstore/store-api.cc b/src/libstore/store-api.cc
@@ -10,7 +10,6 @@
 #include "archive.hh"
 #include "callback.hh"
 #include "remote-store.hh"
-#include "sync.hh"
 
 #include <nlohmann/json.hpp>
 #include <regex>
@@ -1103,7 +1102,7 @@ std::map<StorePath, StorePath> copyPaths(
     };
 
     // total is accessed by each copy, which are each handled in separate threads
-    Sync<uint64_t> _total = 0;
+    std::atomic<uint64_t> total = 0;
 
     for (auto & missingPath : sortedMissing) {
         auto info = srcStore.queryPathInfo(missingPath);
@@ -1126,9 +1125,8 @@ std::map<StorePath, StorePath> copyPaths(
             PushActivity pact(act.id);
 
             LambdaSink progressSink([&](std::string_view data) {
-                auto total(_total.lock());
-                *total += data.size();
-                act.progress(*total, info->narSize);
+                total += data.size();
+                act.progress(total, info->narSize);
             });
             TeeSink tee { sink, progressSink };