diff options
| author | Dan Engelbrecht <[email protected]> | 2022-06-08 10:42:14 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2022-06-08 10:42:14 +0200 |
| commit | 898831078128b31e2c56e8b830f9b505e23a56bf (patch) | |
| tree | a9d846c38fb864a14c2c15b961f39e5839be8ea2 /zenstore | |
| parent | updated changelog (diff) | |
| parent | Merge pull request #123 from EpicGames/de/fix-gc-over-multiple-namespaces (diff) | |
| download | zen-898831078128b31e2c56e8b830f9b505e23a56bf.tar.xz zen-898831078128b31e2c56e8b830f9b505e23a56bf.zip | |
Merge branch 'main' into de/add-log-for-invalid-names
Diffstat (limited to 'zenstore')
| -rw-r--r-- | zenstore/gc.cpp | 18 | ||||
| -rw-r--r-- | zenstore/include/zenstore/gc.h | 4 |
2 files changed, 8 insertions, 14 deletions
diff --git a/zenstore/gc.cpp b/zenstore/gc.cpp index 8e2d441f8..dfa3d54ab 100644 --- a/zenstore/gc.cpp +++ b/zenstore/gc.cpp @@ -170,15 +170,9 @@ SaveCompactBinaryObject(const fs::path& Path, const CbObject& Object) struct GcContext::GcState { - struct CacheBucket - { - std::vector<IoHash> ValidKeys; - std::vector<IoHash> ExpiredKeys; - }; - - using CacheBuckets = std::unordered_map<std::string, CacheBucket>; + using CacheKeyContexts = std::unordered_map<std::string, std::vector<IoHash>>; - CacheBuckets m_CacheBuckets; + CacheKeyContexts m_ExpiredCacheKeys; CasChunkSet m_CasChunks; CasChunkSet m_DeletedCasChunks; CasChunkSet m_CidChunks; @@ -212,9 +206,9 @@ GcContext::ContributeCas(std::span<const IoHash> Cas) } void -GcContext::ContributeCacheKeys(const std::string& Bucket, std::vector<IoHash>&& ExpiredKeys) +GcContext::ContributeCacheKeys(const std::string& CacheKeyContext, std::vector<IoHash>&& ExpiredKeys) { - m_State->m_CacheBuckets[Bucket].ExpiredKeys = std::move(ExpiredKeys); + m_State->m_ExpiredCacheKeys[CacheKeyContext] = std::move(ExpiredKeys); } void @@ -254,9 +248,9 @@ GcContext::DeletedCas() } std::span<const IoHash> -GcContext::ExpiredCacheKeys(const std::string& Bucket) const +GcContext::ExpiredCacheKeys(const std::string& CacheKeyContext) const { - return m_State->m_CacheBuckets[Bucket].ExpiredKeys; + return m_State->m_ExpiredCacheKeys[CacheKeyContext]; } bool diff --git a/zenstore/include/zenstore/gc.h b/zenstore/include/zenstore/gc.h index 6268588ec..a3ad19e10 100644 --- a/zenstore/include/zenstore/gc.h +++ b/zenstore/include/zenstore/gc.h @@ -53,7 +53,7 @@ public: void ContributeCids(std::span<const IoHash> Cid); void ContributeCas(std::span<const IoHash> Hash); - void ContributeCacheKeys(const std::string& Bucket, std::vector<IoHash>&& ExpiredKeys); + void ContributeCacheKeys(const std::string& CacheKeyContext, std::vector<IoHash>&& ExpiredKeys); void IterateCids(std::function<void(const IoHash&)> Callback); @@ -64,7 +64,7 @@ public: void DeletedCas(std::span<const IoHash> Cas); CasChunkSet& DeletedCas(); - std::span<const IoHash> ExpiredCacheKeys(const std::string& Bucket) const; + std::span<const IoHash> ExpiredCacheKeys(const std::string& CacheKeyContext) const; bool IsDeletionMode() const; void SetDeletionMode(bool NewState); |