diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-27 17:56:43 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-05-27 17:56:43 +0000 |
commit | 6f302b2e7232fd0cec1ef4d0671740abb6b9e791 (patch) | |
tree | 26961290f0c44f71c6f0120cab6d7c66c9185800 | |
parent | b6f7fddbd829d7d6aa5cd9aff1da536b654e82cb (diff) |
admin/slobrok.0 does not always exist ....... anymore.
9 files changed, 12 insertions, 12 deletions
diff --git a/documentapi/src/vespa/documentapi/messagebus/policies/externslobrokpolicy.cpp b/documentapi/src/vespa/documentapi/messagebus/policies/externslobrokpolicy.cpp index d12a46ed3a4..f760d5ae2b4 100644 --- a/documentapi/src/vespa/documentapi/messagebus/policies/externslobrokpolicy.cpp +++ b/documentapi/src/vespa/documentapi/messagebus/policies/externslobrokpolicy.cpp @@ -21,7 +21,7 @@ ExternSlobrokPolicy::ExternSlobrokPolicy(const std::map<string, string>& param) _threadPool(std::make_unique<FastOS_ThreadPool>(1024*60)), _transport(std::make_unique<FNET_Transport>()), _orb(std::make_unique<FRT_Supervisor>(_transport.get())), - _slobrokConfigId("admin/slobrok.0") + _slobrokConfigId("client") { if (param.find("config") != param.end()) { vespalib::StringTokenizer configServers(param.find("config")->second, ","); diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java index db22363785d..e69c2e82c04 100755..100644 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCNetworkParams.java @@ -13,7 +13,7 @@ import com.yahoo.cloud.config.SlobroksConfig; public class RPCNetworkParams { private Identity identity = new Identity(""); - private String slobrokConfigId = "admin/slobrok.0"; + private String slobrokConfigId = "client"; private SlobroksConfig slobroksConfig = null; private int listenPort = 0; private int maxInputBufferSize = 256 * 1024; diff --git a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp index c90e48cb5e5..d440d3b012b 100644 --- a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp @@ -6,7 +6,7 @@ namespace mbus { RPCNetworkParams::RPCNetworkParams() - : RPCNetworkParams("admin/slobrok.0") + : RPCNetworkParams("client") { } RPCNetworkParams::RPCNetworkParams(config::ConfigUri configUri) : diff --git a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelClientTest.java b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelClientTest.java index 7c0302ae3dc..62756dbfb49 100644 --- a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelClientTest.java +++ b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelClientTest.java @@ -71,7 +71,7 @@ public class ConfigSentinelClientTest { "logserver state=RUNNING mode=AUTO pid=25018 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"admin/logserver\"\n" + "metricsproxy state=RUNNING mode=AUTO pid=13107 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"hosts/vespa19.dev.gq1.yahoo.com/metricsproxy\"\n" + "searchnode state=RUNNING mode=AUTO pid=25023 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/search/cluster.search/0\"\n" + - "slobrok state=RUNNING mode=AUTO pid=25019 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"admin/slobrok.0\"\n" + + "slobrok state=RUNNING mode=AUTO pid=25019 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"client\"\n" + "\n"; ConfigSentinelDummy configsentinel = new ConfigSentinelDummy(response); diff --git a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelDummy.java b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelDummy.java index def57617f56..19088e8fd4f 100644 --- a/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelDummy.java +++ b/metrics-proxy/src/test/java/ai/vespa/metricsproxy/service/ConfigSentinelDummy.java @@ -17,7 +17,7 @@ public class ConfigSentinelDummy { + "searchnode2 state=RUNNING mode=AUTO pid=6527 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c0/r1\"\n" + "clustercontroller2 state=RUNNING mode=AUTO pid=6523 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/rtx/1\"\n" + "clustercontroller state=RUNNING mode=AUTO pid=6522 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/rtx/0\"\n" - + "slobrok state=RUNNING mode=AUTO pid=6519 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"admin/slobrok.0\"\n" + + "slobrok state=RUNNING mode=AUTO pid=6519 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"client\"\n" + "searchnode3 state=RUNNING mode=AUTO pid=6529 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c1/r0\"\n" + "searchnode state=RUNNING mode=AUTO pid=6526 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c0/r0\"\n" + "qrserver state=RUNNING mode=AUTO pid=6520 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"container/qrserver.0\"\n" @@ -43,7 +43,7 @@ public class ConfigSentinelDummy { + "searchnode2 state=RUNNING mode=AUTO pid=6527 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c0/r1\"\n" + "clustercontroller2 state=RUNNING mode=AUTO pid=6523 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/rtx/1\"\n" + "clustercontroller state=RUNNING mode=AUTO pid=6522 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/rtx/0\"\n" - + "slobrok state=RUNNING mode=AUTO pid=6519 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"admin/slobrok.0\"\n" + + "slobrok state=RUNNING mode=AUTO pid=6519 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"client\"\n" + "searchnode3 state=RUNNING mode=AUTO pid=6529 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c1/r0\"\n" + "searchnode state=RUNNING mode=AUTO pid=6526 exitstatus=0 autostart=TRUE autorestart=TRUE id=\"search/cluster.x/g0/c0/r0\"\n" + "\n"; diff --git a/searchcore/src/apps/vespa-proton-cmd/vespa-proton-cmd.cpp b/searchcore/src/apps/vespa-proton-cmd/vespa-proton-cmd.cpp index 50a2aecce76..2ba3960dd1d 100644 --- a/searchcore/src/apps/vespa-proton-cmd/vespa-proton-cmd.cpp +++ b/searchcore/src/apps/vespa-proton-cmd/vespa-proton-cmd.cpp @@ -118,7 +118,7 @@ public: std::string rtcPattern3 = "*/search/*/realtimecontroller"; try { - slobrok::ConfiguratorFactory sbcfg("admin/slobrok.0"); + slobrok::ConfiguratorFactory sbcfg("client"); slobrok::api::MirrorAPI sbmirror(_frt->supervisor(), sbcfg); for (int timeout = 1; timeout < 20; timeout++) { if (!sbmirror.ready()) { @@ -170,7 +170,7 @@ public: std::string rtcPattern = "search/cluster.*/c*/r*/realtimecontroller"; try { - slobrok::ConfiguratorFactory sbcfg("admin/slobrok.0"); + slobrok::ConfiguratorFactory sbcfg("client"); slobrok::api::MirrorAPI sbmirror(_frt->supervisor(), sbcfg); for (int timeout = 1; timeout < 20; timeout++) { if (!sbmirror.ready()) { diff --git a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp index 62109eda98d..9d78b1a0399 100644 --- a/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/rpc_hooks.cpp @@ -180,7 +180,7 @@ RPCHooksBase::initRPC() RPCHooksBase::Params::Params(Proton &parent, uint32_t port, const vespalib::string &ident, uint32_t transportThreads, uint32_t executorThreads) : proton(parent), - slobrok_config(config::ConfigUri("admin/slobrok.0")), + slobrok_config(config::ConfigUri("client")), identity(ident), rtcPort(port), numTranportThreads(transportThreads), diff --git a/storage/src/vespa/storage/tools/storage-cmd.cpp b/storage/src/vespa/storage/tools/storage-cmd.cpp index 00ee2c9c4cf..472d87c4f9d 100644 --- a/storage/src/vespa/storage/tools/storage-cmd.cpp +++ b/storage/src/vespa/storage/tools/storage-cmd.cpp @@ -61,7 +61,7 @@ public: int retCode = 0; fnet::frt::StandaloneFRT supervisor; - slobrok::ConfiguratorFactory sbcfg("admin/slobrok.0"); + slobrok::ConfiguratorFactory sbcfg("client"); slobrok::api::MirrorAPI mirror(supervisor.supervisor(), sbcfg); while (!mirror.ready()) { diff --git a/vespaclient/src/vespa/vespaclient/vdsstates/statesapp.cpp b/vespaclient/src/vespa/vespaclient/vdsstates/statesapp.cpp index a468dd98698..833a4eb5468 100644 --- a/vespaclient/src/vespa/vespaclient/vdsstates/statesapp.cpp +++ b/vespaclient/src/vespa/vespaclient/vdsstates/statesapp.cpp @@ -209,8 +209,8 @@ Options::Options(Mode mode) } addOptionHeader("Advanced options. Not needed for most usecases"); addOption("l slobrokconfig", _slobrokConfigId, - std::string("admin/slobrok.0"), - "Config id of slobrok. Will use the default config id of admin/slobrok.0 if not specified."); + std::string("client"), + "Config id of slobrok. Will use the default config id of client if not specified."); addOption("p slobrokspec", _slobrokConnectionSpec, std::string(""), "Slobrok connection spec. By setting this, this application " "will not need config at all, but will use the given " |