- Use C++11 for loops.

- Detangle some includes and include what you need.
- Refactor to subclass to avoid code duplication.
- Add config for compression too.
- V1 up to 142, V2 above.

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>(