SERVER-25264 Add MessageCompressorInterface and MessageCompressorRegistry

1 files changed, 11 insertions, 0 deletions

diff --git a/src/mongo/db/server_options_helpers.cpp b/src/mongo/db/server_options_helpers.cpp
index c1729324606..6956c8454f0 100644
--- a/src/mongo/db/server_options_helpers.cpp
+++ b/src/mongo/db/server_options_helpers.cpp
@@ -48,6 +48,7 @@
 #include "mongo/db/server_parameters.h"
 #include "mongo/logger/log_component.h"
 #include "mongo/logger/message_event_utf8_encoder.h"
+#include "mongo/transport/message_compressor_registry.h"
 #include "mongo/util/cmdline_utils/censor_cmdline.h"
 #include "mongo/util/log.h"
 #include "mongo/util/map_util.h"
@@ -389,6 +390,11 @@ Status addGeneralServerOptions(moe::OptionSection* options) {
         .hidden()
         .setSources(moe::SourceAllLegacy);
 
+    auto ret = addMessageCompressionOptions(options, false);
+    if (!ret.isOK()) {
+        return ret;
+    }
+
     return Status::OK();
 }
 
@@ -1038,6 +1044,11 @@ Status storeServerOptions(const moe::Environment& params, const std::vector<std:
     }
 #endif
 
+    ret = storeMessageCompressionOptions(params);
+    if (!ret.isOK()) {
+        return ret;
+    }
+
     return Status::OK();
 }