diff options
Diffstat (limited to 'src/zenstore/compactcas.cpp')
| -rw-r--r-- | src/zenstore/compactcas.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/zenstore/compactcas.cpp b/src/zenstore/compactcas.cpp index 5cc4dad54..bf843171e 100644 --- a/src/zenstore/compactcas.cpp +++ b/src/zenstore/compactcas.cpp @@ -1722,7 +1722,7 @@ TEST_CASE("compactcas.restart") { uint64_t ExpectedSize = 0; - WorkerThreadPool ThreadPool(Max(std::thread::hardware_concurrency() - 1u, 2u), "put"); + WorkerThreadPool ThreadPool(Max(GetHardwareConcurrency() - 1u, 2u), "put"); auto GenerateChunks = [&](CasContainerStrategy& Cas, size_t ChunkCount, uint64_t ChunkSize, std::vector<IoHash>& Hashes) { Latch WorkLatch(1); @@ -1959,7 +1959,7 @@ TEST_CASE("compactcas.restart") TEST_CASE("compactcas.iteratechunks") { std::atomic<size_t> WorkCompleted = 0; - WorkerThreadPool ThreadPool(Max(std::thread::hardware_concurrency() - 1u, 2u), "put"); + WorkerThreadPool ThreadPool(Max(GetHardwareConcurrency() - 1u, 2u), "put"); const uint64_t kChunkSize = 1048 + 395; const size_t kChunkCount = 63840; @@ -2035,7 +2035,7 @@ TEST_CASE("compactcas.iteratechunks") WorkLatch.Wait(); } - WorkerThreadPool BatchWorkerPool(Max(std::thread::hardware_concurrency() - 1u, 2u), "fetch"); + WorkerThreadPool BatchWorkerPool(Max(GetHardwareConcurrency() - 1u, 2u), "fetch"); { std::vector<std::atomic<bool>> FetchedFlags(Hashes.size()); std::atomic<uint64_t> FetchedSize = 0; |