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
|
/**
* Tests that writeConcern 'majority' writes succeed and are visible in a replica set that has one
* data-bearing node and two arbiters.
*/
load("jstests/replsets/rslib.js"); // For startSetIfSupportsReadMajority.
(function() {
"use strict";
function log(arg) {
jsTest.log(tojson(arg));
}
// Set up a set and grab things for later.
var name = "read_majority_two_arbs";
var replTest =
new ReplSetTest({name: name, nodes: 3, nodeOptions: {enableMajorityReadConcern: ''}});
if (!startSetIfSupportsReadMajority(replTest)) {
jsTest.log("skipping test since storage engine doesn't support committed reads");
replTest.stopSet();
return;
}
var nodes = replTest.nodeList();
var config = {
"_id": name,
"members": [
{"_id": 0, "host": nodes[0]},
{"_id": 1, "host": nodes[1], arbiterOnly: true},
{"_id": 2, "host": nodes[2], arbiterOnly: true}
]
};
replTest.initiate(config);
var primary = replTest.getPrimary();
var db = primary.getDB(name);
var t = db[name];
function doRead(readConcern) {
readConcern.maxTimeMS = 3000;
var res = assert.commandWorked(t.runCommand('find', readConcern));
var docs = (new DBCommandCursor(db, res)).toArray();
assert.gt(docs.length, 0, "no docs returned!");
return docs[0].state;
}
function doDirtyRead() {
log("doing dirty read");
var ret = doRead({"readConcern": {"level": "local"}});
log("done doing dirty read.");
return ret;
}
function doCommittedRead() {
log("doing committed read");
var ret = doRead({"readConcern": {"level": "majority"}});
log("done doing committed read.");
return ret;
}
jsTest.log("doing write");
assert.writeOK(
t.save({_id: 1, state: 0}, {writeConcern: {w: "majority", wtimeout: 10 * 1000}}));
jsTest.log("doing read");
assert.eq(doDirtyRead(), 0);
jsTest.log("doing committed read");
assert.eq(doCommittedRead(), 0);
jsTest.log("stopping replTest; test completed successfully");
replTest.stopSet();
}());
|
