aboutsummaryrefslogtreecommitdiffstats
path: root/documentapi
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-12-19 16:06:16 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-12-20 05:10:52 +0000
commita00e560b0d8267e9b376e5c0e6a2139a7be63281 (patch)
treeba207915b8cac9fb92493cc103821f6cce9db31b /documentapi
parent05b58ac83b06b00ae97ecafad101e44d4dd76aee (diff)
Remove stacksize from the thread pools and thread executors.
Diffstat (limited to 'documentapi')
-rw-r--r--documentapi/src/vespa/documentapi/messagebus/policies/asyncinitializationpolicy.cpp10
-rw-r--r--documentapi/src/vespa/documentapi/messagebus/policies/mirror_with_all.cpp2
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))