diff options
author | Tor Egge <Tor.Egge@oath.com> | 2018-02-27 15:29:29 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2018-02-27 15:29:29 +0000 |
commit | e23f938a49c42bfc3326d7aaa8cc62779fcd8aa0 (patch) | |
tree | 650bffb5054f369bbf1640fd9e98a2373791f63b | |
parent | 5585355bbece4027d43ab6cc216e397d06c62c19 (diff) |
Use blocking thread stack executor for document summary writing.
-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; |