diff options
Diffstat (limited to 'src/zenstore/cache/cachedisklayer.cpp')
| -rw-r--r-- | src/zenstore/cache/cachedisklayer.cpp | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/src/zenstore/cache/cachedisklayer.cpp b/src/zenstore/cache/cachedisklayer.cpp index 4535f785b..502ab1508 100644 --- a/src/zenstore/cache/cachedisklayer.cpp +++ b/src/zenstore/cache/cachedisklayer.cpp @@ -1402,7 +1402,7 @@ ZenCacheDiskLayer::CacheBucket::EndPutBatch(PutBatchHandle* Batch) noexcept { ZEN_ASSERT(Batch->Buffers.size() == Batch->Entries.size()); std::vector<uint8_t> EntryFlags; - std::vector<size_t> BufferToEntryIndexes; + std::vector<size_t> BufferToEntryIndexes; std::vector<IoBuffer> BuffersToCommit; BuffersToCommit.reserve(Batch->Buffers.size()); for (size_t Index = 0; Index < Batch->Entries.size(); Index++) @@ -1414,12 +1414,8 @@ ZenCacheDiskLayer::CacheBucket::EndPutBatch(PutBatchHandle* Batch) noexcept TemporaryValue.Value = Batch->Buffers[Index]; std::span<const IoHash> ReferenceSpan(HashKeyAndReferences.begin() + 1, HashKeyAndReferences.end()); PutResult& OutResult = Batch->OutResults[Batch->EntryResultIndexes[Index]]; - OutResult = PutResult{zen::PutStatus::Success}; - if (!ShouldRejectPut(HashKeyAndReferences[0], - TemporaryValue, - ReferenceSpan, - Batch->Entries[Index].Overwrite, - OutResult)) + OutResult = PutResult{zen::PutStatus::Success}; + if (!ShouldRejectPut(HashKeyAndReferences[0], TemporaryValue, ReferenceSpan, Batch->Entries[Index].Overwrite, OutResult)) { BufferToEntryIndexes.push_back(Index); BuffersToCommit.push_back(TemporaryValue.Value); @@ -1440,9 +1436,8 @@ ZenCacheDiskLayer::CacheBucket::EndPutBatch(PutBatchHandle* Batch) noexcept size_t IndexOffset = 0; m_BlockStore.WriteChunks(BuffersToCommit, m_Configuration.PayloadAlignment, [&](std::span<BlockStoreLocation> Locations) { ZEN_MEMSCOPE(GetCacheDiskTag()); - std::vector<DiskIndexEntry> DiskEntries; + std::vector<DiskIndexEntry> DiskEntries; { - RwLock::ExclusiveLockScope IndexLock(m_IndexLock); for (size_t Index = 0; Index < Locations.size(); Index++) { |