summaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-26 15:27:25 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-09-26 15:27:25 +0200
commita4f2e431feb8090a33981cd7a2c49137a06d38ef (patch)
tree8846f2c7b0dfd9c25acb673eb033002aeb4f161b /messagebus
parentfc1b0fd518fe5e37757690ce05e26fb4025d0059 (diff)
Start with 4 threads. Also mention all captures instead of &
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcnetwork.cpp2
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcsend.cpp2
2 files changed, 2 insertions, 2 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
index 95f3679f45c..c977d0d2773 100644
--- a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp
@@ -120,7 +120,7 @@ RPCNetwork::RPCNetwork(const RPCNetworkParams &params) :
_regAPI(std::make_unique<slobrok::api::RegisterAPI>(*_orb, *_slobrokCfgFactory)),
_oosManager(std::make_unique<OOSManager>(*_orb, *_mirror, params.getOOSServerPattern())),
_requestedPort(params.getListenPort()),
- _executor(std::make_unique<vespalib::ThreadStackExecutor>(8,65536)),
+ _executor(std::make_unique<vespalib::ThreadStackExecutor>(4,65536)),
_sendV1(std::make_unique<RPCSendV1>()),
_sendV2(std::make_unique<RPCSendV2>()),
_sendAdapters(),
diff --git a/messagebus/src/vespa/messagebus/network/rpcsend.cpp b/messagebus/src/vespa/messagebus/network/rpcsend.cpp
index f47855340cf..35a0005712b 100644
--- a/messagebus/src/vespa/messagebus/network/rpcsend.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcsend.cpp
@@ -237,7 +237,7 @@ void
RPCSend::invoke(FRT_RPCRequest *req)
{
req->Detach();
- _net->getExecutor().execute(vespalib::makeLambdaTask([&, req]() { doRequest(req);}));
+ _net->getExecutor().execute(vespalib::makeLambdaTask([this, req]() { doRequest(req);}));
}
void