aboutsummaryrefslogtreecommitdiff
path: root/zenstore/gc.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2022-03-22 17:34:11 +0100
committerDan Engelbrecht <[email protected]>2022-03-31 11:28:33 +0200
commitf4d040e2c0f602c34af47614907fecd8f6229316 (patch)
tree987b8e864d46d5851cabe01ab6179d5d78ff425e /zenstore/gc.cpp
parentReduce lock contention when garbage collecting (diff)
downloadzen-f4d040e2c0f602c34af47614907fecd8f6229316.tar.xz
zen-f4d040e2c0f602c34af47614907fecd8f6229316.zip
WIP
Diffstat (limited to 'zenstore/gc.cpp')
-rw-r--r--zenstore/gc.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/zenstore/gc.cpp b/zenstore/gc.cpp
index 853f2a3db..a2bd4ce15 100644
--- a/zenstore/gc.cpp
+++ b/zenstore/gc.cpp
@@ -612,6 +612,7 @@ TEST_CASE("gc.basic")
GcContext GcCtx;
GcCtx.CollectSmallObjects(true);
+ CasStore->Flush();
Gc.CollectGarbage(GcCtx);
CHECK(!CidStore.ContainsChunk(InsertResult.DecompressedId));
@@ -673,6 +674,7 @@ TEST_CASE("gc.full")
KeepChunks.push_back(ChunkHashes[8]);
GcCtx.ContributeCas(KeepChunks);
+ CasStore->Flush();
Gc.CollectGarbage(GcCtx);
CHECK(CasStore->ContainsChunk(ChunkHashes[0]));
@@ -705,6 +707,7 @@ TEST_CASE("gc.full")
KeepChunks.push_back(ChunkHashes[8]);
GcCtx.ContributeCas(KeepChunks);
+ CasStore->Flush();
Gc.CollectGarbage(GcCtx);
CHECK(!CasStore->ContainsChunk(ChunkHashes[0]));
@@ -738,6 +741,7 @@ TEST_CASE("gc.full")
KeepChunks.push_back(ChunkHashes[7]);
GcCtx.ContributeCas(KeepChunks);
+ CasStore->Flush();
Gc.CollectGarbage(GcCtx);
CHECK(!CasStore->ContainsChunk(ChunkHashes[0]));
@@ -772,6 +776,7 @@ TEST_CASE("gc.full")
KeepChunks.push_back(ChunkHashes[8]);
GcCtx.ContributeCas(KeepChunks);
+ CasStore->Flush();
Gc.CollectGarbage(GcCtx);
CHECK(!CasStore->ContainsChunk(ChunkHashes[0]));