summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-09-19 19:34:23 +0200
committerGitHub <noreply@github.com>2017-09-19 19:34:23 +0200
commitff6ea0bf5b34b906d3008bd1ca6560967c91f561 (patch)
tree5af4cbac9f0c5597d996758f626a2e1cda96193b /storage
parentb853bd3dbe033da6b3fa141f8a84b38f45c78e76 (diff)
parent1f8bac86043733a0d875a0c1ab1f028588972aeb (diff)
Merge pull request #3238 from vespa-engine/balder/mbus-transported-with-slime-2
- Use C++11 for loops.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/storageserver/communicationmanager.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/storage/src/vespa/storage/storageserver/communicationmanager.cpp b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
index ae8f3290fef..c90b18038c2 100644
--- a/storage/src/vespa/storage/storageserver/communicationmanager.cpp
+++ b/storage/src/vespa/storage/storageserver/communicationmanager.cpp
@@ -404,6 +404,11 @@ void CommunicationManager::configure(std::unique_ptr<CommunicationManagerConfig>
params.setListenPort(config->mbusport);
}
+ using CompressionConfig = vespalib::compression::CompressionConfig;
+ CompressionConfig::Type compressionType = CompressionConfig::toType(
+ CommunicationManagerConfig::Mbus::Compress::getTypeName(config->mbus.compress.type).c_str());
+ params.setCompressionConfig(CompressionConfig(compressionType, config->mbus.compress.level,
+ 90, config->mbus.compress.limit));
// Configure messagebus here as we for legacy reasons have
// config here.
_mbus = std::make_unique<mbus::RPCMessageBus>(