aboutsummaryrefslogtreecommitdiff
path: root/zenstore/blockstore.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2022-05-01 23:38:59 +0200
committerDan Engelbrecht <[email protected]>2022-05-01 23:40:23 +0200
commitb5f5b1e792a559d0358ab8a755b335cfb2185e9f (patch)
treecaaa207cd78cd0dc309d81d558fcb74b3433c1c0 /zenstore/blockstore.cpp
parentrespect Ctx.RunRecovery() (diff)
downloadzen-b5f5b1e792a559d0358ab8a755b335cfb2185e9f.tar.xz
zen-b5f5b1e792a559d0358ab8a755b335cfb2185e9f.zip
cleanup
Diffstat (limited to 'zenstore/blockstore.cpp')
-rw-r--r--zenstore/blockstore.cpp16
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);
}
}
}