diff options
| -rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp | 3 | ||||
| -rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h | 2 |
2 files changed, 3 insertions, 2 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp index a5523083df7..bcb5190081c 100644 --- a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp @@ -13,7 +13,7 @@ ExecutorThreadingService::ExecutorThreadingService(uint32_t threads, : _masterExecutor(1, stackSize), _indexExecutor(1, stackSize, taskLimit), - _summaryExecutor(1, stackSize), + _summaryExecutor(1, stackSize, taskLimit), _masterService(_masterExecutor), _indexService(_indexExecutor), _summaryService(_summaryExecutor), @@ -62,6 +62,7 @@ void ExecutorThreadingService::setTaskLimit(uint32_t taskLimit) { _indexExecutor.setTaskLimit(taskLimit); + _summaryExecutor.setTaskLimit(taskLimit); _indexFieldInverter.setTaskLimit(taskLimit); _indexFieldWriter.setTaskLimit(taskLimit); _attributeFieldWriter.setTaskLimit(taskLimit); diff --git a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h index 2328702e147..1daba7d7960 100644 --- a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h +++ b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h @@ -18,7 +18,7 @@ class ExecutorThreadingService : public searchcorespi::index::IThreadingService private: vespalib::ThreadStackExecutor _masterExecutor; vespalib::BlockingThreadStackExecutor _indexExecutor; - vespalib::ThreadStackExecutor _summaryExecutor; + vespalib::BlockingThreadStackExecutor _summaryExecutor; ExecutorThreadService _masterService; ExecutorThreadService _indexService; ExecutorThreadService _summaryService; |