mirrors/mongodb
mirrors/mongodb
0
0
Fork 0
mirror of https://github.com/mongodb/mongo.git synced 2024-12-01 01:21:03 +01:00
Code Issues Releases Activity

SERVER-15704: disable resync.js

Browse Source
This commit is contained in:
Scott Hernandez 2014-10-17 10:25:17 -04:00
parent 9dac9ae4ae
commit 75734d035f
1 changed files with 62 additions and 59 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

121
jstests/replsets/resync.js Normal file → Executable file
View File

@ -1,73 +1,76 @@
// test that the resync command works with replica sets and that one does not need to manually
// force a replica set resync by deleting all datafiles
var replTest = new ReplSetTest({name: 'resync', nodes: 3, oplogSize: 1});
var nodes = replTest.nodeList();
// TODO: Remove once test is fixed for SERVER-15704, add "use strict"
if (true) {
var replTest = new ReplSetTest({name: 'resync', nodes: 3, oplogSize: 1});
var nodes = replTest.nodeList();
var conns = replTest.startSet();
var r = replTest.initiate({ "_id": "resync",
"members": [
{"_id": 0, "host": nodes[0]},
{"_id": 1, "host": nodes[1]},
{"_id": 2, "host": nodes[2]}]
});
var conns = replTest.startSet();
var r = replTest.initiate({ "_id": "resync",
"members": [
{"_id": 0, "host": nodes[0]},
{"_id": 1, "host": nodes[1]},
{"_id": 2, "host": nodes[2]}]
});
// Make sure we have a master
var master = replTest.getMaster();
var a_conn = conns[0];
var b_conn = conns[1];
a_conn.setSlaveOk();
b_conn.setSlaveOk();
var A = a_conn.getDB("test");
var B = b_conn.getDB("test");
var AID = replTest.getNodeId(a_conn);
var BID = replTest.getNodeId(b_conn);
assert(master == conns[0], "conns[0] assumed to be master");
assert(a_conn.host == master.host);
// Make sure we have a master
var master = replTest.getMaster();
var a_conn = conns[0];
var b_conn = conns[1];
a_conn.setSlaveOk();
b_conn.setSlaveOk();
var A = a_conn.getDB("test");
var B = b_conn.getDB("test");
var AID = replTest.getNodeId(a_conn);
var BID = replTest.getNodeId(b_conn);
assert(master == conns[0], "conns[0] assumed to be master");
assert(a_conn.host == master.host);
// create an oplog entry with an insert
assert.writeOK( A.foo.insert({ x: 1 }, { writeConcern: { w: 3, wtimeout: 60000 }}));
replTest.stop(BID);
// create an oplog entry with an insert
assert.writeOK( A.foo.insert({ x: 1 }, { writeConcern: { w: 3, wtimeout: 60000 }}));
replTest.stop(BID);
function hasCycled() {
var oplog = a_conn.getDB("local").oplog.rs;
return oplog.find( { "o.x" : 1 } ).sort( { $natural : 1 } )._addSpecial( "$maxScan" , 10 ).itcount() == 0;
}
for ( var cycleNumber = 0; cycleNumber < 10; cycleNumber++ ) {
// insert enough to cycle oplog
var bulk = A.foo.initializeUnorderedBulkOp();
for (i=2; i < 10000; i++) {
bulk.insert({x:i});
function hasCycled() {
var oplog = a_conn.getDB("local").oplog.rs;
return oplog.find( { "o.x" : 1 } ).sort( { $natural : 1 } )._addSpecial( "$maxScan" , 10 ).itcount() == 0;
}
// wait for secondary to also have its oplog cycle
assert.writeOK(bulk.execute({ w: 2, wtimeout : 60000 }));
for ( var cycleNumber = 0; cycleNumber < 10; cycleNumber++ ) {
// insert enough to cycle oplog
var bulk = A.foo.initializeUnorderedBulkOp();
for (i=2; i < 10000; i++) {
bulk.insert({x:i});
}
if ( hasCycled() )
break;
}
// wait for secondary to also have its oplog cycle
assert.writeOK(bulk.execute({ w: 2, wtimeout : 60000 }));
assert( hasCycled() );
// bring node B and it will enter recovery mode because its newest oplog entry is too old
replTest.restart(BID);
// check that it is in recovery mode
assert.soon(function() {
try {
var result = b_conn.getDB("admin").runCommand({replSetGetStatus: 1});
return (result.members[1].stateStr === "RECOVERING");
if ( hasCycled() )
break;
}
catch ( e ) {
print( e );
}
}, "node didn't enter RECOVERING state");
// run resync and wait for it to happen
assert.commandWorked(b_conn.getDB("admin").runCommand({resync:1}));
replTest.awaitReplication();
replTest.awaitSecondaryNodes();
assert( hasCycled() );
replTest.stopSet(15);
// bring node B and it will enter recovery mode because its newest oplog entry is too old
replTest.restart(BID);
// check that it is in recovery mode
assert.soon(function() {
try {
var result = b_conn.getDB("admin").runCommand({replSetGetStatus: 1});
return (result.members[1].stateStr === "RECOVERING");
}
catch ( e ) {
print( e );
}
}, "node didn't enter RECOVERING state");
// run resync and wait for it to happen
assert.commandWorked(b_conn.getDB("admin").runCommand({resync:1}));
replTest.awaitReplication();
replTest.awaitSecondaryNodes();
replTest.stopSet(15);
}