summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorScott Hernandez <scotthernandez@gmail.com>2015-01-30 17:32:19 -0500
committerScott Hernandez <scotthernandez@gmail.com>2015-02-03 13:52:38 -0500
commitda92a96cecad44341d649dc8f893055b64f17c9d (patch)
tree6fcd21dccdee3f265f8e3f81bfa2ac7732d02615
parentacb211cf14ec8ee524b450e5c914080d516b1c47 (diff)
downloadmongo-da92a96cecad44341d649dc8f893055b64f17c9d.tar.gz
SERVER-17096: ensure first node primary in resync.js test
-rwxr-xr-xjstests/replsets/resync.js16
1 files changed, 7 insertions, 9 deletions
diff --git a/jstests/replsets/resync.js b/jstests/replsets/resync.js
index 495c67d1ecb..af75d8bb813 100755
--- a/jstests/replsets/resync.js
+++ b/jstests/replsets/resync.js
@@ -9,14 +9,14 @@
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]}]
+ {"_id": 0, "host": nodes[0], priority:1},
+ {"_id": 1, "host": nodes[1], priority:0},
+ {"_id": 2, "host": nodes[2], arbiterOnly:true}]
});
- // Make sure we have a master
- var master = replTest.getMaster();
var a_conn = conns[0];
+ // Make sure we have a master, and it is conns[0]
+ replTest.waitForState(a_conn, ReplSetTest.State.PRIMARY);
var b_conn = conns[1];
a_conn.setSlaveOk();
b_conn.setSlaveOk();
@@ -24,11 +24,9 @@
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 }}));
+ assert.writeOK( A.foo.insert({ x: 1 }, { writeConcern: { w: 2, wtimeout: 60000 }}));
assert.eq(B.foo.findOne().x, 1)
// run resync and wait for it to happen
@@ -54,7 +52,7 @@
}
// wait for secondary to also have its oplog cycle
- assert.writeOK(bulk.execute({ w: 2, wtimeout : 60000 }));
+ assert.writeOK(bulk.execute({ w: 1, wtimeout : 60000 }));
if ( hasCycled() )
break;