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
|
/**
* Test to ensure that specifying non-local read concern with an uninitiated set does not crash
* node.
*
* @tags: [requires_persistence, requires_majority_read_concern]
*/
(function() {
"use strict";
const rst = new ReplSetTest({nodes: 1});
rst.startSet();
const localDB = rst.nodes[0].getDB('local');
assert.commandWorked(localDB.test.insert({_id: 0}));
assert.commandWorked(localDB.runCommand({
hello: 1,
"$clusterTime": {
"clusterTime": Timestamp(1, 1),
"signature": {"hash": BinData(0, "AAAAAAAAAAAAAAAAAAAAAAAAAAA="), "keyId": NumberLong(0)}
}
}));
jsTestLog("Local readConcern on local database should work.");
const res = assert.commandWorked(localDB.runCommand(
{find: "test", filter: {}, maxTimeMS: 60000, readConcern: {level: "local"}}));
assert.eq([{_id: 0}], res.cursor.firstBatch);
jsTestLog("Majority readConcern should fail with NotYetInitialized.");
assert.commandFailedWithCode(
localDB.runCommand(
{find: "test", filter: {}, maxTimeMS: 60000, readConcern: {level: "majority"}}),
ErrorCodes.NotYetInitialized);
// Nodes don't process $clusterTime metadata when in an unreadable state, so this read will fail
// because the logical clock's latest value is less than the given afterClusterTime timestamp.
jsTestLog("afterClusterTime readConcern should fail with NotPrimaryOrSecondary.");
assert.commandFailedWithCode(localDB.runCommand({
find: "test",
filter: {},
maxTimeMS: 60000,
readConcern: {afterClusterTime: Timestamp(1, 1)}
}),
ErrorCodes.NotPrimaryOrSecondary);
jsTestLog("oplog query should fail with NotYetInitialized.");
assert.commandFailedWithCode(localDB.runCommand({
find: "oplog.rs",
filter: {ts: {$gte: Timestamp(1520004466, 2)}},
tailable: true,
awaitData: true,
maxTimeMS: 60000,
batchSize: 13981010,
term: 1,
readConcern: {afterClusterTime: Timestamp(1, 1)}
}),
ErrorCodes.NotPrimaryOrSecondary);
rst.stopSet();
}());
|
