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
|
//
// Tests write-concern-related batch write protocol functionality for master/slave replication
// More general write concern tests in replsets/batch_write_command_wc.js
//
var request;
var result;
// NOTE: ALL TESTS BELOW SHOULD BE SELF-CONTAINED, FOR EASIER DEBUGGING
jsTest.log("Starting legacy repl tests...");
// Start a master node
// Allows testing legacy repl failures
var mongod = MongoRunner.runMongod({master: "", oplogSize: 40, smallfiles: ""});
var coll = mongod.getCollection("test.batch_write_command_wc_repl");
//
// Basic insert, default WC
coll.remove({});
printjson(request = {insert: coll.getName(), documents: [{a: 1}]});
printjson(result = coll.runCommand(request));
assert(result.ok);
assert.eq(1, result.n);
assert.eq(1, coll.count());
//
// Basic insert, majority WC
coll.remove({});
printjson(request = {insert: coll.getName(), documents: [{a: 1}], writeConcern: {w: 'majority'}});
printjson(result = coll.runCommand(request));
assert(result.ok);
assert.eq(1, result.n);
assert.eq(1, coll.count());
//
// Basic insert, immediate bad wMode error
coll.remove({});
printjson(request = {insert: coll.getName(), documents: [{a: 1}], writeConcern: {w: 'invalid'}});
printjson(result = coll.runCommand(request));
assert(!result.ok);
assert.eq(0, coll.count());
//
// Basic insert, error on WC with wtimeout
coll.remove({});
printjson(
request = {insert: coll.getName(), documents: [{a: 1}], writeConcern: {w: 2, wtimeout: 1}});
printjson(result = coll.runCommand(request));
assert(result.ok);
assert.eq(1, result.n);
assert(result.writeConcernError);
assert(result.writeConcernError.errInfo.wtimeout);
assert.eq(1, coll.count());
jsTest.log("DONE legacy repl tests");
MongoRunner.stopMongod(mongod);
|
