diff options
author | Geir Storli <geirst@yahooinc.com> | 2022-05-16 14:26:55 +0000 |
---|---|---|
committer | Geir Storli <geirst@yahooinc.com> | 2022-05-18 09:04:38 +0000 |
commit | 3aa28e27fb35d63ce340a354bf39b41f9c304bc4 (patch) | |
tree | 4da9a0bcd199f326af589abfd2def79ae80253d6 /searchcore/src/tests/proton/documentdb/executor_threading_service | |
parent | b116016d101c88f0649c026af382a1f735e80f50 (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.cpp | 11 |
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()); |