aboutsummaryrefslogtreecommitdiff
path: root/src/zenstore/cas.cpp
diff options
context:
space:
mode:
authorStefan Boberg <[email protected]>2025-03-06 17:27:59 +0100
committerStefan Boberg <[email protected]>2025-03-06 17:27:59 +0100
commit66e5d1f4e288e0c32f854ebe3b63584b42b83554 (patch)
treed67e9d358419b5baccd429d54988414e0d7cd7a6 /src/zenstore/cas.cpp
parentreduced memory churn using fixed_xxx containers (#236) (diff)
downloadzen-66e5d1f4e288e0c32f854ebe3b63584b42b83554.tar.xz
zen-66e5d1f4e288e0c32f854ebe3b63584b42b83554.zip
switched std::vector -> eastl::vector
Diffstat (limited to 'src/zenstore/cas.cpp')
-rw-r--r--src/zenstore/cas.cpp72
1 files changed, 36 insertions, 36 deletions
diff --git a/src/zenstore/cas.cpp b/src/zenstore/cas.cpp
index 73c10a6db..e85383a2a 100644
--- a/src/zenstore/cas.cpp
+++ b/src/zenstore/cas.cpp
@@ -60,21 +60,21 @@ public:
CasImpl(GcManager& Gc);
virtual ~CasImpl();
- virtual void Initialize(const CidStoreConfiguration& InConfig) override;
- virtual CasStore::InsertResult InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash, InsertMode Mode) override;
- virtual std::vector<InsertResult> InsertChunks(std::span<IoBuffer> Data,
- std::span<IoHash> ChunkHashes,
- InsertMode Mode = InsertMode::kMayBeMovedInPlace) override;
- virtual IoBuffer FindChunk(const IoHash& ChunkHash) override;
- virtual bool ContainsChunk(const IoHash& ChunkHash) override;
- virtual void FilterChunks(HashKeySet& InOutChunks) override;
- virtual bool IterateChunks(std::span<IoHash> DecompressedIds,
- const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
- WorkerThreadPool* OptionalWorkerPool,
- uint64_t LargeSizeLimit) override;
- virtual void Flush() override;
- virtual void ScrubStorage(ScrubContext& Ctx) override;
- virtual CidStoreSize TotalSize() const override;
+ virtual void Initialize(const CidStoreConfiguration& InConfig) override;
+ virtual CasStore::InsertResult InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash, InsertMode Mode) override;
+ virtual eastl::vector<InsertResult> InsertChunks(std::span<IoBuffer> Data,
+ std::span<IoHash> ChunkHashes,
+ InsertMode Mode = InsertMode::kMayBeMovedInPlace) override;
+ virtual IoBuffer FindChunk(const IoHash& ChunkHash) override;
+ virtual bool ContainsChunk(const IoHash& ChunkHash) override;
+ virtual void FilterChunks(HashKeySet& InOutChunks) override;
+ virtual bool IterateChunks(std::span<IoHash> DecompressedIds,
+ const std::function<bool(size_t Index, const IoBuffer& Payload)>& AsyncCallback,
+ WorkerThreadPool* OptionalWorkerPool,
+ uint64_t LargeSizeLimit) override;
+ virtual void Flush() override;
+ virtual void ScrubStorage(ScrubContext& Ctx) override;
+ virtual CidStoreSize TotalSize() const override;
private:
CasContainerStrategy m_TinyStrategy;
@@ -126,8 +126,8 @@ CasImpl::Initialize(const CidStoreConfiguration& InConfig)
// Initialize payload storage
{
- WorkerThreadPool& WorkerPool = GetMediumWorkerPool(EWorkloadType::Burst);
- std::vector<std::future<void>> Work;
+ WorkerThreadPool& WorkerPool = GetMediumWorkerPool(EWorkloadType::Burst);
+ eastl::vector<std::future<void>> Work;
Work.emplace_back(
WorkerPool.EnqueueTask(std::packaged_task<void()>{[&]() { m_LargeStrategy.Initialize(m_Config.RootDirectory, IsNewStore); }}));
Work.emplace_back(WorkerPool.EnqueueTask(std::packaged_task<void()>{[&]() {
@@ -259,11 +259,11 @@ CasImpl::InsertChunk(IoBuffer Chunk, const IoHash& ChunkHash, InsertMode Mode)
}
static void
-GetCompactCasResults(CasContainerStrategy& Strategy,
- std::span<IoBuffer> Data,
- std::span<IoHash> ChunkHashes,
- std::span<size_t> Indexes,
- std::vector<CasStore::InsertResult> Results)
+GetCompactCasResults(CasContainerStrategy& Strategy,
+ std::span<IoBuffer> Data,
+ std::span<IoHash> ChunkHashes,
+ std::span<size_t> Indexes,
+ eastl::vector<CasStore::InsertResult> Results)
{
const size_t Count = Indexes.size();
if (Count == 1)
@@ -272,8 +272,8 @@ GetCompactCasResults(CasContainerStrategy& Strategy,
Results[Index] = Strategy.InsertChunk(Data[Index], ChunkHashes[Index]);
return;
}
- std::vector<IoBuffer> Chunks;
- std::vector<IoHash> Hashes;
+ eastl::vector<IoBuffer> Chunks;
+ eastl::vector<IoHash> Hashes;
Chunks.reserve(Count);
Hashes.reserve(Count);
for (size_t Index : Indexes)
@@ -292,12 +292,12 @@ GetCompactCasResults(CasContainerStrategy& Strategy,
};
static void
-GetFileCasResults(FileCasStrategy& Strategy,
- CasStore::InsertMode Mode,
- std::span<IoBuffer> Data,
- std::span<IoHash> ChunkHashes,
- std::span<size_t> Indexes,
- std::vector<CasStore::InsertResult> Results)
+GetFileCasResults(FileCasStrategy& Strategy,
+ CasStore::InsertMode Mode,
+ std::span<IoBuffer> Data,
+ std::span<IoHash> ChunkHashes,
+ std::span<size_t> Indexes,
+ eastl::vector<CasStore::InsertResult> Results)
{
for (size_t Index : Indexes)
{
@@ -305,7 +305,7 @@ GetFileCasResults(FileCasStrategy& Strategy,
}
};
-std::vector<CasStore::InsertResult>
+eastl::vector<CasStore::InsertResult>
CasImpl::InsertChunks(std::span<IoBuffer> Data, std::span<IoHash> ChunkHashes, CasStore::InsertMode Mode)
{
ZEN_MEMSCOPE(GetCasTag());
@@ -314,14 +314,14 @@ CasImpl::InsertChunks(std::span<IoBuffer> Data, std::span<IoHash> ChunkHashes, C
if (Data.size() == 1)
{
- std::vector<CasStore::InsertResult> Result(1);
+ eastl::vector<CasStore::InsertResult> Result(1);
Result[0] = InsertChunk(Data[0], ChunkHashes[0], Mode);
return Result;
}
- std::vector<size_t> TinyIndexes;
- std::vector<size_t> SmallIndexes;
- std::vector<size_t> LargeIndexes;
+ eastl::vector<size_t> TinyIndexes;
+ eastl::vector<size_t> SmallIndexes;
+ eastl::vector<size_t> LargeIndexes;
for (size_t Index = 0; Index < Data.size(); Index++)
{
@@ -341,7 +341,7 @@ CasImpl::InsertChunks(std::span<IoBuffer> Data, std::span<IoHash> ChunkHashes, C
}
}
- std::vector<CasStore::InsertResult> Result(Data.size());
+ eastl::vector<CasStore::InsertResult> Result(Data.size());
if (!TinyIndexes.empty())
{