diff options
Diffstat (limited to 'jstests/sharding/secondary_query_routing.js')
-rw-r--r-- | jstests/sharding/secondary_query_routing.js | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/jstests/sharding/secondary_query_routing.js b/jstests/sharding/secondary_query_routing.js index 8b9649a23ad..ff0dfcb22d9 100644 --- a/jstests/sharding/secondary_query_routing.js +++ b/jstests/sharding/secondary_query_routing.js @@ -4,35 +4,35 @@ */ (function() { -var rsOpts = { nodes: 2 }; -var st = new ShardingTest({ mongos: 2, shards: { rs0: rsOpts, rs1: rsOpts }}); + var rsOpts = { + nodes: 2 + }; + var st = new ShardingTest({mongos: 2, shards: {rs0: rsOpts, rs1: rsOpts}}); -st.s0.adminCommand({ enableSharding: 'test' }); + st.s0.adminCommand({enableSharding: 'test'}); -st.ensurePrimaryShard('test', 'test-rs0'); -st.s0.adminCommand({ shardCollection: 'test.user', key: { x: 1 }}); -st.s0.adminCommand({ split: 'test.user', middle: { x: 0 }}); + st.ensurePrimaryShard('test', 'test-rs0'); + st.s0.adminCommand({shardCollection: 'test.user', key: {x: 1}}); + st.s0.adminCommand({split: 'test.user', middle: {x: 0}}); -st.s1.setReadPref('secondary'); -var testDB = st.s1.getDB('test'); -// This establishes the shard version Mongos #1's view. -testDB.user.insert({ x: 1 }); + st.s1.setReadPref('secondary'); + var testDB = st.s1.getDB('test'); + // This establishes the shard version Mongos #1's view. + testDB.user.insert({x: 1}); -// Mongos #0 bumps up the version without Mongos #1 knowledge. -// Note: moveChunk has implicit { w: 2 } write concern. -st.s0.adminCommand({ moveChunk: 'test.user', - find: { x: 0 }, - to: 'test-rs1', - _waitForDelete: true }); + // Mongos #0 bumps up the version without Mongos #1 knowledge. + // Note: moveChunk has implicit { w: 2 } write concern. + st.s0.adminCommand( + {moveChunk: 'test.user', find: {x: 0}, to: 'test-rs1', _waitForDelete: true}); -// Clear all the connections to make sure that Mongos #1 will attempt to establish -// the shard version. -assert.commandWorked(testDB.adminCommand({ connPoolSync: 1 })); + // Clear all the connections to make sure that Mongos #1 will attempt to establish + // the shard version. + assert.commandWorked(testDB.adminCommand({connPoolSync: 1})); -// Mongos #1 performs a query to the secondary. -var res = testDB.runReadCommand({ count: 'user', query: { x: 1 }}); -assert(res.ok); -assert.eq(1, res.n, tojson(res)); + // Mongos #1 performs a query to the secondary. + var res = testDB.runReadCommand({count: 'user', query: {x: 1}}); + assert(res.ok); + assert.eq(1, res.n, tojson(res)); -st.stop(); + st.stop(); })(); |