diff options
Diffstat (limited to 'jstests/replsets/replset9.js')
| -rw-r--r-- | jstests/replsets/replset9.js | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/jstests/replsets/replset9.js b/jstests/replsets/replset9.js index 7bf5254a384..d2317780bcb 100644 --- a/jstests/replsets/replset9.js +++ b/jstests/replsets/replset9.js @@ -18,17 +18,19 @@ mdc.insert( { _id:-1, x:"dummy" } ); // Make this db big so that cloner takes a while. print ("inserting bigstrings"); +var bulk = mdc.initializeUnorderedBulkOp(); for( i = 0; i < doccount; ++i ) { - mdc.insert( { _id:i, x:bigstring } ); + mdc.insert({ _id: i, x: bigstring }); } -md.getLastError(); +assert.writeOK(bulk.execute()); // Insert some docs to update and remove print ("inserting x"); +bulk = mdc.initializeUnorderedBulkOp(); for( i = doccount; i < doccount*2; ++i ) { - mdc.insert( { _id:i, bs:bigstring, x:i } ); + bulk.insert({ _id: i, bs: bigstring, x: i }); } -md.getLastError(); +assert.writeOK(bulk.execute()); // add a secondary; start cloning var slave = rt.add(); @@ -44,11 +46,11 @@ var slave = rt.add(); cmd[cmdKey] = config; printjson(cmd); - jsTest.attempt({context:rt, timeout: timeout, desc: "reinitiate replica set"}, function() { + assert.soon(function() { var result = admin.runCommand(cmd); printjson(result); return result['ok'] == 1; - }); + }, "reinitiate replica set", timeout); })(); @@ -57,12 +59,14 @@ var sc = slave.getDB( 'd' )[ 'c' ]; slave.setSlaveOk(); print ("updating and deleting documents"); +bulk = mdc.initializeUnorderedBulkOp(); for (i = doccount*4; i > doccount; --i) { - mdc.update( { _id:i }, { $inc: { x : 1 } } ); - mdc.remove( { _id:i } ); - mdc.insert( { bs:bigstring } ); + bulk.find({ _id: i }).update({ $inc: { x: 1 }}); + bulk.find({ _id: i }).remove(); + bulk.insert({ bs: bigstring }); } -md.getLastError(); +assert.writeOK(bulk.execute()); + print ("finished"); // Wait for replication to catch up. rt.awaitReplication(640000); |
