diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-12-19 16:06:16 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-12-20 05:10:52 +0000 |
commit | a00e560b0d8267e9b376e5c0e6a2139a7be63281 (patch) | |
tree | ba207915b8cac9fb92493cc103821f6cce9db31b /documentapi | |
parent | 05b58ac83b06b00ae97ecafad101e44d4dd76aee (diff) |
Remove stacksize from the thread pools and thread executors.
Diffstat (limited to 'documentapi')
-rw-r--r-- | documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp | 10 | ||||
-rw-r--r-- | documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp | 2 |
2 files changed, 7 insertions, 5 deletions
diff --git a/documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp b/documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp index 01a300badab..df035ce0831 100644 --- a/documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp +++ b/documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp @@ -13,6 +13,9 @@ #include <vespa/documentapi/messagebus/documentprotocol.h> #include <vespa/vespalib/text/stringtokenizer.h> +namespace { + VESPA_THREAD_STACK_TAG(async_init_policy); +} namespace documentapi { std::map<string, string> @@ -34,9 +37,8 @@ AsyncInitializationPolicy::parse(string parameters) { return retVal; } -AsyncInitializationPolicy::AsyncInitializationPolicy( - const std::map<string, string>&) - : _executor(new vespalib::ThreadStackExecutor(1, 1024)), +AsyncInitializationPolicy::AsyncInitializationPolicy(const std::map<string, string>&) + : _executor(std::make_unique<vespalib::ThreadStackExecutor>(1, async_init_policy)), _state(State::NOT_STARTED), _syncInit(true) { @@ -85,7 +87,7 @@ AsyncInitializationPolicy::select(mbus::RoutingContext& context) // entirely done with accessing the state of this policy (including // the mutex). After setting _state == RUNNING, only the task // is allowed to mutate _state. - _executor->execute(vespalib::Executor::Task::UP(new Task(*this))); + _executor->execute(std::make_unique<Task>(*this)); _state = State::RUNNING; } diff --git a/documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp b/documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp index 9c67b3b3ef7..0841c2ed32b 100644 --- a/documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp +++ b/documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp @@ -10,7 +10,7 @@ namespace documentapi { MirrorAndStuff::MirrorAndStuff(const slobrok::ConfiguratorFactory & config) - : _threadPool(std::make_unique<FastOS_ThreadPool>(64_Ki)), + : _threadPool(std::make_unique<FastOS_ThreadPool>()), _transport(std::make_unique<FNET_Transport>()), _orb(std::make_unique<FRT_Supervisor>(_transport.get())), _mirror(std::make_unique<slobrok::api::MirrorAPI>(*_orb, config)) |