SERVER-37882 Switch the distributed transaction commit protocol to the RPC protocol

1 files changed, 1 insertions, 16 deletions

diff --git a/src/mongo/s/transaction_router_test.cpp b/src/mongo/s/transaction_router_test.cpp
index 889c0c5ceed..bc14fb5b326 100644
--- a/src/mongo/s/transaction_router_test.cpp
+++ b/src/mongo/s/transaction_router_test.cpp
@@ -657,7 +657,7 @@ TEST_F(TransactionRouterTest, SendCommitDirectlyForSingleParticipants) {
     future.timed_get(kFutureTimeout);
 }
 
-TEST_F(TransactionRouterTest, SendPrepareAndCoordinateCommitForMultipleParticipants) {
+TEST_F(TransactionRouterTest, SendCoordinateCommitForMultipleParticipants) {
     LogicalSessionId lsid(makeLogicalSessionIdForTest());
     TxnNumber txnNum{3};
 
@@ -676,21 +676,6 @@ TEST_F(TransactionRouterTest, SendPrepareAndCoordinateCommitForMultipleParticipa
     auto future = launchAsync([&] { txnRouter->commitTransaction(operationContext()); });
 
     onCommand([&](const RemoteCommandRequest& request) {
-        ASSERT_EQ(hostAndPort2, request.target);
-        ASSERT_EQ("admin", request.dbname);
-
-        auto cmdName = request.cmdObj.firstElement().fieldNameStringData();
-        ASSERT_EQ(cmdName, "prepareTransaction");
-
-        auto coordinator = request.cmdObj["coordinatorId"].str();
-        ASSERT_EQ(shard1.toString(), coordinator);
-
-        checkSessionDetails(request.cmdObj, lsid, txnNum, boost::none);
-
-        return BSON("ok" << 1);
-    });
-
-    onCommand([&](const RemoteCommandRequest& request) {
         ASSERT_EQ(hostAndPort1, request.target);
         ASSERT_EQ("admin", request.dbname);