diff options
Diffstat (limited to 'searchcore/src/apps')
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)) |