summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-07-24 14:57:51 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2017-07-24 14:57:51 +0000
commit28cab783cf426758b4f878fcc523fddfef52eb6d (patch)
treed7e227b72c3027bec10ba6a22288c95d210ede40 /messagebus
parentda67accbf615ad94e2ff24b061798cdfcc4afec2 (diff)
make_vespa_string -> make_string.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/vespa/messagebus/error.cpp4
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcnetwork.cpp19
2 files changed, 11 insertions, 12 deletions
diff --git a/messagebus/src/vespa/messagebus/error.cpp b/messagebus/src/vespa/messagebus/error.cpp
index 5e5aed85f29..7a7785a853f 100644
--- a/messagebus/src/vespa/messagebus/error.cpp
+++ b/messagebus/src/vespa/messagebus/error.cpp
@@ -24,9 +24,9 @@ Error::toString() const
{
string name(ErrorCode::getName(_code));
if (name.empty()) {
- name = vespalib::make_vespa_string("%u", _code);
+ name = vespalib::make_string("%u", _code);
}
- return vespalib::make_vespa_string("[%s @ %s]: %s", name.c_str(),
+ return vespalib::make_string("[%s @ %s]: %s", name.c_str(),
_service.empty() ? "localhost" : _service.c_str(),
_msg.c_str());
}
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
index e5851bb3c4c..20edbd084e5 100644
--- a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
@@ -9,11 +9,14 @@
#include <vespa/slobrok/sbregister.h>
#include <vespa/slobrok/sbmirror.h>
#include <vespa/vespalib/component/vtag.h>
+#include <vespa/vespalib/util/stringfmt.h>
#include <vespa/fnet/scheduler.h>
#include <vespa/log/log.h>
LOG_SETUP(".rpcnetwork");
+using vespalib::make_string;
+
namespace {
/**
@@ -190,7 +193,7 @@ RPCNetwork::invoke(FRT_RPCRequest *req)
const string
RPCNetwork::getConnectionSpec() const
{
- return vespalib::make_vespa_string("tcp/%s:%d", _ident.getHostname().c_str(), _orb.GetListenPort());
+ return make_string("tcp/%s:%d", _ident.getHostname().c_str(), _orb.GetListenPort());
}
RPCSendAdapter *
@@ -292,13 +295,13 @@ RPCNetwork::resolveServiceAddress(RoutingNode &recipient, const string &serviceN
{
if (_oosManager.isOOS(serviceName)) {
return Error(ErrorCode::SERVICE_OOS,
- vespalib::make_vespa_string("The service '%s' has been marked as out of service.",
+ make_string("The service '%s' has been marked as out of service.",
serviceName.c_str()));
}
RPCServiceAddress::UP ret = _servicePool.resolve(serviceName);
if (ret.get() == NULL) {
return Error(ErrorCode::NO_ADDRESS_FOR_SERVICE,
- vespalib::make_vespa_string("The address of service '%s' could not be resolved. It is not currently "
+ make_string("The address of service '%s' could not be resolved. It is not currently "
"registered with the Vespa name server. "
"The service must be having problems, or the routing configuration is wrong.",
serviceName.c_str()));
@@ -306,7 +309,7 @@ RPCNetwork::resolveServiceAddress(RoutingNode &recipient, const string &serviceN
RPCTarget::SP target = _targetPool.getTarget(_orb, *ret);
if (target.get() == NULL) {
return Error(ErrorCode::CONNECTION_ERROR,
- vespalib::make_vespa_string("Failed to connect to service '%s'.",
+ make_string("Failed to connect to service '%s'.",
serviceName.c_str()));
}
ret->setTarget(target); // free by freeServiceAddress()
@@ -348,17 +351,13 @@ RPCNetwork::send(RPCNetwork::SendContext &ctx)
RPCSendAdapter *adapter = getSendAdapter(ctx._version);
if (adapter == NULL) {
replyError(ctx, ErrorCode::INCOMPATIBLE_VERSION,
- vespalib::make_vespa_string(
- "Can not send to version '%s' recipient.",
- ctx._version.toString().c_str()));
+ make_string("Can not send to version '%s' recipient.", ctx._version.toString().c_str()));
} else if (timeRemaining == 0) {
replyError(ctx, ErrorCode::TIMEOUT,
"Aborting transmission because zero time remains.");
} else if (payload.size() == 0) {
replyError(ctx, ErrorCode::ENCODE_ERROR,
- vespalib::make_vespa_string(
- "Protocol '%s' failed to encode message.",
- ctx._msg.getProtocol().c_str()));
+ make_string("Protocol '%s' failed to encode message.", ctx._msg.getProtocol().c_str()));
} else if (ctx._recipients.size() == 1) {
adapter->sendByHandover(*ctx._recipients.front(), ctx._version, std::move(payload), timeRemaining);
} else {