diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-03-25 15:20:53 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-03-25 15:20:53 +0000 |
commit | 020c88692058131e4009125e00ff5ca2400a2f31 (patch) | |
tree | d098c48bbe49b0c3a1373704bf966ad27c82b7f0 /messagebus | |
parent | a4f448633278360f7cb8ef2135f68291cb021a9f (diff) |
Add config control over tcpnodelay for c++ too.
Diffstat (limited to 'messagebus')
3 files changed, 10 insertions, 0 deletions
diff --git a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp index ae427a74d27..4b498c4c014 100644 --- a/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcnetwork.cpp @@ -130,6 +130,7 @@ RPCNetwork::RPCNetwork(const RPCNetworkParams ¶ms) : { _transport->SetMaxInputBufferSize(params.getMaxInputBufferSize()); _transport->SetMaxOutputBufferSize(params.getMaxOutputBufferSize()); + _transport->SetTCPNoDelay(params.getTcpNoDelay()); } RPCNetwork::~RPCNetwork() diff --git a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp index bd87e4dbbe2..5bf277a8ee6 100644 --- a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp +++ b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.cpp @@ -15,6 +15,7 @@ RPCNetworkParams::RPCNetworkParams(config::ConfigUri configUri) : _maxInputBufferSize(256*1024), _maxOutputBufferSize(256*1024), _numThreads(4), + _tcpNoDelay(true), _dispatchOnEncode(true), _dispatchOnDecode(false), _connectionExpireSecs(600), diff --git a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h index ba530257030..140f81c611c 100644 --- a/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h +++ b/messagebus/src/vespa/messagebus/network/rpcnetworkparams.h @@ -20,6 +20,7 @@ private: uint32_t _maxInputBufferSize; uint32_t _maxOutputBufferSize; uint32_t _numThreads; + bool _tcpNoDelay; bool _dispatchOnEncode; bool _dispatchOnDecode; double _connectionExpireSecs; @@ -106,6 +107,13 @@ public: uint32_t getNumThreads() const { return _numThreads; } + RPCNetworkParams &setTcpNoDelay(bool tcpNoDelay) { + _tcpNoDelay = tcpNoDelay; + return *this; + } + + bool getTcpNoDelay() const { return _tcpNoDelay; } + /** * Returns the number of seconds before an idle network connection expires. * |