diff options
| author | Stefan Boberg <[email protected]> | 2025-03-06 17:27:59 +0100 |
|---|---|---|
| committer | Stefan Boberg <[email protected]> | 2025-03-06 17:27:59 +0100 |
| commit | 66e5d1f4e288e0c32f854ebe3b63584b42b83554 (patch) | |
| tree | d67e9d358419b5baccd429d54988414e0d7cd7a6 /src/zenstore/cas.cpp | |
| parent | reduced memory churn using fixed_xxx containers (#236) (diff) | |
| download | zen-66e5d1f4e288e0c32f854ebe3b63584b42b83554.tar.xz zen-66e5d1f4e288e0c32f854ebe3b63584b42b83554.zip | |
switched std::vector -> eastl::vector
Diffstat (limited to 'src/zenstore/cas.cpp')
| -rw-r--r-- | src/zenstore/cas.cpp | 72 |
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()) { |