diff options
| author | Alex Taskov <alex.taskov@mongodb.com> | 2020-02-04 13:18:29 -0500 |
|---|---|---|
| committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2020-02-04 18:42:34 +0000 |
| commit | 8d3429fed4e5307a9e79fe99494ccefc388e54f4 (patch) | |
| tree | 615d6e74116fc32da0c1ac92227f22ad8f615f38 /src/mongo/db/s/start_chunk_clone_request_test.cpp | |
| parent | 0eaddad5bb19553974910d4957d18e1ad790a504 (diff) | |
| download | mongo-8d3429fed4e5307a9e79fe99494ccefc388e54f4.tar.gz | |
SERVER-45339 Make MigrationSourceManager send _recvChunkStart to recipient shard as a retryable write
Diffstat (limited to 'src/mongo/db/s/start_chunk_clone_request_test.cpp')
| -rw-r--r-- | src/mongo/db/s/start_chunk_clone_request_test.cpp | 15 |
1 files changed, 14 insertions, 1 deletions
diff --git a/src/mongo/db/s/start_chunk_clone_request_test.cpp b/src/mongo/db/s/start_chunk_clone_request_test.cpp index 0ff6f4ffb35..f498be0e366 100644 --- a/src/mongo/db/s/start_chunk_clone_request_test.cpp +++ b/src/mongo/db/s/start_chunk_clone_request_test.cpp @@ -33,7 +33,10 @@ #include "mongo/base/status_with.h" #include "mongo/bson/bsonobjbuilder.h" +#include "mongo/db/client.h" #include "mongo/db/jsobj.h" +#include "mongo/db/logical_session_id_helpers.h" +#include "mongo/db/service_context.h" #include "mongo/s/shard_id.h" #include "mongo/unittest/unittest.h" @@ -44,14 +47,22 @@ using unittest::assertGet; namespace { TEST(StartChunkCloneRequest, CreateAsCommandComplete) { + auto serviceContext = ServiceContext::make(); + auto client = serviceContext->makeClient("TestClient"); + auto opCtx = client->makeOperationContext(); + MigrationSessionId sessionId = MigrationSessionId::generate("shard0001", "shard0002"); UUID migrationId = UUID::gen(); + auto lsid = makeLogicalSessionId(opCtx.get()); + TxnNumber txnNumber = 0; BSONObjBuilder builder; StartChunkCloneRequest::appendAsCommand( &builder, NamespaceString("TestDB.TestColl"), migrationId, + lsid, + txnNumber, sessionId, assertGet(ConnectionString::parse("TestDonorRS/Donor1:12345,Donor2:12345,Donor3:12345")), ShardId("shard0001"), @@ -68,7 +79,9 @@ TEST(StartChunkCloneRequest, CreateAsCommandComplete) { ASSERT_EQ("TestDB.TestColl", request.getNss().ns()); ASSERT_EQ(sessionId.toString(), request.getSessionId().toString()); - ASSERT(migrationId == request.getMigrationId()); + ASSERT_EQ(migrationId, request.getMigrationId()); + ASSERT_EQ(lsid, request.getLsid()); + ASSERT_EQ(txnNumber, request.getTxnNumber()); ASSERT(sessionId.matches(request.getSessionId())); ASSERT_EQ( assertGet(ConnectionString::parse("TestDonorRS/Donor1:12345,Donor2:12345,Donor3:12345")) |