aboutsummaryrefslogtreecommitdiff
path: root/zenstore/CAS.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2021-05-25 12:54:06 +0200
committerStefan Boberg <[email protected]>2021-05-25 12:54:06 +0200
commite9a1089cfb918a7790503309726d9b6cd5004c39 (patch)
tree93b4b20b2c19b2c0bb80a7862f3ea7d73c80bffc /zenstore/CAS.cpp
parentStructured cache now verifies attachment payloads (diff)
downloadzen-e9a1089cfb918a7790503309726d9b6cd5004c39.tar.xz
zen-e9a1089cfb918a7790503309726d9b6cd5004c39.zip
Removed pointer-based InsertChunk from CAS store interface.
All code must now use the IoBuffer path
Diffstat (limited to 'zenstore/CAS.cpp')
-rw-r--r--zenstore/CAS.cpp28
1 files changed, 5 insertions, 23 deletions
diff --git a/zenstore/CAS.cpp b/zenstore/CAS.cpp
index 8d81fc5cb..1f477cb17 100644
--- a/zenstore/CAS.cpp
+++ b/zenstore/CAS.cpp
@@ -38,7 +38,6 @@ public:
virtual ~CasImpl();
virtual void Initialize(const CasStoreConfiguration& InConfig) override;
- virtual CasStore::InsertResult InsertChunk(const void* ChunkData, size_t ChunkSize, const IoHash& ChunkHash) override;
virtual CasStore::InsertResult InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash) override;
virtual IoBuffer FindChunk(const IoHash& ChunkHash) override;
@@ -104,39 +103,22 @@ CasImpl::Initialize(const CasStoreConfiguration& InConfig)
}
CasStore::InsertResult
-CasImpl::InsertChunk(const void* ChunkData, size_t ChunkSize, const IoHash& ChunkHash)
-{
- if (ChunkSize < m_Config.TinyValueThreshold)
- {
- return m_TinyStrategy.InsertChunk(ChunkData, ChunkSize, ChunkHash);
- }
- else if (ChunkSize >= m_Config.HugeValueThreshold)
- {
- return m_LargeStrategy.InsertChunk(ChunkData, ChunkSize, ChunkHash);
- }
- else
- {
- return m_SmallStrategy.InsertChunk(ChunkData, ChunkSize, ChunkHash);
- }
-}
-
-CasStore::InsertResult
CasImpl::InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash)
{
const uint64_t ChunkSize = Chunk.Size();
if (ChunkSize < m_Config.TinyValueThreshold)
{
+ ZEN_ASSERT(ChunkSize);
+
return m_TinyStrategy.InsertChunk(Chunk, ChunkHash);
}
- else if (Chunk.Size() >= m_Config.HugeValueThreshold)
- {
- return m_LargeStrategy.InsertChunk(Chunk, ChunkHash);
- }
- else
+ else if (ChunkSize < m_Config.HugeValueThreshold)
{
return m_SmallStrategy.InsertChunk(Chunk, ChunkHash);
}
+
+ return m_LargeStrategy.InsertChunk(Chunk, ChunkHash);
}
IoBuffer