diff options
Diffstat (limited to 'src/zenstore/cidstore.cpp')
| -rw-r--r-- | src/zenstore/cidstore.cpp | 15 |
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) { |