blob: daed9de7ad6d83a24ddaf8b6d403d9b5901b7f07 (
plain)
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
|
/* @file : jstests/fsync_lock_read_secondaries.js
*
* SERVER 4243 : If there is a pending write due to an fsync lock, all reads are blocked
*
* This test validates part of SERVER-4243 ticket. Allow reading on secondaries with fsyncLock
* mode enabled. Previously oplog application would cause blocking.
* The corresponding commit :
* https://github.com/mongodb/mongo/commit/73aa870d129bd7d51de946b91c16cc056aaacbc7
*/
/*
* 1) Create a replica set.
* 2) Add some documents to primary.
* 3) Wait until the secondary nodes are in state "SECONDARY".
* 4) Set slaveOk on secondary.
* 5) Take the fsync lock on a secondary. This will stop replication.
* 6) Insert some more documents to primary.
* 7) Expect to be able to read from the secondary; the count of documents should
* be equal to the number of documents added in step 2.
* 8) Release the fsync lock. This will resume replication.
* 9) Soon, the secondary should be applying the oplog again, which we should
* witness as an increase in the count of documents stored on the secondary.
*/
(function() {
"use strict";
// Load utility methods for replica set tests
load("jstests/replsets/rslib.js");
var replTest = new ReplSetTest({name: 'testSet', nodes: 2, oplogSize: 5});
// Start each mongod in the replica set. Returns a list of nodes
var nodes = replTest.startSet();
// This will wait for initiation
replTest.initiate();
var primary = replTest.getPrimary();
var ret = primary.getDB("admin").fsyncLock();
if (!ret.ok) {
assert.commandFailedWithCode(ret, ErrorCodes.CommandNotSupported);
jsTestLog("Storage Engine does not support fsyncLock, so bailing");
return;
}
primary.getDB("admin").fsyncUnlock();
var docNum = 100;
for (var i = 0; i < docNum; i++) {
primary.getDB("foo").bar.save({a: i});
}
waitForAllMembers(primary.getDB("foo"));
replTest.awaitReplication();
// Calling getPrimary also populates '_secondaries'.
var secondaries = replTest.getSecondaries();
secondaries[0].setSecondaryOk();
assert.commandWorked(secondaries[0].getDB("admin").runCommand({fsync: 1, lock: 1}));
var docNum = 1000;
for (var i = 0; i < docNum; i++) {
primary.getDB("foo").bar.save({a: i});
}
// Issue a read query on the secondary while holding the fsync lock.
// This is what we are testing. Previously this would block. After the fix
// this should work just fine.
var secondary0count = secondaries[0].getDB("foo").bar.find().itcount();
assert.eq(secondary0count,
100,
"Doc count in fsync lock wrong. Expected (=100), found " + secondary0count);
assert(secondaries[0].getDB("admin").fsyncUnlock().ok);
// The secondary should have equal or more documents than what it had before.
assert.soon(function() {
return secondaries[0].getDB("foo").bar.find().itcount() > 100;
}, "count of documents stored on the secondary did not increase");
replTest.stopSet();
}());
|
