summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2018-02-27 15:29:29 +0000
committerTor Egge <Tor.Egge@oath.com>2018-02-27 15:29:29 +0000
commite23f938a49c42bfc3326d7aaa8cc62779fcd8aa0 (patch)
tree650bffb5054f369bbf1640fd9e98a2373791f63b
parent5585355bbece4027d43ab6cc216e397d06c62c19 (diff)
Use blocking thread stack executor for document summary writing.
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp3
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h2
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;