diff options
Diffstat (limited to 'searchcore')
3 files changed, 6 insertions, 14 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/documentdb.cpp b/searchcore/src/vespa/searchcore/proton/server/documentdb.cpp index 1b2cc18708c..39d902ebfc2 100644 --- a/searchcore/src/vespa/searchcore/proton/server/documentdb.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/documentdb.cpp @@ -168,7 +168,7 @@ DocumentDB::DocumentDB(const vespalib::string &baseDir, fastos::TimeStamp visibilityDelay = loaded_config->getMaintenanceConfigSP()->getVisibilityDelay(); _visibility.setVisibilityDelay(visibilityDelay); if (_visibility.getVisibilityDelay() > 0) { - _writeService.setTaskLimit(_writeServiceConfig.semiUnboundTaskLimit()); + _writeService.setTaskLimit(_writeServiceConfig.semiUnboundTaskLimit(), _writeServiceConfig.defaultTaskLimit()); } } @@ -413,9 +413,9 @@ DocumentDB::applyConfig(DocumentDBConfig::SP configSnapshot, SerialNum serialNum _visibility.setVisibilityDelay(visibilityDelay); } if (_visibility.getVisibilityDelay() > 0) { - _writeService.setTaskLimit(_writeServiceConfig.semiUnboundTaskLimit()); + _writeService.setTaskLimit(_writeServiceConfig.semiUnboundTaskLimit(), _writeServiceConfig.defaultTaskLimit()); } else { - _writeService.setTaskLimit(_writeServiceConfig.defaultTaskLimit()); + _writeService.setTaskLimit(_writeServiceConfig.defaultTaskLimit(), _writeServiceConfig.defaultTaskLimit()); } if (params.shouldSubDbsChange() || hasVisibilityDelayChanged) { applySubDBConfig(*configSnapshot, serialNum, params); diff --git a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp index bcb5190081c..52a401a9e35 100644 --- a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.cpp @@ -59,20 +59,14 @@ ExecutorThreadingService::shutdown() } void -ExecutorThreadingService::setTaskLimit(uint32_t taskLimit) +ExecutorThreadingService::setTaskLimit(uint32_t taskLimit, uint32_t summaryTaskLimit) { _indexExecutor.setTaskLimit(taskLimit); - _summaryExecutor.setTaskLimit(taskLimit); + _summaryExecutor.setTaskLimit(summaryTaskLimit); _indexFieldInverter.setTaskLimit(taskLimit); _indexFieldWriter.setTaskLimit(taskLimit); _attributeFieldWriter.setTaskLimit(taskLimit); } -void -ExecutorThreadingService::setUnboundTaskLimit() -{ - setTaskLimit(std::numeric_limits<uint32_t>::max()); -} - } // namespace proton diff --git a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h index 1daba7d7960..2e9eecf8fea 100644 --- a/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h +++ b/searchcore/src/vespa/searchcore/proton/server/executorthreadingservice.h @@ -45,9 +45,7 @@ public: void shutdown(); - void setTaskLimit(uint32_t taskLimit); - - void setUnboundTaskLimit(); + void setTaskLimit(uint32_t taskLimit, uint32_t summaryTaskLimit); // Expose the underlying executors for stats fetching and testing. vespalib::ThreadStackExecutorBase &getMasterExecutor() { |