diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-07-02 07:59:16 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-07-02 08:02:21 +0000 |
commit | b9e8bce0a6fa021f595c17e1d55d025417593b0a (patch) | |
tree | 60fdedd5578b4632803dd29d49e7ba07d07275aa /messagebus | |
parent | f61b968e55f500ea94db364673d73f187aab45e4 (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.cpp | 1 | ||||
-rw-r--r-- | messagebus/src/vespa/messagebus/network/rpcnetworkparams.h | 8 |
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. * |