diff options
| author | Dan Engelbrecht <[email protected]> | 2022-05-01 23:38:59 +0200 |
|---|---|---|
| committer | Dan Engelbrecht <[email protected]> | 2022-05-01 23:40:23 +0200 |
| commit | b5f5b1e792a559d0358ab8a755b335cfb2185e9f (patch) | |
| tree | caaa207cd78cd0dc309d81d558fcb74b3433c1c0 /zenstore/blockstore.cpp | |
| parent | respect Ctx.RunRecovery() (diff) | |
| download | zen-b5f5b1e792a559d0358ab8a755b335cfb2185e9f.tar.xz zen-b5f5b1e792a559d0358ab8a755b335cfb2185e9f.zip | |
cleanup
Diffstat (limited to 'zenstore/blockstore.cpp')
| -rw-r--r-- | zenstore/blockstore.cpp | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/zenstore/blockstore.cpp b/zenstore/blockstore.cpp index 559dfc1ee..9961e734d 100644 --- a/zenstore/blockstore.cpp +++ b/zenstore/blockstore.cpp @@ -194,7 +194,7 @@ BlockStore::Initialize(const std::filesystem::path& BlocksBasePath, } void -BlockStore::WriteChunk(const void* Data, uint64_t Size, uint64_t Alignment, WriteCompleteCallback Callback) +BlockStore::WriteChunk(const void* Data, uint64_t Size, uint64_t Alignment, WriteChunkCallback Callback) { RwLock::ExclusiveLockScope InsertLock(m_InsertLock); @@ -584,9 +584,9 @@ BlockStore::ReclaimSpace(const ReclaimSnapshotState& Snapshot, } void -BlockStore::IterateChunks(const std::vector<BlockStoreLocation>& ChunkLocations, - std::function<void(size_t ChunkIndex, const void* Data, uint64_t Size)> SmallChunkCallback, - std::function<void(size_t ChunkIndex, BasicFile& BlockFile, uint64_t Offset, uint64_t Size)> LargeChunkCallback) +BlockStore::IterateChunks(const std::vector<BlockStoreLocation>& ChunkLocations, + IterateChunksSmallSizeCallback SmallSizeCallback, + IterateChunksLargeSizeCallback LargeSizeCallback) { // We do a read sweep through the payloads file and validate // any entries that are contained within each segment, with @@ -637,9 +637,9 @@ BlockStore::IterateChunks(const std::vector<BlockStoreLocation>& continue; } - SmallChunkCallback(ChunkIndex, - reinterpret_cast<uint8_t*>(BufferBase) + Location.Offset - WindowStart, - Location.Size); + SmallSizeCallback(ChunkIndex, + reinterpret_cast<uint8_t*>(BufferBase) + Location.Offset - WindowStart, + Location.Size); } } @@ -654,7 +654,7 @@ BlockStore::IterateChunks(const std::vector<BlockStoreLocation>& { const BlockStoreLocation Location = ChunkLocations[ChunkIndex]; BasicFile& BlockFile = m_ChunkBlocks[Location.BlockIndex]->GetBasicFile(); - LargeChunkCallback(ChunkIndex, BlockFile, Location.Offset, Location.Size); + LargeSizeCallback(ChunkIndex, BlockFile, Location.Offset, Location.Size); } } } |