aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/apps
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 /searchcore/src/apps
parent05b58ac83b06b00ae97ecafad101e44d4dd76aee (diff)
Remove stacksize from the thread pools and thread executors.
Diffstat (limited to 'searchcore/src/apps')
-rw-r--r--searchcore/src/apps/proton/proton.cpp2
-rw-r--r--searchcore/src/apps/tests/persistenceconformance_test.cpp5
-rw-r--r--searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp2
-rw-r--r--searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp12
-rw-r--r--searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp2
5 files changed, 10 insertions, 13 deletions
diff --git a/searchcore/src/apps/proton/proton.cpp b/searchcore/src/apps/proton/proton.cpp
index 60b64dd9ad8..8468487995a 100644
--- a/searchcore/src/apps/proton/proton.cpp
+++ b/searchcore/src/apps/proton/proton.cpp
@@ -283,7 +283,7 @@ App::main(int argc, char **argv)
try {
setupSignals();
setup_fadvise();
- FastOS_ThreadPool threadPool(128_Ki);
+ FastOS_ThreadPool threadPool;
Transport transport(buildTransportConfig(), threadPool);
startAndRun(threadPool, transport.transport(), argc, argv);
} catch (const vespalib::InvalidCommandLineArgumentsException &e) {
diff --git a/searchcore/src/apps/tests/persistenceconformance_test.cpp b/searchcore/src/apps/tests/persistenceconformance_test.cpp
index 52e2a314fd2..fad09101d95 100644
--- a/searchcore/src/apps/tests/persistenceconformance_test.cpp
+++ b/searchcore/src/apps/tests/persistenceconformance_test.cpp
@@ -34,7 +34,6 @@
#include <vespa/document/config/documenttypes_config_fwd.h>
#include <vespa/document/repo/documenttyperepo.h>
#include <vespa/document/test/make_bucket_space.h>
-#include <vespa/vespalib/util/size_literals.h>
#include <filesystem>
#include <vespa/log/log.h>
@@ -203,7 +202,7 @@ public:
_shared_service, _tls, _metricsWireService,
_fileHeaderContext, std::make_shared<search::attribute::Interlock>(),
_config_stores.getConfigStore(docType.toString()),
- std::make_shared<vespalib::ThreadStackExecutor>(16, 128_Ki), HwInfo());
+ std::make_shared<vespalib::ThreadStackExecutor>(16), HwInfo());
}
};
@@ -214,7 +213,7 @@ DocumentDBFactory::DocumentDBFactory(const vespalib::string &baseDir, int tlsLis
_tlsSpec(vespalib::make_string("tcp/localhost:%d", tlsListenPort)),
_queryLimiter(),
_metricsWireService(),
- _summaryExecutor(8, 128_Ki),
+ _summaryExecutor(8),
_shared_service(_summaryExecutor, _summaryExecutor),
_tls(_shared_service.transport(), "tls", tlsListenPort, baseDir, _fileHeaderContext)
{}
diff --git a/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp b/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp
index 95c63f56bac..8777f5c2410 100644
--- a/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp
+++ b/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp
@@ -158,7 +158,7 @@ void
Benchmark::run()
{
_cluster->start(_feed);
- vespalib::ThreadStackExecutor executor(_params.get_client_threads(), 128_Ki);
+ vespalib::ThreadStackExecutor executor(_params.get_client_threads());
BmFeeder feeder(_repo, *_cluster->get_feed_handler(), executor);
auto put_feed = _feed.make_feed(executor, _params, [this](BmRange range, BucketSelector bucket_selector) { return _feed.make_put_feed(range, bucket_selector); }, _feed.num_buckets(), "put");
auto update_feed = _feed.make_feed(executor, _params, [this](BmRange range, BucketSelector bucket_selector) { return _feed.make_update_feed(range, bucket_selector); }, _feed.num_buckets(), "update");
diff --git a/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp b/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp
index 7d190a81087..4a408edcdd9 100644
--- a/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp
+++ b/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp
@@ -24,7 +24,6 @@
#include <vespa/searchlib/index/dummyfileheadercontext.h>
#include <vespa/vespalib/objects/nbostream.h>
#include <vespa/vespalib/util/lambdatask.h>
-#include <vespa/vespalib/util/size_literals.h>
#include <vespa/vespalib/util/threadstackexecutor.h>
#include <getopt.h>
#include <filesystem>
@@ -209,16 +208,15 @@ public:
};
ReFeed::ReFeed(const BMParams& params, std::shared_ptr<const DocumentTypeRepo> repo, IBmFeedHandler& feed_handler, int64_t& time_bias, const std::vector<vespalib::nbostream>& feed, const vespalib::string& op_name)
- : _top_executor(1, 128_Ki),
- _executor(params.get_client_threads(), 128_Ki),
+ : _top_executor(1),
+ _executor(params.get_client_threads()),
_feeder(repo, feed_handler, _executor),
_op_name(op_name),
_params(params),
_time_bias(time_bias),
_feed(feed)
{
- _top_executor.execute(makeLambdaTask([this]()
- { run(); }));
+ _top_executor.execute(makeLambdaTask([this]() { run(); }));
}
ReFeed::~ReFeed()
@@ -355,7 +353,7 @@ Benchmark::adjust_cluster_state_after_first_redistribution()
void
Benchmark::make_feed()
{
- vespalib::ThreadStackExecutor executor(_params.get_client_threads(), 128_Ki);
+ vespalib::ThreadStackExecutor executor(_params.get_client_threads());
_put_feed = _feed.make_feed(executor, _params, [this](BmRange range, BucketSelector bucket_selector) { return _feed.make_put_feed(range, bucket_selector); }, _feed.num_buckets(), "put");
if (_params.get_refeed_mode() == ReFeedMode::UPDATE) {
_update_feed = _feed.make_feed(executor, _params, [this](BmRange range, BucketSelector bucket_selector) { return _feed.make_update_feed(range, bucket_selector); }, _feed.num_buckets(), "update");
@@ -365,7 +363,7 @@ Benchmark::make_feed()
void
Benchmark::feed()
{
- vespalib::ThreadStackExecutor executor(_params.get_client_threads(), 128_Ki);
+ vespalib::ThreadStackExecutor executor(_params.get_client_threads());
BmFeeder feeder(_repo, *_cluster->get_feed_handler(), executor);
BmNodeStatsReporter reporter(*_cluster, false);
reporter.start(500ms);
diff --git a/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp b/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
index 711191125da..749ca2fab80 100644
--- a/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
+++ b/searchcore/src/apps/vespa-transactionlog-inspect/vespa-transactionlog-inspect.cpp
@@ -387,7 +387,7 @@ public:
BaseUtility(const BaseOptions &bopts)
: _bopts(bopts),
_fileHeader(),
- _threadPool(64_Ki),
+ _threadPool(),
_transport(),
_server(_transport, _bopts.tlsName, _bopts.listenPort, _bopts.tlsDir, _fileHeader),
_client(_transport, vespalib::make_string("tcp/localhost:%d", _bopts.listenPort))