aboutsummaryrefslogtreecommitdiff
path: root/zenserver/cache/structuredcachestore.cpp
diff options
context:
space:
mode:
authorPer Larsson <[email protected]>2021-12-10 15:29:18 +0100
committerPer Larsson <[email protected]>2021-12-10 15:29:18 +0100
commit370d0134a7f755b1e39fbba5c9482ecc9ff3a0fe (patch)
tree7329dc070434ccc265be6a7651274366d8c9fc06 /zenserver/cache/structuredcachestore.cpp
parentSet GC default enabled and interval set to zero (off). (diff)
downloadzen-370d0134a7f755b1e39fbba5c9482ecc9ff3a0fe.tar.xz
zen-370d0134a7f755b1e39fbba5c9482ecc9ff3a0fe.zip
Added size to GcStorage.
Diffstat (limited to 'zenserver/cache/structuredcachestore.cpp')
-rw-r--r--zenserver/cache/structuredcachestore.cpp24
1 files changed, 12 insertions, 12 deletions
diff --git a/zenserver/cache/structuredcachestore.cpp b/zenserver/cache/structuredcachestore.cpp
index 64e597d53..f74bb05c1 100644
--- a/zenserver/cache/structuredcachestore.cpp
+++ b/zenserver/cache/structuredcachestore.cpp
@@ -200,10 +200,10 @@ ZenCacheStore::CollectGarbage(GcContext& GcCtx)
m_DiskLayer.CollectGarbage(GcCtx);
}
-ZenCacheSize
-ZenCacheStore::TotalSize() const
+GcStorageSize
+ZenCacheStore::StorageSize() const
{
- return {.MemorySize = m_MemLayer.TotalSize(), .DiskSize = m_DiskLayer.TotalSize()};
+ return {.DiskSize = m_DiskLayer.TotalSize(), .MemorySize = m_MemLayer.TotalSize()};
}
//////////////////////////////////////////////////////////////////////////
@@ -472,7 +472,7 @@ struct ZenCacheDiskLayer::CacheBucket
void CollectGarbage(GcContext& GcCtx);
inline bool IsOk() const { return m_IsOk; }
- inline uint64_t TotalSize() const { return m_TotalSize; }
+ inline uint64_t TotalSize() const { return m_TotalSize.load(std::memory_order::relaxed); }
private:
std::filesystem::path m_BucketDir;
@@ -1544,7 +1544,7 @@ TEST_CASE("zcache.size")
const size_t Count = 16;
ScopedTemporaryDirectory TempDir;
- ZenCacheSize CacheSize;
+ GcStorageSize CacheSize;
{
CasGc Gc;
@@ -1561,7 +1561,7 @@ TEST_CASE("zcache.size")
Zcs.Put("test_bucket-{}"_format(Bucket), IoHash::HashBuffer(&Key, sizeof(uint32_t)), {.Value = Buffer});
}
- CacheSize = Zcs.TotalSize();
+ CacheSize = Zcs.StorageSize();
CHECK_EQ(CacheValue.GetSize() * Count, CacheSize.DiskSize);
CHECK_EQ(CacheValue.GetSize() * Count, CacheSize.MemorySize);
}
@@ -1570,7 +1570,7 @@ TEST_CASE("zcache.size")
CasGc Gc;
ZenCacheStore Zcs(Gc, TempDir.Path() / "cache");
- const ZenCacheSize SerializedSize = Zcs.TotalSize();
+ const GcStorageSize SerializedSize = Zcs.StorageSize();
CHECK_EQ(SerializedSize.MemorySize, 0);
CHECK_EQ(SerializedSize.DiskSize, CacheSize.DiskSize);
@@ -1578,7 +1578,7 @@ TEST_CASE("zcache.size")
{
Zcs.DropBucket("test_bucket-{}"_format(Bucket));
}
- CHECK_EQ(0, Zcs.TotalSize().DiskSize);
+ CHECK_EQ(0, Zcs.StorageSize().DiskSize);
}
}
@@ -1587,7 +1587,7 @@ TEST_CASE("zcache.size")
const size_t Count = 16;
ScopedTemporaryDirectory TempDir;
- ZenCacheSize CacheSize;
+ GcStorageSize CacheSize;
{
CasGc Gc;
@@ -1604,7 +1604,7 @@ TEST_CASE("zcache.size")
Zcs.Put("test_bucket-{}"_format(Bucket), IoHash::HashBuffer(&Key, sizeof(uint32_t)), {.Value = Buffer});
}
- CacheSize = Zcs.TotalSize();
+ CacheSize = Zcs.StorageSize();
CHECK_EQ(CacheValue.GetSize() * Count, CacheSize.DiskSize);
CHECK_EQ(0, CacheSize.MemorySize);
}
@@ -1613,7 +1613,7 @@ TEST_CASE("zcache.size")
CasGc Gc;
ZenCacheStore Zcs(Gc, TempDir.Path() / "cache");
- const ZenCacheSize SerializedSize = Zcs.TotalSize();
+ const GcStorageSize SerializedSize = Zcs.StorageSize();
CHECK_EQ(SerializedSize.MemorySize, 0);
CHECK_EQ(SerializedSize.DiskSize, CacheSize.DiskSize);
@@ -1621,7 +1621,7 @@ TEST_CASE("zcache.size")
{
Zcs.DropBucket("test_bucket-{}"_format(Bucket));
}
- CHECK_EQ(0, Zcs.TotalSize().DiskSize);
+ CHECK_EQ(0, Zcs.StorageSize().DiskSize);
}
}
}