mongodb/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SERVER-121274 Add test coverage for the change stream control events generated by movePrimary (#52826)

Browse Source 
Co-authored-by: Copilot <copilot@github.com>
GitOrigin-RevId: 73b0541111bdf4161590383c3eacdd2f7352dcaa
This commit is contained in:
ppolato 2026-04-29 18:20:40 +02:00 committed by MongoDB Bot
parent 00cd7ceec8
commit 45ed8d2e32
1 changed files with 25 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
jstests/noPassthrough/ddl/ddl_commits_generate_historical_placement_metadata.js
View File

@ -235,6 +235,15 @@ function makeMoveChunkEntryTemplate(nss, donor, recipient, noMoreChunksOnDonor)
};
}
function makeMovePrimaryEntryTemplate(dbName, fromPrimary, toPrimary) {
return {
op: "n",
ns: dbName,
o: {msg: {movePrimary: dbName}},
o2: {movePrimary: dbName, from: fromPrimary, to: toPrimary},
};
}
function makeChunkOnNewShardEntryTemplate(nss, donor, recipient) {
return {
op: "n",
@ -632,6 +641,22 @@ function testMovePrimary(dbName, fromPrimaryShardName, toPrimaryShardName) {
// Verify that the new primary shard is the one specified in the command.
const newDbInfo = getValidatedPlacementInfoForDB(dbName);
assert.sameMembers(newDbInfo.shards, [toPrimaryShardName]);
// Verify that the old primary shard a single op entry marking the DDL commit.
const expectedEntryTemplatesOnOldPrimary = [
makeMovePrimaryEntryTemplate(dbName, fromPrimaryShardName, toPrimaryShardName),
];
const [movePrimaryEntry] = verifyCommitOpEntriesOnShards(expectedEntryTemplatesOnOldPrimary, [
fromPrimaryShardName,
])[fromPrimaryShardName];
// The commit entry must not be hidden to change stream readers.
assert(!movePrimaryEntry.fromMigrate || movePrimaryEntry.fromMigrate === false);
// The op entry represents a control event for change stream readers,
// so that it must be emitted after inserting the related placement change doc.
assert(timestampCmp(movePrimaryEntry.ts, newDbInfo.timestamp) > 0);
}
function testDropCollection() {