From 56248d50536a25d63526662683b221df8137ab36 Mon Sep 17 00:00:00 2001 From: Esha Maharishi Date: Wed, 31 Oct 2018 21:54:33 -0400 Subject: SERVER-37882 Switch the distributed transaction commit protocol to the RPC protocol --- src/mongo/s/transaction_router_test.cpp | 17 +---------------- 1 file changed, 1 insertion(+), 16 deletions(-) (limited to 'src/mongo/s/transaction_router_test.cpp') 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}; @@ -675,21 +675,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); -- cgit v1.2.1