diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-19 19:06:42 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-09-19 19:06:42 +0200 |
commit | 1f8bac86043733a0d875a0c1ab1f028588972aeb (patch) | |
tree | 6be6d1315d66c9d5985e03188917ba6b3705803a /messagebus/src | |
parent | ea4ba360e06c8470b8608b238242fef7043283d7 (diff) |
Follow up on @havardpe comments.
Diffstat (limited to 'messagebus/src')
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcnetwork.cpp | 2 | ||||
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcsend.cpp | 3 |
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 ¶ms) : _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())); |