From d5b2a263e6d4c893c6ec3fb99b36110630da6529 Mon Sep 17 00:00:00 2001 From: Dan Engelbrecht Date: Mon, 6 Oct 2025 10:18:49 +0200 Subject: speed up tests (#555) * faster FileSystemTraversal test * faster jobqueue test * faster NamedEvent test * faster cache tests * faster basic http tests * faster blockstore test * faster cache store tests * faster compactcas tests * more responsive zenserver launch * tweak worker pool sizes in tests --- src/zenserver-test/cache-tests.cpp | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) (limited to 'src/zenserver-test/cache-tests.cpp') diff --git a/src/zenserver-test/cache-tests.cpp b/src/zenserver-test/cache-tests.cpp index 2a040936c..1ce5f3be4 100644 --- a/src/zenserver-test/cache-tests.cpp +++ b/src/zenserver-test/cache-tests.cpp @@ -690,9 +690,9 @@ TEST_CASE("zcache.rpc") CbPackage Package; CHECK(Request.Format(Package)); - IoBuffer Body = FormatPackageMessageBuffer(Package).Flatten().AsIoBuffer(); - Body.SetContentType(HttpContentType::kCbPackage); - HttpClient::Response Result = Http.Post("/$rpc", Body, {{"Accept", "application/x-ue-cbpkg"}}); + CompositeBuffer Body(FormatPackageMessageBuffer(Package)); + HttpClient::Response Result = + Http.Post("/$rpc", Body, HttpContentType::kCbPackage, HttpClient::Accept(HttpContentType::kCbPackage)); CHECK(Result.StatusCode == HttpResponseCode::OK); if (OutPackages) @@ -762,7 +762,7 @@ TEST_CASE("zcache.rpc") const std::string BaseUri = fmt::format("http://localhost:{}/z$", BasePort); CachePolicy Policy = CachePolicy::Default; - std::vector Keys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 128); + std::vector Keys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 16); GetCacheRecordResult Result = GetCacheRecords(BaseUri, "ue4.ddc"sv, Keys, Policy); CHECK(Result.Result.Results.size() == Keys.size()); @@ -791,7 +791,7 @@ TEST_CASE("zcache.rpc") const std::string BaseUri = fmt::format("http://localhost:{}/z$", BasePort); CachePolicy Policy = CachePolicy::Default; - std::vector ExistingKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 128); + std::vector ExistingKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 16); std::vector Keys; for (const zen::CacheKey& Key : ExistingKeys) @@ -1244,7 +1244,7 @@ TEST_CASE("zcache.rpc") const std::string BaseUri = fmt::format("http://localhost:{}/z$", BasePort); std::vector SmallKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 4, 1024); - std::vector LargeKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 4, 1024 * 1024 * 16, SmallKeys.size()); + std::vector LargeKeys = PutCacheRecords(BaseUri, "ue4.ddc"sv, "mastodon"sv, 2, 1024 * 1024 * 16, SmallKeys.size()); std::vector Keys(SmallKeys.begin(), SmallKeys.end()); Keys.insert(Keys.end(), LargeKeys.begin(), LargeKeys.end()); @@ -1540,7 +1540,7 @@ TEST_CASE("zcache.failing.upstream") } Completed.fetch_add(1); }, - WorkerThreadPool::EMode::EnableBacklog); + WorkerThreadPool::EMode::DisableBacklog); } bool UseUpstream1 = false; while (Completed < ThreadCount * KeyMultiplier) @@ -1634,7 +1634,7 @@ TEST_CASE("zcache.failing.upstream") } Completed.fetch_add(1); }, - WorkerThreadPool::EMode::EnableBacklog); + WorkerThreadPool::EMode::DisableBacklog); } while (Completed < ThreadCount * KeyMultiplier) { -- cgit v1.2.3