diff options
| author | Dan Engelbrecht <[email protected]> | 2022-09-13 12:07:50 +0200 |
|---|---|---|
| committer | Dan Engelbrecht <[email protected]> | 2022-09-15 12:36:45 +0200 |
| commit | 2c45799f1ddf9d14350dc1ed15eaf771c8913da1 (patch) | |
| tree | e8e9d7eac29e3a0c1e00cd1467a6507a197384c8 /zenserver-test | |
| parent | don't report cache miss as error (diff) | |
| download | zen-2c45799f1ddf9d14350dc1ed15eaf771c8913da1.tar.xz zen-2c45799f1ddf9d14350dc1ed15eaf771c8913da1.zip | |
GetCacheChunksRequest with separate policy and OptionalValueFilter
Diffstat (limited to 'zenserver-test')
| -rw-r--r-- | zenserver-test/zenserver-test.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/zenserver-test/zenserver-test.cpp b/zenserver-test/zenserver-test.cpp index 94cb80bc6..3c828b20a 100644 --- a/zenserver-test/zenserver-test.cpp +++ b/zenserver-test/zenserver-test.cpp @@ -2234,20 +2234,21 @@ TEST_CASE("zcache.rpc.allpolicies") return A.Key.Hash < B.Key.Hash; }); CachePolicy BatchDefaultPolicy = CachePolicy::Default; - cacherequests::GetCacheChunksRequest GetCacheChunksRequest = {.DefaultPolicy = BatchDefaultPolicy, - .Namespace = std::string(TestNamespace)}; + cacherequests::GetCacheChunksRequest GetCacheChunksRequest = {.Namespace = std::string(TestNamespace)}; + cacherequests::ChunksRequestPolicy GetCacheChunksPolicy = {.DefaultPolicy = BatchDefaultPolicy}; GetCacheChunksRequest.Requests.reserve(ChunkRequests.size()); + GetCacheChunksPolicy.ChunkPolicies.reserve(ChunkRequests.size()); for (CacheGetChunkRequest& ChunkRequest : ChunkRequests) { GetCacheChunksRequest.Requests.push_back({.Key = ChunkRequest.Key, .ValueId = ChunkRequest.ValueId, .ChunkId = IoHash(), .RawOffset = ChunkRequest.RawOffset, - .RawSize = ChunkRequest.RawSize, - .Policy = ChunkRequest.Policy}); + .RawSize = ChunkRequest.RawSize}); + GetCacheChunksPolicy.ChunkPolicies.push_back({ChunkRequest.Policy}); } CbPackage Package; - CHECK(GetCacheChunksRequest.Format(Package)); + CHECK(GetCacheChunksRequest.Format(Package, GetCacheChunksPolicy)); IoBuffer Body = FormatPackageMessageBuffer(Package).Flatten().AsIoBuffer(); cpr::Response Result = cpr::Post(cpr::Url{fmt::format("{}/$rpc", BaseUri)}, |