aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/executor_threading_service
diff options
context:
space:
mode:
authorGeir Storli <geirst@yahooinc.com>2023-08-31 13:19:59 +0000
committerGeir Storli <geirst@yahooinc.com>2023-08-31 13:19:59 +0000
commit1d5c8305e80887c3bd86e7e71952565f81243018 (patch)
tree83647afbaae101c00dabb5d49dd3f258c3635a17 /searchcore/src/tests/proton/documentdb/executor_threading_service
parentc5c458f910f45b6d6c52b87e0a93c2ed17f87217 (diff)
Simplify IThreadingService as there only is one field writer executor.
Support for separate executors for "index invert", "index write", and "attribute write" was removed in 2022.
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.cpp17
1 files changed, 2 insertions, 15 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 bc02f460b4e..9bba8c12ee7 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
@@ -34,15 +34,6 @@ public:
ThreadingServiceConfig::make()))
{
}
- SequencedTaskExecutor* index_inverter() {
- return to_concrete_type(service->indexFieldInverter());
- }
- SequencedTaskExecutor* index_writer() {
- return to_concrete_type(service->indexFieldWriter());
- }
- SequencedTaskExecutor* attribute_writer() {
- return to_concrete_type(service->attributeFieldWriter());
- }
SequencedTaskExecutor* field_writer() {
return to_concrete_type(*field_writer_executor);
}
@@ -57,9 +48,7 @@ assert_executor(SequencedTaskExecutor* exec, uint32_t exp_executors, uint32_t ex
TEST_F(ExecutorThreadingServiceTest, shared_field_writer_specified_from_the_outside)
{
- EXPECT_EQ(field_writer(), index_inverter());
- EXPECT_EQ(field_writer(), index_writer());
- EXPECT_EQ(field_writer(), attribute_writer());
+ EXPECT_EQ(field_writer(), &service->field_writer());
assert_executor(field_writer(), 3, 200);
}
@@ -69,9 +58,7 @@ TEST_F(ExecutorThreadingServiceTest, tasks_limits_can_be_updated)
EXPECT_EQ(5, service->master_task_limit());
EXPECT_EQ(7, service->index().getTaskLimit());
EXPECT_EQ(11, service->summary().getTaskLimit());
- EXPECT_EQ(7, index_inverter()->first_executor()->getTaskLimit());
- EXPECT_EQ(7, index_writer()->first_executor()->getTaskLimit());
- EXPECT_EQ(7, attribute_writer()->first_executor()->getTaskLimit());
+ EXPECT_EQ(7, field_writer()->first_executor()->getTaskLimit());
}
GTEST_MAIN_RUN_ALL_TESTS()