diff options
| author | Dan Engelbrecht <[email protected]> | 2022-09-19 14:05:54 +0200 |
|---|---|---|
| committer | GitHub <[email protected]> | 2022-09-19 05:05:54 -0700 |
| commit | def3cf543afd926ad9b7289859afcc6cf7e44870 (patch) | |
| tree | 079c519071c6729fec7c46444a68de26a2946bba /zenserver/cache/structuredcache.cpp | |
| parent | LoadCompactBinary gracefully handles read failures and sizes larger than the ... (diff) | |
| download | zen-def3cf543afd926ad9b7289859afcc6cf7e44870.tar.xz zen-def3cf543afd926ad9b7289859afcc6cf7e44870.zip | |
rename URI chunk requests from value -> chunk (#166)
Diffstat (limited to 'zenserver/cache/structuredcache.cpp')
| -rw-r--r-- | zenserver/cache/structuredcache.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/zenserver/cache/structuredcache.cpp b/zenserver/cache/structuredcache.cpp index f8cbfa55c..50ecd41c2 100644 --- a/zenserver/cache/structuredcache.cpp +++ b/zenserver/cache/structuredcache.cpp @@ -382,7 +382,7 @@ HttpStructuredCacheService::HandleRequest(HttpServerRequest& Request) .BucketSegment = RequestData.Bucket.value(), .HashKey = RequestData.HashKey.value(), .ValueContentId = RequestData.ValueContentId.value()}; - return HandleCacheValueRequest(Request, Ref, ParseCachePolicy(Request.GetQueryParams())); + return HandleCacheChunkRequest(Request, Ref, ParseCachePolicy(Request.GetQueryParams())); } if (RequestData.HashKey.has_value()) @@ -926,16 +926,16 @@ HttpStructuredCacheService::HandlePutCacheRecord(zen::HttpServerRequest& Request } void -HttpStructuredCacheService::HandleCacheValueRequest(HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) +HttpStructuredCacheService::HandleCacheChunkRequest(HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) { switch (Request.RequestVerb()) { case HttpVerb::kHead: case HttpVerb::kGet: - HandleGetCacheValue(Request, Ref, PolicyFromUrl); + HandleGetCacheChunk(Request, Ref, PolicyFromUrl); break; case HttpVerb::kPut: - HandlePutCacheValue(Request, Ref, PolicyFromUrl); + HandlePutCacheChunk(Request, Ref, PolicyFromUrl); break; default: break; @@ -943,7 +943,7 @@ HttpStructuredCacheService::HandleCacheValueRequest(HttpServerRequest& Request, } void -HttpStructuredCacheService::HandleGetCacheValue(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) +HttpStructuredCacheService::HandleGetCacheChunk(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) { Stopwatch Timer; @@ -955,7 +955,7 @@ HttpStructuredCacheService::HandleGetCacheValue(zen::HttpServerRequest& Request, if (QueryUpstream) { - if (auto UpstreamResult = m_UpstreamCache.GetCacheValue(Ref.Namespace, {Ref.BucketSegment, Ref.HashKey}, Ref.ValueContentId); + if (auto UpstreamResult = m_UpstreamCache.GetCacheChunk(Ref.Namespace, {Ref.BucketSegment, Ref.HashKey}, Ref.ValueContentId); UpstreamResult.Success) { if (CompressedBuffer Compressed = CompressedBuffer::FromCompressed(SharedBuffer(UpstreamResult.Value))) @@ -1011,7 +1011,7 @@ HttpStructuredCacheService::HandleGetCacheValue(zen::HttpServerRequest& Request, } void -HttpStructuredCacheService::HandlePutCacheValue(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) +HttpStructuredCacheService::HandlePutCacheChunk(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy PolicyFromUrl) { // Note: Individual cacherecord values are not propagated upstream until a valid cache record has been stored ZEN_UNUSED(PolicyFromUrl); |