From eadca136e5db2895379dda0f1a66f019d3914a82 Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Fri, 29 Oct 2021 11:14:12 +0200 Subject: First pass batch request. --- zenserver/cache/structuredcache.h | 1 + 1 file changed, 1 insertion(+) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index ad7253f79..d6b4944fd 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -89,6 +89,7 @@ private: void HandleCachePayloadRequest(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandleGetCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandlePutCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); + void HandleBatchRequest(zen::HttpServerRequest& Request, CachePolicy Policy); void HandleCacheBucketRequest(zen::HttpServerRequest& Request, std::string_view Bucket); virtual void HandleStatsRequest(zen::HttpServerRequest& Request) override; virtual void HandleStatusRequest(zen::HttpServerRequest& Request) override; -- cgit v1.2.3 From 4f503210dca72fdaeee61693626ef6085e93e030 Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Mon, 8 Nov 2021 16:00:10 +0100 Subject: Added batched get chunk(s). --- zenserver/cache/structuredcache.h | 2 ++ 1 file changed, 2 insertions(+) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index d6b4944fd..fe4453c2b 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -90,6 +90,8 @@ private: void HandleGetCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandlePutCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandleBatchRequest(zen::HttpServerRequest& Request, CachePolicy Policy); + void HandleBatchGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); + void HandleBatchGetCacheChunks(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); void HandleCacheBucketRequest(zen::HttpServerRequest& Request, std::string_view Bucket); virtual void HandleStatsRequest(zen::HttpServerRequest& Request) override; virtual void HandleStatusRequest(zen::HttpServerRequest& Request) override; -- cgit v1.2.3 From e0d54396fa3ba0f5466a4ea1f2810721c18fa55f Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Tue, 9 Nov 2021 13:20:00 +0100 Subject: Sort cache keys when resolving payload ID's. --- zenserver/cache/structuredcache.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index fe4453c2b..1ff4f28c9 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -91,7 +91,7 @@ private: void HandlePutCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandleBatchRequest(zen::HttpServerRequest& Request, CachePolicy Policy); void HandleBatchGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); - void HandleBatchGetCacheChunks(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); + void HandleBatchGetCachePayloads(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); void HandleCacheBucketRequest(zen::HttpServerRequest& Request, std::string_view Bucket); virtual void HandleStatsRequest(zen::HttpServerRequest& Request) override; virtual void HandleStatusRequest(zen::HttpServerRequest& Request) override; -- cgit v1.2.3 From 424be141e88b04b4de7ab5def2c29b03f5f72d48 Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Wed, 10 Nov 2021 08:47:57 +0100 Subject: Handle cache record policy. --- zenserver/cache/structuredcache.h | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index 1ff4f28c9..9efcc05fa 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -89,9 +89,9 @@ private: void HandleCachePayloadRequest(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandleGetCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandlePutCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); - void HandleBatchRequest(zen::HttpServerRequest& Request, CachePolicy Policy); - void HandleBatchGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); - void HandleBatchGetCachePayloads(zen::HttpServerRequest& Request, CbObjectView BatchRequest, CachePolicy Policy); + void HandleBatchRequest(zen::HttpServerRequest& Request); + void HandleBatchGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest); + void HandleBatchGetCachePayloads(zen::HttpServerRequest& Request, CbObjectView BatchRequest); void HandleCacheBucketRequest(zen::HttpServerRequest& Request, std::string_view Bucket); virtual void HandleStatsRequest(zen::HttpServerRequest& Request) override; virtual void HandleStatusRequest(zen::HttpServerRequest& Request) override; -- cgit v1.2.3 From 6c6b615e82444fbdfb4a2b8cc2ed173a1cf772b5 Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Thu, 11 Nov 2021 17:12:14 +0100 Subject: Changed from batch to RPC. --- zenserver/cache/structuredcache.h | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index 9efcc05fa..3d9914606 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -89,9 +89,9 @@ private: void HandleCachePayloadRequest(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandleGetCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); void HandlePutCachePayload(zen::HttpServerRequest& Request, const CacheRef& Ref, CachePolicy Policy); - void HandleBatchRequest(zen::HttpServerRequest& Request); - void HandleBatchGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest); - void HandleBatchGetCachePayloads(zen::HttpServerRequest& Request, CbObjectView BatchRequest); + void HandleRpcRequest(zen::HttpServerRequest& Request); + void HandleRpcGetCacheRecords(zen::HttpServerRequest& Request, CbObjectView BatchRequest); + void HandleRpcGetCachePayloads(zen::HttpServerRequest& Request, CbObjectView BatchRequest); void HandleCacheBucketRequest(zen::HttpServerRequest& Request, std::string_view Bucket); virtual void HandleStatsRequest(zen::HttpServerRequest& Request) override; virtual void HandleStatusRequest(zen::HttpServerRequest& Request) override; -- cgit v1.2.3 From 6fcd94a6dd98d2643251edf29cf078e6d8641403 Mon Sep 17 00:00:00 2001 From: Per Larsson Date: Mon, 15 Nov 2021 08:20:10 +0100 Subject: Updated cache policy according to UE. --- zenserver/cache/structuredcache.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'zenserver/cache/structuredcache.h') diff --git a/zenserver/cache/structuredcache.h b/zenserver/cache/structuredcache.h index 3d9914606..51073d05d 100644 --- a/zenserver/cache/structuredcache.h +++ b/zenserver/cache/structuredcache.h @@ -20,7 +20,7 @@ class CasStore; class CidStore; class UpstreamCache; class ZenCacheStore; -enum class CachePolicy : uint8_t; +enum class CachePolicy : uint32_t; /** * Structured cache service. Imposes constraints on keys, supports blobs and -- cgit v1.2.3