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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
/**
* Tests that temporary collections are not dropped when a member of a replica set is started up as
* a stand-alone mongod, i.e. without the --replSet parameter.
*
* @tags: [requires_persistence, requires_majority_read_concern, requires_replication,
* # Restarting as a standalone is not supported in multiversion tests.
* multiversion_incompatible]
*/
(function() {
var rst = new ReplSetTest({nodes: 2});
rst.startSet();
// Rig the election so that the first node becomes the primary and remains primary despite the
// secondary being terminated during this test.
var replSetConfig = rst.getReplSetConfig();
replSetConfig.members[1].priority = 0;
replSetConfig.members[1].votes = 0;
rst.initiate(replSetConfig);
var primaryConn = rst.getPrimary();
var secondaryConn = rst.getSecondary();
var primaryDB = primaryConn.getDB("test");
var secondaryDB = secondaryConn.getDB("test");
// Create a temporary collection and wait until the operation has replicated to the secondary.
assert.commandWorked(primaryDB.runCommand({
applyOps: [{
op: "c",
ns: primaryDB.getName() + ".$cmd",
o: {
create: "temp_collection",
temp: true,
writeConcern: {w: 2, wtimeout: ReplSetTest.kDefaultTimeoutMS}
}
}]
}));
rst.awaitReplication();
// Verify that the temporary collection exists on the primary and has temp=true.
var primaryCollectionInfos = primaryDB.getCollectionInfos({name: "temp_collection"});
assert.eq(1, primaryCollectionInfos.length, "'temp_collection' wasn't created on the primary");
assert.eq("temp_collection",
primaryCollectionInfos[0].name,
"'temp_collection' wasn't created on the primary");
assert.eq(true,
primaryCollectionInfos[0].options.temp,
"'temp_collection' wasn't created as temporary on the primary: " +
tojson(primaryCollectionInfos[0].options));
// Verify that the temporary collection exists on the secondary and has temp=true.
var secondaryCollectionInfos = secondaryDB.getCollectionInfos({name: "temp_collection"});
assert.eq(1, secondaryCollectionInfos.length, "'temp_collection' wasn't created on the secondary");
assert.eq("temp_collection",
secondaryCollectionInfos[0].name,
"'temp_collection' wasn't created on the secondary");
assert.eq(true,
secondaryCollectionInfos[0].options.temp,
"'temp_collection' wasn't created as temporary on the secondary: " +
tojson(secondaryCollectionInfos[0].options));
// Shut down the secondary and restart it as a stand-alone mongod.
var secondaryNodeId = rst.getNodeId(secondaryDB.getMongo());
rst.stop(secondaryNodeId);
var storageEngine = jsTest.options().storageEngine || "wiredTiger";
if (storageEngine === "wiredTiger") {
secondaryConn = MongoRunner.runMongod({
dbpath: secondaryConn.dbpath,
noCleanData: true,
setParameter: {recoverFromOplogAsStandalone: true}
});
} else {
secondaryConn = MongoRunner.runMongod({dbpath: secondaryConn.dbpath, noCleanData: true});
}
assert.neq(null, secondaryConn, "secondary failed to start up as a stand-alone mongod");
secondaryDB = secondaryConn.getDB("test");
// Verify that the temporary collection still exists on the secondary and has temp=true.
secondaryCollectionInfos = secondaryDB.getCollectionInfos({name: "temp_collection"});
assert.eq(1,
secondaryCollectionInfos.length,
"'temp_collection' was dropped after restarting the secondary as a stand-alone");
assert.eq("temp_collection",
secondaryCollectionInfos[0].name,
"'temp_collection' was dropped after restarting the secondary as a stand-alone");
assert.eq(true,
secondaryCollectionInfos[0].options.temp,
"'temp_collection' is no longer temporary after restarting the secondary as a" +
" stand-alone: " + tojson(secondaryCollectionInfos[0].options));
// Shut down the secondary and restart it as a member of the replica set.
MongoRunner.stopMongod(secondaryConn);
var restart = true;
rst.start(secondaryNodeId, {}, restart);
// Verify that writes are replicated to the temporary collection and can successfully be applied
// by the secondary after having restarted it.
assert.commandWorked(primaryDB.temp_collection.insert(
{}, {writeConcern: {w: 2, wtimeout: ReplSetTest.kDefaultTimeoutMS}}));
rst.stopSet();
})();
|
