aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-19 19:34:23 +0200
committerGitHub <noreply@github.com>2017-09-19 19:34:23 +0200
commitff6ea0bf5b34b906d3008bd1ca6560967c91f561 (patch)
tree5af4cbac9f0c5597d996758f626a2e1cda96193b /vespaclient
parentb853bd3dbe033da6b3fa141f8a84b38f45c78e76 (diff)
parent1f8bac86043733a0d875a0c1ab1f028588972aeb (diff)
Merge pull request #3238 from vespa-engine/balder/mbus-transported-with-slime-2
- Use C++11 for loops.
Diffstat (limited to 'vespaclient')
-rw-r--r--vespaclient/src/vespa/vespaclient/vesparoute/application.cpp9
1 files changed, 5 insertions, 4 deletions
diff --git a/vespaclient/src/vespa/vespaclient/vesparoute/application.cpp b/vespaclient/src/vespa/vespaclient/vesparoute/application.cpp
index 1a518b4c819..fe4600aea58 100644
--- a/vespaclient/src/vespa/vespaclient/vesparoute/application.cpp
+++ b/vespaclient/src/vespa/vespaclient/vesparoute/application.cpp
@@ -4,16 +4,18 @@
#include <vespa/document/config/config-documenttypes.h>
#include <vespa/document/repo/documenttyperepo.h>
-#include <vespa/document/util/stringutil.h>
#include <vespa/documentapi/messagebus/documentprotocol.h>
#include <vespa/messagebus/configagent.h>
#include <vespa/messagebus/routing/routingtable.h>
#include <vespa/messagebus/routing/routedirective.h>
#include <vespa/messagebus/rpcmessagebus.h>
+#include <vespa/messagebus/network/rpcsendv1.h>
+#include <vespa/messagebus/network/rpcsendv2.h>
#include <vespa/slobrok/sbmirror.h>
#include <vespa/config/common/exceptions.h>
#include <vespa/config/helper/configgetter.hpp>
#include <vespa/vespalib/util/stringfmt.h>
+#include <vespa/fnet/frt/supervisor.h>
using config::ConfigGetter;
using document::DocumenttypesConfig;
@@ -528,9 +530,8 @@ Application::isService(FRT_Supervisor &frt, const std::string &spec) const
FRT_StringValue *retList = req->GetReturn()->GetValue(2)._string_array._pt;
for (uint32_t i = 0; i < numMethods; ++i) {
- if (strcmp(methods[i]._str, mbus::RPCSendV1::METHOD_NAME) == 0 &&
- strcmp(argList[i]._str, mbus::RPCSendV1::METHOD_PARAMS) == 0 &&
- strcmp(retList[i]._str, mbus::RPCSendV1::METHOD_RETURN) == 0) {
+ if (mbus::RPCSendV1::isCompatible(methods[i]._str,argList[i]._str, retList[i]._str) ||
+ mbus::RPCSendV2::isCompatible(methods[i]._str,argList[i]._str, retList[i]._str)) {
ret = true;
break;
}