diff options
author | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:17:50 -0500 |
---|---|---|
committer | Jonathan Abrahams <jonathan@mongodb.com> | 2016-03-09 12:18:14 -0500 |
commit | 4ae691e8edc87d0e3cfb633bb91c328426be007b (patch) | |
tree | 52079a593f54382ca13a2e741633eab1b6271893 /jstests/sharding/stale_mongos_updates_and_removes.js | |
parent | a025d43f3ce2efc1fb1282a718f5d286fa0a4dc1 (diff) | |
download | mongo-4ae691e8edc87d0e3cfb633bb91c328426be007b.tar.gz |
SERVER-22468 Format JS code with approved style in jstests/
Diffstat (limited to 'jstests/sharding/stale_mongos_updates_and_removes.js')
-rw-r--r-- | jstests/sharding/stale_mongos_updates_and_removes.js | 87 |
1 files changed, 51 insertions, 36 deletions
diff --git a/jstests/sharding/stale_mongos_updates_and_removes.js b/jstests/sharding/stale_mongos_updates_and_removes.js index 193cfcb83bf..17f75b4c986 100644 --- a/jstests/sharding/stale_mongos_updates_and_removes.js +++ b/jstests/sharding/stale_mongos_updates_and_removes.js @@ -17,10 +17,10 @@ var resetCollection = function() { assert(staleMongos.getCollection(collNS).drop()); st.ensurePrimaryShard(dbName, st._shardNames[0]); - assert.commandWorked(staleMongos.adminCommand({ shardCollection: collNS, key: { x: 1 }})); - for (var i=0; i<numShardKeys; i++) { - assert.writeOK(staleMongos.getCollection(collNS).insert({ x: i, fieldToUpdate: 0 })); - assert.writeOK(staleMongos.getCollection(collNS).insert({ x: i, fieldToUpdate: 0 })); + assert.commandWorked(staleMongos.adminCommand({shardCollection: collNS, key: {x: 1}})); + for (var i = 0; i < numShardKeys; i++) { + assert.writeOK(staleMongos.getCollection(collNS).insert({x: i, fieldToUpdate: 0})); + assert.writeOK(staleMongos.getCollection(collNS).insert({x: i, fieldToUpdate: 0})); } }; @@ -37,22 +37,18 @@ var makeStaleMongosTargetMultipleShards = function() { resetCollection(); // Make sure staleMongos sees all data on first shard. - var chunk = staleMongos.getCollection("config.chunks").findOne({ min: { x: MinKey }, - max: { x: MaxKey }}); + var chunk = + staleMongos.getCollection("config.chunks").findOne({min: {x: MinKey}, max: {x: MaxKey}}); assert(chunk.shard === st._shardNames[0]); // Make sure staleMongos sees two chunks on two different shards. - assert.commandWorked(staleMongos.adminCommand({ split: collNS, middle: { x: splitPoint }})); - assert.commandWorked(staleMongos.adminCommand({ moveChunk: collNS, - find: { x: 0 }, - to: st._shardNames[1], - _waitForDelete: true })); + assert.commandWorked(staleMongos.adminCommand({split: collNS, middle: {x: splitPoint}})); + assert.commandWorked(staleMongos.adminCommand( + {moveChunk: collNS, find: {x: 0}, to: st._shardNames[1], _waitForDelete: true})); // Use freshMongos to consolidate the chunks on one shard. - assert.commandWorked(freshMongos.adminCommand({ moveChunk: collNS, - find: { x: 0 }, - to: st._shardNames[0], - _waitForDelete: true })); + assert.commandWorked(freshMongos.adminCommand( + {moveChunk: collNS, find: {x: 0}, to: st._shardNames[0], _waitForDelete: true})); }; // Create a new sharded collection and move a chunk from one shard to another. In the end, @@ -65,20 +61,22 @@ var makeStaleMongosTargetMultipleShards = function() { var makeStaleMongosTargetSingleShard = function() { resetCollection(); // Make sure staleMongos sees all data on first shard. - var chunk = staleMongos.getCollection("config.chunks").findOne({ min: { x: MinKey }, - max: { x: MaxKey }}); + var chunk = + staleMongos.getCollection("config.chunks").findOne({min: {x: MinKey}, max: {x: MaxKey}}); assert(chunk.shard === st._shardNames[0]); // Use freshMongos to move chunk to another shard. - assert.commandWorked(freshMongos.adminCommand({ moveChunk: collNS, - find: { x: 0 }, - to: st._shardNames[1], - _waitForDelete: true })); + assert.commandWorked(freshMongos.adminCommand( + {moveChunk: collNS, find: {x: 0}, to: st._shardNames[1], _waitForDelete: true})); }; var checkAllRemoveQueries = function(makeMongosStaleFunc) { - var multi = { justOne: false }; - var single = { justOne: true }; + var multi = { + justOne: false + }; + var single = { + justOne: true + }; var doRemove = function(query, multiOption, makeMongosStaleFunc) { makeMongosStaleFunc(); @@ -94,7 +92,7 @@ var checkAllRemoveQueries = function(makeMongosStaleFunc) { var checkRemoveIsInvalid = function(query, multiOption, makeMongosStaleFunc) { makeMongosStaleFunc(); - var res = staleMongos.getCollection(collNS).remove(query, multiOption); + var res = staleMongos.getCollection(collNS).remove(query, multiOption); assert.writeError(res); }; @@ -116,12 +114,23 @@ var checkAllRemoveQueries = function(makeMongosStaleFunc) { }; var checkAllUpdateQueries = function(makeMongosStaleFunc) { - var oUpdate = { $inc: { fieldToUpdate: 1 }}; // op-style update (non-idempotent) - var rUpdate = { x: 0, fieldToUpdate: 1 }; // replacement-style update (idempotent) - var queryAfterUpdate = { fieldToUpdate: 1 }; + var oUpdate = { + $inc: {fieldToUpdate: 1} + }; // op-style update (non-idempotent) + var rUpdate = { + x: 0, + fieldToUpdate: 1 + }; // replacement-style update (idempotent) + var queryAfterUpdate = { + fieldToUpdate: 1 + }; - var multi = { multi: true }; - var single = { multi: false }; + var multi = { + multi: true + }; + var single = { + multi: false + }; var doUpdate = function(query, update, multiOption, makeMongosStaleFunc) { makeMongosStaleFunc(); @@ -143,7 +152,7 @@ var checkAllUpdateQueries = function(makeMongosStaleFunc) { }; // This update has inconsistent behavior as explained in SERVER-22895. - //doUpdate(emptyQuery, rUpdate, single, makeMongosStaleFunc); + // doUpdate(emptyQuery, rUpdate, single, makeMongosStaleFunc); // Not possible because replacement-style requires equality match on shard key. checkUpdateIsInvalid(emptyQuery, rUpdate, multi, makeMongosStaleFunc); // Not possible because op-style requires equality match on shard key if single update. @@ -172,28 +181,34 @@ var checkAllUpdateQueries = function(makeMongosStaleFunc) { doUpdate(multiPointQuery, oUpdate, multi, makeMongosStaleFunc); }; -var st = new ShardingTest({shards: 2, mongos: 2, other: { mongosOptions: { noAutoSplit: "" }} }); +var st = new ShardingTest({shards: 2, mongos: 2, other: {mongosOptions: {noAutoSplit: ""}}}); var dbName = 'test'; var collNS = dbName + '.foo'; var numShardKeys = 10; var numDocs = numShardKeys * 2; var splitPoint = numShardKeys / 2; -assert.commandWorked(st.s.adminCommand({ enableSharding: dbName })); -assert.commandWorked(st.s.adminCommand({ shardCollection: collNS, key: { x: 1 }})); +assert.commandWorked(st.s.adminCommand({enableSharding: dbName})); +assert.commandWorked(st.s.adminCommand({shardCollection: collNS, key: {x: 1}})); var freshMongos = st.s0; var staleMongos = st.s1; var emptyQuery = {}; -var pointQuery = { x: 0 }; +var pointQuery = { + x: 0 +}; // Choose a range that would fall on only one shard. // Use (splitPoint - 1) because of SERVER-20768. -var rangeQuery = { x: { $gte: 0, $lt: splitPoint - 1 }}; +var rangeQuery = { + x: {$gte: 0, $lt: splitPoint - 1} +}; // Choose points that would fall on two different shards. -var multiPointQuery = { $or: [{ x: 0 }, { x: numShardKeys }]}; +var multiPointQuery = { + $or: [{x: 0}, {x: numShardKeys}] +}; checkAllRemoveQueries(makeStaleMongosTargetSingleShard); checkAllRemoveQueries(makeStaleMongosTargetMultipleShards); |