summaryrefslogtreecommitdiffstats
path: root/messagebus/src
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-19 19:06:42 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-19 19:06:42 +0200
commit1f8bac86043733a0d875a0c1ab1f028588972aeb (patch)
tree6be6d1315d66c9d5985e03188917ba6b3705803a /messagebus/src
parentea4ba360e06c8470b8608b238242fef7043283d7 (diff)
Follow up on @havardpe comments.
Diffstat (limited to 'messagebus/src')
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcnetwork.cpp2
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcsend.cpp3
2 files changed, 3 insertions, 2 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
index 55848e32d76..4b4b23a75db 100644
--- a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
@@ -109,7 +109,7 @@ RPCNetwork::RPCNetwork(const RPCNetworkParams &params) :
_ident(params.getIdentity()),
_threadPool(std::make_unique<FastOS_ThreadPool>(128000, 0)),
_transport(std::make_unique<FNET_Transport>()),
- _orb(std::make_unique<FRT_Supervisor>(_transport.get(), _threadPool.get())),
+ _orb(std::make_unique<FRT_Supervisor>(_transport.get(), nullptr)),
_scheduler(*_transport->GetScheduler()),
_targetPool(std::make_unique<RPCTargetPool>(params.getConnectionExpireSecs())),
_targetPoolTask(_scheduler, *_targetPool),
diff --git a/messagebus/src/vespa/messagebus/network/rpcsend.cpp b/messagebus/src/vespa/messagebus/network/rpcsend.cpp
index 56c23997c4c..705b8648442 100644
--- a/messagebus/src/vespa/messagebus/network/rpcsend.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcsend.cpp
@@ -41,7 +41,8 @@ class FillByHandover final : public PayLoadFiller
public:
FillByHandover(Blob payload) : _payload(std::move(payload)) { }
void fill(FRT_Values & v) const override {
- v.AddData(std::move(_payload.payload()), _payload.size());
+ size_t sz = _payload.size();
+ v.AddData(std::move(_payload.payload()), sz);
}
void fill(const vespalib::Memory & name, vespalib::slime::Cursor & v) const override {
v.setData(name, vespalib::Memory(_payload.data(), _payload.size()));