summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp')
-rw-r--r--searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp66
1 files changed, 0 insertions, 66 deletions
diff --git a/searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp b/searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp
deleted file mode 100644
index 658ebe818eb..00000000000
--- a/searchcore/src/tests/proton/documentdb/threading_service_config/threading_service_config_test.cpp
+++ /dev/null
@@ -1,66 +0,0 @@
-// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
-#include <vespa/log/log.h>
-LOG_SETUP("threading_service_config_test");
-
-#include <vespa/searchcore/config/config-proton.h>
-#include <vespa/searchcore/proton/common/hw_info.h>
-#include <vespa/searchcore/proton/server/threading_service_config.h>
-#include <vespa/vespalib/testkit/testapp.h>
-
-using namespace proton;
-using ProtonConfig = vespa::config::search::core::ProtonConfig;
-using ProtonConfigBuilder = vespa::config::search::core::ProtonConfigBuilder;
-
-struct Fixture {
- ProtonConfig cfg;
- Fixture(uint32_t baseLineIndexingThreads = 2)
- : cfg(makeConfig(baseLineIndexingThreads))
- {
- }
- ProtonConfig makeConfig(uint32_t baseLineIndexingThreads) {
- ProtonConfigBuilder builder;
- builder.indexing.threads = baseLineIndexingThreads;
- builder.indexing.tasklimit = 500;
- builder.indexing.semiunboundtasklimit = 50000;
- builder.feeding.concurrency = 0.5;
- return builder;
- }
- ThreadingServiceConfig make(uint32_t cpuCores) {
- return ThreadingServiceConfig::make(cfg, HwInfo::Cpu(cpuCores));
- }
- void assertIndexingThreads(uint32_t expIndexingThreads, uint32_t cpuCores) {
- EXPECT_EQUAL(expIndexingThreads, make(cpuCores).indexingThreads());
- }
-};
-
-TEST_F("require that indexing threads are set based on cpu cores and feeding concurrency", Fixture)
-{
- TEST_DO(f.assertIndexingThreads(2, 1));
- TEST_DO(f.assertIndexingThreads(2, 4));
- TEST_DO(f.assertIndexingThreads(2, 8));
- TEST_DO(f.assertIndexingThreads(2, 12));
- TEST_DO(f.assertIndexingThreads(3, 13));
- TEST_DO(f.assertIndexingThreads(3, 18));
- TEST_DO(f.assertIndexingThreads(4, 19));
- TEST_DO(f.assertIndexingThreads(4, 24));
-}
-
-TEST_F("require that indexing threads is always >= 1", Fixture(0))
-{
- TEST_DO(f.assertIndexingThreads(1, 0));
-}
-
-TEST_F("require that default task limit is set", Fixture)
-{
- EXPECT_EQUAL(500u, f.make(24).defaultTaskLimit());
-}
-
-TEST_F("require that semiunbound task limit is scaled based on indexing threads", Fixture)
-{
- EXPECT_EQUAL(12500u, f.make(24).semiUnboundTaskLimit());
-}
-
-TEST_MAIN()
-{
- TEST_RUN_ALL();
-}