diff options
| author | Dan Engelbrecht <[email protected]> | 2025-05-12 10:08:50 +0200 |
|---|---|---|
| committer | GitHub Enterprise <[email protected]> | 2025-05-12 10:08:50 +0200 |
| commit | e452381cf3fcff977e32541b1c3909294a8f6a4d (patch) | |
| tree | 973928b3d40654dc9e5adf1b54e78108f3eb7ddd /src/zenstore/cas.cpp | |
| parent | handle exception in oplog mirror (#389) (diff) | |
| download | zen-e452381cf3fcff977e32541b1c3909294a8f6a4d.tar.xz zen-e452381cf3fcff977e32541b1c3909294a8f6a4d.zip | |
tweak iterate block parameters (#390)
* tweak block iteration chunk sizes
Diffstat (limited to 'src/zenstore/cas.cpp')
| -rw-r--r-- | src/zenstore/cas.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/src/zenstore/cas.cpp b/src/zenstore/cas.cpp index ed42f254e..460f0e10d 100644 --- a/src/zenstore/cas.cpp +++ b/src/zenstore/cas.cpp @@ -412,6 +412,7 @@ CasImpl::IterateChunks(std::span<IoHash> DecompressedIds, uint64_t LargeSizeLimit) { ZEN_TRACE_CPU("CAS::IterateChunks"); + if (!m_SmallStrategy.IterateChunks( DecompressedIds, [&](size_t Index, const IoBuffer& Payload) { @@ -420,10 +421,11 @@ CasImpl::IterateChunks(std::span<IoHash> DecompressedIds, return AsyncCallback(Index, Payload); }, OptionalWorkerPool, - LargeSizeLimit)) + LargeSizeLimit == 0 ? m_Config.HugeValueThreshold : Min(LargeSizeLimit, m_Config.HugeValueThreshold))) { return false; } + if (!m_TinyStrategy.IterateChunks( DecompressedIds, [&](size_t Index, const IoBuffer& Payload) { @@ -432,10 +434,11 @@ CasImpl::IterateChunks(std::span<IoHash> DecompressedIds, return AsyncCallback(Index, Payload); }, OptionalWorkerPool, - LargeSizeLimit)) + LargeSizeLimit == 0 ? m_Config.TinyValueThreshold : Min(LargeSizeLimit, m_Config.TinyValueThreshold))) { return false; } + if (!m_LargeStrategy.IterateChunks( DecompressedIds, [&](size_t Index, const IoBuffer& Payload) { |