summaryrefslogtreecommitdiffstats
path: root/searchcore/src/apps
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-07-01 11:39:33 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2022-07-01 11:39:33 +0000
commit6f06c179f2e1d27f736e659d89cd13218c810ea4 (patch)
tree19e5d14a32ce8b50d03713676959066a9f88b149 /searchcore/src/apps
parent7ac6a7c5a793e11bce08a2bac040a1860b6edce1 (diff)
Avoid using void skip thread config.
Diffstat (limited to 'searchcore/src/apps')
-rw-r--r--searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp9
-rw-r--r--searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp8
2 files changed, 0 insertions, 17 deletions
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 df0827e78c9..95c63f56bac 100644
--- a/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp
+++ b/searchcore/src/apps/vespa-feed-bm/vespa_feed_bm.cpp
@@ -21,14 +21,11 @@
#include <vespa/searchcore/bmcluster/spi_bm_feed_handler.h>
#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>
#include <iostream>
-#include <thread>
-#include <unistd.h>
#include <vespa/log/log.h>
LOG_SETUP("vespa-feed-bm");
@@ -229,7 +226,6 @@ App::usage()
"[--rpc-events-before-wakeup events]\n"
"[--rpc-network-threads threads]\n"
"[--rpc-targets-per-node targets]\n"
- "[--skip-communicationmanager-thread]\n"
"[--skip-get-spi-bucket-info]\n"
"[--update-passes update-passes]\n"
"[--use-async-message-handling]\n"
@@ -261,7 +257,6 @@ App::get_options(int argc, char **argv)
{ "rpc-events-before-wakeup", 1, nullptr, 0 },
{ "rpc-network-threads", 1, nullptr, 0 },
{ "rpc-targets-per-node", 1, nullptr, 0 },
- { "skip-communicationmanager-thread", 0, nullptr, 0 },
{ "skip-get-spi-bucket-info", 0, nullptr, 0 },
{ "update-passes", 1, nullptr, 0 },
{ "use-async-message-handling", 0, nullptr, 0 },
@@ -288,7 +283,6 @@ App::get_options(int argc, char **argv)
LONGOPT_RPC_EVENTS_BEFORE_WAKEUP,
LONGOPT_RPC_NETWORK_THREADS,
LONGOPT_RPC_TARGETS_PER_NODE,
- LONGOPT_SKIP_COMMUNICATIONMANAGER_THREAD,
LONGOPT_SKIP_GET_SPI_BUCKET_INFO,
LONGOPT_UPDATE_PASSES,
LONGOPT_USE_ASYNC_MESSAGE_HANDLING,
@@ -355,9 +349,6 @@ App::get_options(int argc, char **argv)
case LONGOPT_RPC_TARGETS_PER_NODE:
_bm_params.set_rpc_targets_per_node(atoi(optarg));
break;
- case LONGOPT_SKIP_COMMUNICATIONMANAGER_THREAD:
- _bm_params.set_skip_communicationmanager_thread(true);
- break;
case LONGOPT_SKIP_GET_SPI_BUCKET_INFO:
_bm_params.set_skip_get_spi_bucket_info(true);
break;
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 f22e817b72c..7d190a81087 100644
--- a/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp
+++ b/searchcore/src/apps/vespa-redistribute-bm/vespa_redistribute_bm.cpp
@@ -23,7 +23,6 @@
#include <vespa/searchcore/bmcluster/spi_bm_feed_handler.h>
#include <vespa/searchlib/index/dummyfileheadercontext.h>
#include <vespa/vespalib/objects/nbostream.h>
-#include <vespa/vespalib/testkit/testapp.h>
#include <vespa/vespalib/util/lambdatask.h>
#include <vespa/vespalib/util/size_literals.h>
#include <vespa/vespalib/util/threadstackexecutor.h>
@@ -31,7 +30,6 @@
#include <filesystem>
#include <iostream>
#include <thread>
-#include <unistd.h>
#include <vespa/log/log.h>
LOG_SETUP("vespa-redistribute-bm");
@@ -491,7 +489,6 @@ App::usage()
"[--rpc-network-threads threads]\n"
"[--rpc-targets-per-node targets]\n"
"[--response-threads threads]\n"
- "[--skip-communicationmanager-thread]\n"
"[--use-async-message-handling]\n"
"[--use-feed-settle]" << std::endl;
}
@@ -526,7 +523,6 @@ App::get_options(int argc, char **argv)
{ "rpc-events-before-wakeup", 1, nullptr, 0 },
{ "rpc-network-threads", 1, nullptr, 0 },
{ "rpc-targets-per-node", 1, nullptr, 0 },
- { "skip-communicationmanager-thread", 0, nullptr, 0 },
{ "use-async-message-handling", 0, nullptr, 0 },
{ "use-feed-settle", 0, nullptr, 0 },
{ nullptr, 0, nullptr, 0 }
@@ -556,7 +552,6 @@ App::get_options(int argc, char **argv)
LONGOPT_RPC_EVENTS_BEFORE_WAKEUP,
LONGOPT_RPC_NETWORK_THREADS,
LONGOPT_RPC_TARGETS_PER_NODE,
- LONGOPT_SKIP_COMMUNICATIONMANAGER_THREAD,
LONGOPT_USE_ASYNC_MESSAGE_HANDLING,
LONGOPT_USE_FEED_SETTLE
};
@@ -643,9 +638,6 @@ App::get_options(int argc, char **argv)
case LONGOPT_RPC_TARGETS_PER_NODE:
_bm_params.set_rpc_targets_per_node(atoi(optarg));
break;
- case LONGOPT_SKIP_COMMUNICATIONMANAGER_THREAD:
- _bm_params.set_skip_communicationmanager_thread(true);
- break;
case LONGOPT_USE_ASYNC_MESSAGE_HANDLING:
_bm_params.set_use_async_message_handling_on_schedule(true);
break;