aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-07-02 07:59:16 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-07-02 08:02:21 +0000
commitb9e8bce0a6fa021f595c17e1d55d025417593b0a (patch)
tree60fdedd5578b4632803dd29d49e7ba07d07275aa /messagebus
parentf61b968e55f500ea94db364673d73f187aab45e4 (diff)
- Control tcp-no-delay explicit.
- Wire in configuration of number of rpc targets.
Diffstat (limited to 'messagebus')
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp1
-rw-r--r--messagebus/src/vespa/messagebus/network/rpcnetworkparams.h8
2 files changed, 9 insertions, 0 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp
index ed104dc6cd5..59802167c34 100644
--- a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp
+++ b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp
@@ -17,6 +17,7 @@ RPCNetworkParams::RPCNetworkParams(config::ConfigUri configUri) :
_maxOutputBufferSize(256_Ki),
_numThreads(4),
_numNetworkThreads(1),
+ _numRpcTargets(1),
_tcpNoDelay(true),
_dispatchOnEncode(true),
_dispatchOnDecode(false),
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h
index 193bc013c0a..37739ee5189 100644
--- a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h
+++ b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h
@@ -21,6 +21,7 @@ private:
uint32_t _maxOutputBufferSize;
uint32_t _numThreads;
uint32_t _numNetworkThreads;
+ uint32_t _numRpcTargets;
bool _tcpNoDelay;
bool _dispatchOnEncode;
bool _dispatchOnDecode;
@@ -47,6 +48,13 @@ public:
uint32_t getNumNetworkThreads() const { return _numNetworkThreads; }
+ RPCNetworkParams &setNumRpcTargets(uint32_t numRpcTargets) {
+ _numRpcTargets = numRpcTargets;
+ return *this;
+ }
+
+ uint32_t getNumRpcTargets() const { return _numRpcTargets; }
+
/**
* Returns the identity to use for the network.
*