1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
|
// Tests the $out and read concern majority.
// @tags: [
// requires_majority_read_concern,
// ]
(function() {
"use strict";
load("jstests/libs/write_concern_util.js"); // For stopReplicationOnSecondaries.
const rst = new ReplSetTest({nodes: 2, nodeOptions: {enableMajorityReadConcern: ""}});
rst.startSet();
rst.initiate();
const name = "out_majority_read";
const db = rst.getPrimary().getDB(name);
const sourceColl = db.sourceColl;
assert.commandWorked(sourceColl.insert({_id: 1, state: 'before'}));
rst.awaitLastOpCommitted();
stopReplicationOnSecondaries(rst);
// Rename the collection temporarily and then back to its original name. This advances the minimum
// visible snapshot and forces the $out to block until its snapshot advances.
const tempColl = db.getName() + '.temp';
assert.commandWorked(db.adminCommand({
renameCollection: sourceColl.getFullName(),
to: tempColl,
}));
assert.commandWorked(db.adminCommand({
renameCollection: tempColl,
to: sourceColl.getFullName(),
}));
// Create the index that is not majority committed
assert.commandWorked(sourceColl.createIndex({state: 1}, {name: "secondIndex"}, 0));
// Run the $out in the parallel shell as it will block in the metadata until the snapshot is
// advanced. This will no longer block with point-in-time reads as a new collection instance is
// created internally when reading before the minimum visible snapshot.
const awaitShell = startParallelShell(`{
const testDB = db.getSiblingDB("${name}");
const sourceColl = testDB.sourceColl;
// Run $out and make sure the {state:1} index is carried over.
const res = sourceColl.aggregate([{$out: sourceColl.getName()}],
{readConcern: {level: 'majority'}});
assert.eq(res.itcount(), 0);
const indexes = sourceColl.getIndexes();
assert.eq(indexes.length, 2);
assert.eq(indexes[0].name, "_id_");
assert.eq(indexes[1].name, "secondIndex");
}`,
db.getMongo().port);
// Restart data replication and wait until the new write becomes visible.
restartReplicationOnSecondaries(rst);
rst.awaitLastOpCommitted();
awaitShell();
rst.stopSet();
}());
|
