summaryrefslogtreecommitdiff
path: root/jstests/replsets/tags.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/replsets/tags.js')
-rw-r--r--jstests/replsets/tags.js48
1 files changed, 12 insertions, 36 deletions
diff --git a/jstests/replsets/tags.js b/jstests/replsets/tags.js
index 55a0c4e2927..a079c4c9bb9 100644
--- a/jstests/replsets/tags.js
+++ b/jstests/replsets/tags.js
@@ -98,9 +98,7 @@
jsTestLog('Node ' + nodeId + ' (' + replTest.nodes[nodeId].host + ') should be primary.');
replTest.waitForState(replTest.nodes[nodeId], ReplSetTest.State.PRIMARY, 60 * 1000);
primary = replTest.getPrimary();
- var writeConcern = {
- writeConcern: {w: expectedWritableNodes, wtimeout: 30 * 1000}
- };
+ var writeConcern = {writeConcern: {w: expectedWritableNodes, wtimeout: 30 * 1000}};
assert.writeOK(primary.getDB('foo').bar.insert({x: 100}, writeConcern));
return primary;
};
@@ -125,9 +123,7 @@
jsTestLog('partitions: nodes with each set of brackets [N1, N2, N3] form a complete network.');
jsTestLog('partitions: [0-1-2] [3] [4] (only nodes 0 and 1 can replicate from primary node 2');
- var doc = {
- x: 1
- };
+ var doc = {x: 1};
// This timeout should be shorter in duration than the server parameter maxSyncSourceLagSecs.
// Some writes are expected to block for this 'timeout' duration before failing.
@@ -140,9 +136,7 @@
primary = ensurePrimary(2, 3);
jsTestLog('Non-existent write concern should be rejected.');
- options = {
- writeConcern: {w: 'blahblah', wtimeout: timeout}
- };
+ options = {writeConcern: {w: 'blahblah', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
var result = assert.writeError(primary.getDB('foo').bar.insert(doc, options));
assert.neq(null, result.getWriteConcernError());
@@ -151,9 +145,7 @@
tojson(result.getWriteConcernError()));
jsTestLog('Write concern "3 or 4" should fail - 3 and 4 are not connected to the primary.');
- var options = {
- writeConcern: {w: '3 or 4', wtimeout: timeout}
- };
+ var options = {writeConcern: {w: '3 or 4', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
result = primary.getDB('foo').bar.insert(doc, options);
assert.neq(null, result.getWriteConcernError());
@@ -166,16 +158,12 @@
jsTestLog('Write concern "3 or 4" should work - 4 is now connected to the primary ' +
primary.host + ' via node 1 ' + replTest.nodes[1].host);
- options = {
- writeConcern: {w: '3 or 4', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '3 or 4', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
jsTestLog('Write concern "3 and 4" should fail - 3 is not connected to the primary.');
- options = {
- writeConcern: {w: '3 and 4', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '3 and 4', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
result = assert.writeError(primary.getDB('foo').bar.insert(doc, options));
assert.neq(null, result.getWriteConcernError());
@@ -190,31 +178,23 @@
jsTestLog('31003 should sync from 31004 (31024)');
jsTestLog('Write concern "3 and 4" should work - ' +
'nodes 3 and 4 are connected to primary via node 1.');
- options = {
- writeConcern: {w: '3 and 4', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '3 and 4', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
jsTestLog('Write concern "2" - writes to primary only.');
- options = {
- writeConcern: {w: '2', wtimeout: 0}
- };
+ options = {writeConcern: {w: '2', wtimeout: 0}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
jsTestLog('Write concern "1 and 2"');
- options = {
- writeConcern: {w: '1 and 2', wtimeout: 0}
- };
+ options = {writeConcern: {w: '1 and 2', wtimeout: 0}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
jsTestLog('Write concern "2 dc and 3 server"');
primary = ensurePrimary(2, 5);
- options = {
- writeConcern: {w: '2 dc and 3 server', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '2 dc and 3 server', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
@@ -239,17 +219,13 @@
primary = ensurePrimary(1, 4);
jsTestLog('Write concern "3 and 4" should still work with new primary node 1 ' + primary.host);
- options = {
- writeConcern: {w: '3 and 4', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '3 and 4', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
assert.writeOK(primary.getDB('foo').bar.insert(doc, options));
jsTestLog('Write concern "2" should fail because node 2 ' + replTest.nodes[2].host +
' is down.');
- options = {
- writeConcern: {w: '2', wtimeout: timeout}
- };
+ options = {writeConcern: {w: '2', wtimeout: timeout}};
assert.writeOK(primary.getDB('foo').bar.insert(doc));
result = assert.writeError(primary.getDB('foo').bar.insert(doc, options));
assert.neq(null, result.getWriteConcernError());