diff options
Diffstat (limited to 'jstests/sharding/trace_missing_docs_test.js')
-rw-r--r-- | jstests/sharding/trace_missing_docs_test.js | 56 |
1 files changed, 28 insertions, 28 deletions
diff --git a/jstests/sharding/trace_missing_docs_test.js b/jstests/sharding/trace_missing_docs_test.js index b09003617d4..329ad529ac3 100644 --- a/jstests/sharding/trace_missing_docs_test.js +++ b/jstests/sharding/trace_missing_docs_test.js @@ -2,45 +2,45 @@ load('jstests/libs/trace_missing_docs.js'); (function() { - 'use strict'; +'use strict'; - var testDocMissing = function(useReplicaSet) { - var options = { - rs: useReplicaSet, - shardOptions: {oplogSize: 10}, - rsOptions: {nodes: 1, oplogSize: 10} - }; +var testDocMissing = function(useReplicaSet) { + var options = { + rs: useReplicaSet, + shardOptions: {oplogSize: 10}, + rsOptions: {nodes: 1, oplogSize: 10} + }; - var st = new ShardingTest({shards: 2, mongos: 1, other: options}); + var st = new ShardingTest({shards: 2, mongos: 1, other: options}); - var mongos = st.s0; - var coll = mongos.getCollection("foo.bar"); - var admin = mongos.getDB("admin"); + var mongos = st.s0; + var coll = mongos.getCollection("foo.bar"); + var admin = mongos.getDB("admin"); - assert.commandWorked(admin.runCommand({enableSharding: coll.getDB() + ""})); - st.ensurePrimaryShard(coll.getDB() + "", st.shard0.shardName); + assert.commandWorked(admin.runCommand({enableSharding: coll.getDB() + ""})); + st.ensurePrimaryShard(coll.getDB() + "", st.shard0.shardName); - coll.ensureIndex({sk: 1}); - assert.commandWorked(admin.runCommand({shardCollection: coll + "", key: {sk: 1}})); + coll.ensureIndex({sk: 1}); + assert.commandWorked(admin.runCommand({shardCollection: coll + "", key: {sk: 1}})); - assert.writeOK(coll.insert({_id: 12345, sk: 67890, hello: "world"})); - assert.writeOK(coll.update({_id: 12345}, {$set: {baz: 'biz'}})); - assert.writeOK(coll.update({sk: 67890}, {$set: {baz: 'boz'}})); + assert.writeOK(coll.insert({_id: 12345, sk: 67890, hello: "world"})); + assert.writeOK(coll.update({_id: 12345}, {$set: {baz: 'biz'}})); + assert.writeOK(coll.update({sk: 67890}, {$set: {baz: 'boz'}})); - assert.commandWorked(admin.runCommand( - {moveChunk: coll + "", find: {sk: 0}, to: st.shard1.shardName, _waitForDelete: true})); + assert.commandWorked(admin.runCommand( + {moveChunk: coll + "", find: {sk: 0}, to: st.shard1.shardName, _waitForDelete: true})); - st.printShardingStatus(); + st.printShardingStatus(); - var ops = traceMissingDoc(coll, {_id: 12345, sk: 67890}); + var ops = traceMissingDoc(coll, {_id: 12345, sk: 67890}); - assert.eq(ops[0].op, 'i'); - assert.eq(ops.length, 5); + assert.eq(ops[0].op, 'i'); + assert.eq(ops.length, 5); - jsTest.log("DONE! (using rs)"); + jsTest.log("DONE! (using rs)"); - st.stop(); - }; + st.stop(); +}; - testDocMissing(true); +testDocMissing(true); })(); |