diff options
Diffstat (limited to 'jstests/sharding/cursor_cleanup.js')
-rw-r--r-- | jstests/sharding/cursor_cleanup.js | 24 |
1 files changed, 12 insertions, 12 deletions
diff --git a/jstests/sharding/cursor_cleanup.js b/jstests/sharding/cursor_cleanup.js index 4eb200b87e3..5d0ce46f532 100644 --- a/jstests/sharding/cursor_cleanup.js +++ b/jstests/sharding/cursor_cleanup.js @@ -2,21 +2,21 @@ // Tests cleanup of sharded and unsharded cursors // -var st = new ShardingTest({ shards : 2, mongos : 1 }); +var st = new ShardingTest({shards: 2, mongos: 1}); var mongos = st.s0; -var admin = mongos.getDB( "admin" ); -var config = mongos.getDB( "config" ); +var admin = mongos.getDB("admin"); +var config = mongos.getDB("config"); var shards = config.shards.find().toArray(); -var coll = mongos.getCollection( "foo.bar" ); -var collUnsharded = mongos.getCollection( "foo.baz" ); +var coll = mongos.getCollection("foo.bar"); +var collUnsharded = mongos.getCollection("foo.baz"); // Shard collection -printjson(admin.runCommand({ enableSharding : coll.getDB() + "" })); -printjson(admin.runCommand({ movePrimary : coll.getDB() + "", to : shards[0]._id })); -printjson(admin.runCommand({ shardCollection : coll + "", key : { _id : 1 } })); -printjson(admin.runCommand({ split : coll + "", middle : { _id : 0 } })); -printjson(admin.runCommand({ moveChunk : coll + "", find : { _id : 0 }, to : shards[1]._id })); +printjson(admin.runCommand({enableSharding: coll.getDB() + ""})); +printjson(admin.runCommand({movePrimary: coll.getDB() + "", to: shards[0]._id})); +printjson(admin.runCommand({shardCollection: coll + "", key: {_id: 1}})); +printjson(admin.runCommand({split: coll + "", middle: {_id: 0}})); +printjson(admin.runCommand({moveChunk: coll + "", find: {_id: 0}, to: shards[1]._id})); jsTest.log("Collection set up..."); st.printShardingStatus(true); @@ -26,8 +26,8 @@ jsTest.log("Insert enough data to overwhelm a query batch."); var bulk = coll.initializeUnorderedBulkOp(); var bulk2 = collUnsharded.initializeUnorderedBulkOp(); for (var i = -150; i < 150; i++) { - bulk.insert({ _id : i }); - bulk2.insert({ _id : i }); + bulk.insert({_id: i}); + bulk2.insert({_id: i}); } assert.writeOK(bulk.execute()); assert.writeOK(bulk2.execute()); |