diff options
Diffstat (limited to 'zenstore/compactcas.cpp')
| -rw-r--r-- | zenstore/compactcas.cpp | 20 |
1 files changed, 16 insertions, 4 deletions
diff --git a/zenstore/compactcas.cpp b/zenstore/compactcas.cpp index 5f335816c..3cb7d8854 100644 --- a/zenstore/compactcas.cpp +++ b/zenstore/compactcas.cpp @@ -2372,7 +2372,10 @@ TEST_CASE("compactcas.threadedinsert") // * doctest::skip(true)) ZEN_ASSERT(InsertResult.New); }); } - ThreadPool.Flush(); + while (ThreadPool.PendingWork() > 0) + { + Sleep(1); + } } const uint64_t TotalSize = Cas.StorageSize().DiskSize; @@ -2389,7 +2392,10 @@ TEST_CASE("compactcas.threadedinsert") // * doctest::skip(true)) CHECK(ChunkHash == Hash); }); } - ThreadPool.Flush(); + while (ThreadPool.PendingWork() > 0) + { + Sleep(1); + } } std::unordered_set<IoHash, IoHash::Hasher> GcChunkHashes(ChunkHashes.begin(), ChunkHashes.end()); @@ -2473,7 +2479,10 @@ TEST_CASE("compactcas.threadedinsert") // * doctest::skip(true)) Deleted.IterateChunks([&GcChunkHashes](const IoHash& ChunkHash) { GcChunkHashes.erase(ChunkHash); }); } - ThreadPool.Flush(); + while (ThreadPool.PendingWork() > 0) + { + Sleep(1); + } { std::vector<IoHash> AddedHashes; @@ -2517,7 +2526,10 @@ TEST_CASE("compactcas.threadedinsert") // * doctest::skip(true)) CHECK(ChunkHash == IoHash::HashBuffer(Cas.FindChunk(ChunkHash))); }); } - ThreadPool.Flush(); + while (ThreadPool.PendingWork() > 0) + { + Sleep(1); + } } } } |