aboutsummaryrefslogtreecommitdiff
path: root/zenserver/upstream/upstreamcache.cpp
diff options
context:
space:
mode:
authorDan Engelbrecht <[email protected]>2022-08-31 09:57:43 +0200
committerGitHub <[email protected]>2022-08-31 00:57:43 -0700
commit1ea0f4d70f9097fd6d8a541274815d3797bd8ad6 (patch)
tree46ce5cba07471f0d7923850d4e736a4c0db58036 /zenserver/upstream/upstreamcache.cpp
parentupdate changelog with changes since 0.1.3 (#151) (diff)
downloadzen-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.cpp26
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;
};