iterate cas chunks (#59)

- Improvement: Reworked GetChunkInfos in oplog store to reduce disk thrashing and improve performance

1 files changed, 15 insertions, 0 deletions

diff --git a/src/zenstore/cidstore.cpp b/src/zenstore/cidstore.cpp
index 68bccd06b..71fd596f4 100644
--- a/src/zenstore/cidstore.cpp
+++ b/src/zenstore/cidstore.cpp
@@ -117,6 +117,13 @@ struct CidStore::Impl
 		InOutChunks.RemoveHashesIf([&](const IoHash& Hash) { return ContainsChunk(Hash); });
 	}
 
+	bool IterateChunks(std::span<IoHash>												 DecompressedIds,
+					   const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
+					   WorkerThreadPool*												 OptionalWorkerPool)
+	{
+		return m_CasStore.IterateChunks(DecompressedIds, AsyncCallback, OptionalWorkerPool);
+	}
+
 	void Flush() { m_CasStore.Flush(); }
 
 	void ScrubStorage(ScrubContext& Ctx)
@@ -207,6 +214,14 @@ CidStore::ContainsChunk(const IoHash& DecompressedId)
 	return m_Impl->ContainsChunk(DecompressedId);
 }
 
+bool
+CidStore::IterateChunks(std::span<IoHash>												  DecompressedIds,
+						const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
+						WorkerThreadPool*												  OptionalWorkerPool)
+{
+	return m_Impl->IterateChunks(DecompressedIds, AsyncCallback, OptionalWorkerPool);
+}
+
 void
 CidStore::FilterChunks(HashKeySet& InOutChunks)
 {