From f84f5d9c1ca60c39cb27c806900d6a99727650d3 Mon Sep 17 00:00:00 2001
From: Stefan Boberg <stefan@boberg.org>
Date: Wed, 11 Aug 2021 12:09:34 +0200
Subject: Implemented Flush() operation for CID/CAS store interfaces

---
 zenstore/CAS.cpp | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

(limited to 'zenstore/CAS.cpp')

diff --git a/zenstore/CAS.cpp b/zenstore/CAS.cpp
index 1f477cb17..36cf85549 100644
--- a/zenstore/CAS.cpp
+++ b/zenstore/CAS.cpp
@@ -40,6 +40,7 @@ public:
 	virtual void				   Initialize(const CasStoreConfiguration& InConfig) override;
 	virtual CasStore::InsertResult InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash) override;
 	virtual IoBuffer			   FindChunk(const IoHash& ChunkHash) override;
+	virtual void				   Flush() override;
 
 private:
 	void PickDefaultDirectory();
@@ -143,13 +144,20 @@ CasImpl::FindChunk(const IoHash& ChunkHash)
 	return IoBuffer{};
 }
 
+void
+CasImpl::Flush()
+{
+	m_SmallStrategy.Flush();
+	m_TinyStrategy.Flush();
+	m_LargeStrategy.Flush();
+}
+
 //////////////////////////////////////////////////////////////////////////
 
 CasStore*
 CreateCasStore()
 {
 	return new CasImpl();
-	// return new FileCasImpl();
 }
 
 //////////////////////////////////////////////////////////////////////////
-- 
cgit v1.2.3