summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/executor_threading_service
diff options
context:
space:
mode:
authorGeir Storli <geirst@yahooinc.com>2022-05-16 14:26:55 +0000
committerGeir Storli <geirst@yahooinc.com>2022-05-18 09:04:38 +0000
commit3aa28e27fb35d63ce340a354bf39b41f9c304bc4 (patch)
tree4da9a0bcd199f326af589abfd2def79ae80253d6 /searchcore/src/tests/proton/documentdb/executor_threading_service
parentb116016d101c88f0649c026af382a1f735e80f50 (diff)
Move tracking of num field writer threads from ThreadingServiceConfig to SharedThreadingServiceConfig.
This is a follow-up for when the shared field writer executor is used across all document dbs.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/executor_threading_service')
-rw-r--r--searchcore/src/tests/proton/documentdb/executor_threading_service/executor_threading_service_test.cpp11
1 files changed, 3 insertions, 8 deletions
diff --git a/searchcore/src/tests/proton/documentdb/executor_threading_service/executor_threading_service_test.cpp b/searchcore/src/tests/proton/documentdb/executor_threading_service/executor_threading_service_test.cpp
index d4f4e24ba6c..bc02f460b4e 100644
--- a/searchcore/src/tests/proton/documentdb/executor_threading_service/executor_threading_service_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/executor_threading_service/executor_threading_service_test.cpp
@@ -26,16 +26,13 @@ public:
ExecutorThreadingServiceTest()
: _transport(1),
field_writer_executor(SequencedTaskExecutor::create(my_field_writer_executor, 3, 200)),
- service()
- {
- }
- void setup(uint32_t indexing_threads) {
- service = std::make_unique<ExecutorThreadingService>(_transport.shared(),
+ service(std::make_unique<ExecutorThreadingService>(_transport.shared(),
_transport.transport(),
_transport.clock(),
*field_writer_executor,
nullptr,
- ThreadingServiceConfig::make(indexing_threads));
+ ThreadingServiceConfig::make()))
+ {
}
SequencedTaskExecutor* index_inverter() {
return to_concrete_type(service->indexFieldInverter());
@@ -60,7 +57,6 @@ assert_executor(SequencedTaskExecutor* exec, uint32_t exp_executors, uint32_t ex
TEST_F(ExecutorThreadingServiceTest, shared_field_writer_specified_from_the_outside)
{
- setup(4);
EXPECT_EQ(field_writer(), index_inverter());
EXPECT_EQ(field_writer(), index_writer());
EXPECT_EQ(field_writer(), attribute_writer());
@@ -69,7 +65,6 @@ TEST_F(ExecutorThreadingServiceTest, shared_field_writer_specified_from_the_outs
TEST_F(ExecutorThreadingServiceTest, tasks_limits_can_be_updated)
{
- setup(4);
service->set_task_limits(5, 7, 11);
EXPECT_EQ(5, service->master_task_limit());
EXPECT_EQ(7, service->index().getTaskLimit());