SERVER-32519 Add a new wire version for v3.8

2 files changed, 11 insertions, 1 deletions

diff --git a/src/mongo/rpc/protocol.cpp b/src/mongo/rpc/protocol.cpp
index ada7e8f2cee..fe0f9cebfcc 100644
--- a/src/mongo/rpc/protocol.cpp
+++ b/src/mongo/rpc/protocol.cpp
@@ -181,7 +181,7 @@ ProtocolSet computeProtocolSet(const WireVersionInfo version) {
             result |= supports::kOpMsgOnly;
         }
         if (version.maxWireVersion >= WireVersion::FIND_COMMAND &&
-            version.maxWireVersion <= WireVersion::SUPPORTS_OP_MSG) {
+            version.maxWireVersion <= WireVersion::REPLICA_SET_TRANSACTIONS) {
             // Future versions may remove support for OP_COMMAND.
             result |= supports::kOpCommandOnly;
         }
diff --git a/src/mongo/rpc/protocol_test.cpp b/src/mongo/rpc/protocol_test.cpp
index f3f8ba51f97..1781d9fab2c 100644
--- a/src/mongo/rpc/protocol_test.cpp
+++ b/src/mongo/rpc/protocol_test.cpp
@@ -71,6 +71,16 @@ TEST(Protocol, FailedNegotiation) {
 
 TEST(Protocol, parseProtocolSetFromIsMasterReply) {
     {
+        // MongoDB 3.8
+        auto mongod38 =
+            BSON("maxWireVersion" << static_cast<int>(WireVersion::REPLICA_SET_TRANSACTIONS)
+                                  << "minWireVersion"
+                                  << static_cast<int>(WireVersion::RELEASE_2_4_AND_BEFORE));
+
+        ASSERT_EQ(assertGet(parseProtocolSetFromIsMasterReply(mongod38)).protocolSet,
+                  supports::kAll);
+    }
+    {
         // MongoDB 3.6
         auto mongod36 =
             BSON("maxWireVersion" << static_cast<int>(WireVersion::SUPPORTS_OP_MSG)  //