aboutsummaryrefslogtreecommitdiff
path: root/src/zenstore/cas.h
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2024-04-24 13:53:54 +0200
committerGitHub Enterprise <[email protected]>2024-04-24 13:53:54 +0200
commit1c0ddc112a6c18d411f1f3ae6d236ecc2bedcfaa (patch)
treecfafeecb830a44a6d0870a217edabcc62d37669c /src/zenstore/cas.h
parentremove obsolete code (diff)
downloadzen-1c0ddc112a6c18d411f1f3ae6d236ecc2bedcfaa.tar.xz
zen-1c0ddc112a6c18d411f1f3ae6d236ecc2bedcfaa.zip
iterate cas chunks (#59)
- Improvement: Reworked GetChunkInfos in oplog store to reduce disk thrashing and improve performance
Diffstat (limited to 'src/zenstore/cas.h')
-rw-r--r--src/zenstore/cas.h3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/zenstore/cas.h b/src/zenstore/cas.h
index f93724905..169f4d58c 100644
--- a/src/zenstore/cas.h
+++ b/src/zenstore/cas.h
@@ -46,6 +46,9 @@ public:
virtual IoBuffer FindChunk(const IoHash& ChunkHash) = 0;
virtual bool ContainsChunk(const IoHash& ChunkHash) = 0;
virtual void FilterChunks(HashKeySet& InOutChunks) = 0;
+ virtual bool IterateChunks(std::span<IoHash> DecompressedIds,
+ const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
+ WorkerThreadPool* OptionalWorkerPool) = 0;
virtual void Flush() = 0;
virtual void ScrubStorage(ScrubContext& Ctx) = 0;
virtual void GarbageCollect(GcContext& GcCtx) = 0;