aboutsummaryrefslogtreecommitdiff
path: root/src/zenserver/storage/cache/httpstructuredcache.cpp
diff options
context:
space:
mode:
authorZousar Shaker <[email protected]>2025-12-19 09:07:15 -0700
committerGitHub Enterprise <[email protected]>2025-12-19 09:07:15 -0700
commit7e4c79846cf380078f3b92a5aa79c79e4cfe578e (patch)
tree2dae1f55c00cf6778c7b16e100e84b24e44d0795 /src/zenserver/storage/cache/httpstructuredcache.cpp
parentoptimize scavenge (#697) (diff)
parentMerge branch 'main' into zs/limit-overwrite-default (diff)
downloadzen-7e4c79846cf380078f3b92a5aa79c79e4cfe578e.tar.xz
zen-7e4c79846cf380078f3b92a5aa79c79e4cfe578e.zip
Merge pull request #696 from ue-foundation/zs/limit-overwrite-default
Zs/limit overwrite default
Diffstat (limited to 'src/zenserver/storage/cache/httpstructuredcache.cpp')
-rw-r--r--src/zenserver/storage/cache/httpstructuredcache.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/src/zenserver/storage/cache/httpstructuredcache.cpp b/src/zenserver/storage/cache/httpstructuredcache.cpp
index 03d2140a1..72f29d14e 100644
--- a/src/zenserver/storage/cache/httpstructuredcache.cpp
+++ b/src/zenserver/storage/cache/httpstructuredcache.cpp
@@ -1268,7 +1268,8 @@ HttpStructuredCacheService::HandlePutCacheRecord(HttpServerRequest& Request, con
if (HasUpstream && EnumHasAllFlags(PolicyFromUrl, CachePolicy::StoreRemote))
{
- m_UpstreamCache.EnqueueUpstream({.Type = ContentType, .Namespace = Ref.Namespace, .Key = {Ref.BucketSegment, Ref.HashKey}});
+ m_UpstreamCache.EnqueueUpstream(
+ {.Type = ContentType, .Namespace = Ref.Namespace, .Key = {Ref.BucketSegment, Ref.HashKey}, .Overwrite = Overwrite});
}
ZEN_DEBUG("PUTCACHERECORD - '{}/{}/{}' {} '{}' in {}",
@@ -1347,7 +1348,8 @@ HttpStructuredCacheService::HandlePutCacheRecord(HttpServerRequest& Request, con
m_UpstreamCache.EnqueueUpstream({.Type = ZenContentType::kCbObject,
.Namespace = Ref.Namespace,
.Key = {Ref.BucketSegment, Ref.HashKey},
- .ValueContentIds = std::move(ValidAttachments)});
+ .ValueContentIds = std::move(ValidAttachments),
+ .Overwrite = Overwrite});
}
Request.WriteResponse(HttpResponseCode::Created);
@@ -1465,7 +1467,8 @@ HttpStructuredCacheService::HandlePutCacheRecord(HttpServerRequest& Request, con
m_UpstreamCache.EnqueueUpstream({.Type = ZenContentType::kCbPackage,
.Namespace = Ref.Namespace,
.Key = {Ref.BucketSegment, Ref.HashKey},
- .ValueContentIds = std::move(ValidAttachments)});
+ .ValueContentIds = std::move(ValidAttachments),
+ .Overwrite = Overwrite});
}
Request.WriteResponse(HttpResponseCode::Created);