diff options
| author | Dan Engelbrecht <[email protected]> | 2022-08-31 09:57:43 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2022-08-31 00:57:43 -0700 |
| commit | 1ea0f4d70f9097fd6d8a541274815d3797bd8ad6 (patch) | |
| tree | 46ce5cba07471f0d7923850d4e736a4c0db58036 /zenserver/upstream/upstreamcache.cpp | |
| parent | update changelog with changes since 0.1.3 (#151) (diff) | |
| download | zen-1ea0f4d70f9097fd6d8a541274815d3797bd8ad6.tar.xz zen-1ea0f4d70f9097fd6d8a541274815d3797bd8ad6.zip | |
remove legacy derived data interface for Jupiter (#152)
* remove legacy derived data interface for Jupiter
Diffstat (limited to 'zenserver/upstream/upstreamcache.cpp')
| -rw-r--r-- | zenserver/upstream/upstreamcache.cpp | 26 |
1 files changed, 6 insertions, 20 deletions
diff --git a/zenserver/upstream/upstreamcache.cpp b/zenserver/upstream/upstreamcache.cpp index 40d627862..a897c21fd 100644 --- a/zenserver/upstream/upstreamcache.cpp +++ b/zenserver/upstream/upstreamcache.cpp @@ -88,7 +88,6 @@ namespace detail { JupiterUpstreamEndpoint(const CloudCacheClientOptions& Options, const UpstreamAuthConfig& AuthConfig, AuthMgr& Mgr) : m_AuthMgr(Mgr) , m_Log(zen::logging::Get("upstream")) - , m_UseLegacyDdc(Options.UseLegacyDdc) { ZEN_ASSERT(!Options.Name.empty()); m_Info.Name = Options.Name; @@ -192,12 +191,7 @@ namespace detail { std::string_view BlobStoreNamespace = GetActualBlobStoreNamespace(Session, Namespace); - if (m_UseLegacyDdc && Type == ZenContentType::kBinary) - { - std::string_view DdcNamespace = GetActualDdcNamespace(Session, Namespace); - Result = Session.GetDerivedData(DdcNamespace, CacheKey.Bucket, CacheKey.Hash); - } - else if (Type == ZenContentType::kCompressedBinary) + if (Type == ZenContentType::kCompressedBinary) { Result = Session.GetRef(BlobStoreNamespace, CacheKey.Bucket, CacheKey.Hash, ZenContentType::kCbObject); @@ -449,18 +443,11 @@ namespace detail { for (uint32_t Attempt = 0; Attempt < MaxAttempts && !Result.Success; Attempt++) { std::string_view BlobStoreNamespace = GetActualBlobStoreNamespace(Session, CacheRecord.Namespace); - if (m_UseLegacyDdc) - { - Result = Session.PutDerivedData(BlobStoreNamespace, CacheRecord.Key.Bucket, CacheRecord.Key.Hash, RecordValue); - } - else - { - Result = Session.PutRef(BlobStoreNamespace, - CacheRecord.Key.Bucket, - CacheRecord.Key.Hash, - RecordValue, - ZenContentType::kBinary); - } + Result = Session.PutRef(BlobStoreNamespace, + CacheRecord.Key.Bucket, + CacheRecord.Key.Hash, + RecordValue, + ZenContentType::kBinary); } m_Status.SetFromErrorCode(Result.ErrorCode, Result.Reason); @@ -671,7 +658,6 @@ namespace detail { UpstreamEndpointInfo m_Info; UpstreamStatus m_Status; UpstreamEndpointStats m_Stats; - bool m_UseLegacyDdc; RefPtr<CloudCacheClient> m_Client; }; |