summaryrefslogtreecommitdiff
path: root/jstests/sharding/secondary_shard_versioning.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/secondary_shard_versioning.js')
-rw-r--r--jstests/sharding/secondary_shard_versioning.js160
1 files changed, 80 insertions, 80 deletions
diff --git a/jstests/sharding/secondary_shard_versioning.js b/jstests/sharding/secondary_shard_versioning.js
index 6c92231ec82..94e49c09a5d 100644
--- a/jstests/sharding/secondary_shard_versioning.js
+++ b/jstests/sharding/secondary_shard_versioning.js
@@ -2,98 +2,98 @@
* Tests that secondaries participate in the shard versioning protocol.
*/
(function() {
- "use strict";
+"use strict";
- load('jstests/libs/profiler.js'); // for profilerHasSingleMatchingEntryOrThrow()
+load('jstests/libs/profiler.js'); // for profilerHasSingleMatchingEntryOrThrow()
- // Set the secondaries to priority 0 and votes 0 to prevent the primaries from stepping down.
- let rsOpts = {nodes: [{}, {rsConfig: {priority: 0}}]};
- let st = new ShardingTest({mongos: 2, shards: {rs0: rsOpts, rs1: rsOpts}});
+// Set the secondaries to priority 0 and votes 0 to prevent the primaries from stepping down.
+let rsOpts = {nodes: [{}, {rsConfig: {priority: 0}}]};
+let st = new ShardingTest({mongos: 2, shards: {rs0: rsOpts, rs1: rsOpts}});
- assert.commandWorked(st.s0.adminCommand({enableSharding: 'test'}));
- st.ensurePrimaryShard('test', st.shard0.shardName);
+assert.commandWorked(st.s0.adminCommand({enableSharding: 'test'}));
+st.ensurePrimaryShard('test', st.shard0.shardName);
- assert.commandWorked(st.s0.adminCommand({shardCollection: 'test.foo', key: {x: 1}}));
- assert.commandWorked(st.s0.adminCommand({split: 'test.foo', middle: {x: 0}}));
+assert.commandWorked(st.s0.adminCommand({shardCollection: 'test.foo', key: {x: 1}}));
+assert.commandWorked(st.s0.adminCommand({split: 'test.foo', middle: {x: 0}}));
- let freshMongos = st.s0;
- let staleMongos = st.s1;
+let freshMongos = st.s0;
+let staleMongos = st.s1;
- jsTest.log("do insert from stale mongos to make it load the routing table before the move");
- assert.writeOK(staleMongos.getDB('test').foo.insert({x: 1}));
+jsTest.log("do insert from stale mongos to make it load the routing table before the move");
+assert.writeOK(staleMongos.getDB('test').foo.insert({x: 1}));
- jsTest.log("do moveChunk from fresh mongos");
- assert.commandWorked(freshMongos.adminCommand({
- moveChunk: 'test.foo',
- find: {x: 0},
- to: st.shard1.shardName,
- }));
+jsTest.log("do moveChunk from fresh mongos");
+assert.commandWorked(freshMongos.adminCommand({
+ moveChunk: 'test.foo',
+ find: {x: 0},
+ to: st.shard1.shardName,
+}));
- // Turn on system profiler on secondaries to collect data on all future operations on the db.
- let donorShardSecondary = st.rs0.getSecondary();
- let recipientShardSecondary = st.rs1.getSecondary();
- assert.commandWorked(donorShardSecondary.getDB('test').setProfilingLevel(2));
- assert.commandWorked(recipientShardSecondary.getDB('test').setProfilingLevel(2));
+// Turn on system profiler on secondaries to collect data on all future operations on the db.
+let donorShardSecondary = st.rs0.getSecondary();
+let recipientShardSecondary = st.rs1.getSecondary();
+assert.commandWorked(donorShardSecondary.getDB('test').setProfilingLevel(2));
+assert.commandWorked(recipientShardSecondary.getDB('test').setProfilingLevel(2));
- // Use the mongos with the stale routing table to send read requests to the secondaries. 'local'
- // read concern level must be specified in the request because secondaries default to
- // 'available', which doesn't participate in the version protocol. Check that the donor shard
- // returns a stale shardVersion error, which provokes mongos to refresh its routing table and
- // re-target; that the recipient shard secondary refreshes its routing table on hearing the
- // fresh version from mongos; and that the recipient shard secondary returns the results.
+// Use the mongos with the stale routing table to send read requests to the secondaries. 'local'
+// read concern level must be specified in the request because secondaries default to
+// 'available', which doesn't participate in the version protocol. Check that the donor shard
+// returns a stale shardVersion error, which provokes mongos to refresh its routing table and
+// re-target; that the recipient shard secondary refreshes its routing table on hearing the
+// fresh version from mongos; and that the recipient shard secondary returns the results.
- jsTest.log("do secondary read from stale mongos");
- let res = staleMongos.getDB('test').runCommand({
- count: 'foo',
- query: {x: 1},
- $readPreference: {mode: "secondary"},
- readConcern: {"level": "local"}
- });
- assert(res.ok);
- assert.eq(1, res.n, tojson(res));
+jsTest.log("do secondary read from stale mongos");
+let res = staleMongos.getDB('test').runCommand({
+ count: 'foo',
+ query: {x: 1},
+ $readPreference: {mode: "secondary"},
+ readConcern: {"level": "local"}
+});
+assert(res.ok);
+assert.eq(1, res.n, tojson(res));
- // Check that the donor shard secondary returned stale shardVersion.
- profilerHasSingleMatchingEntryOrThrow({
- profileDB: donorShardSecondary.getDB('test'),
- filter: {
- "ns": "test.foo",
- "command.count": "foo",
- "command.query": {x: 1},
- "command.shardVersion": {"$exists": true},
- "command.$readPreference": {"mode": "secondary"},
- "command.readConcern": {"level": "local"},
- "errCode": ErrorCodes.StaleConfig
- }
- });
+// Check that the donor shard secondary returned stale shardVersion.
+profilerHasSingleMatchingEntryOrThrow({
+ profileDB: donorShardSecondary.getDB('test'),
+ filter: {
+ "ns": "test.foo",
+ "command.count": "foo",
+ "command.query": {x: 1},
+ "command.shardVersion": {"$exists": true},
+ "command.$readPreference": {"mode": "secondary"},
+ "command.readConcern": {"level": "local"},
+ "errCode": ErrorCodes.StaleConfig
+ }
+});
- // The recipient shard secondary will also return stale shardVersion once, even though the
- // mongos is fresh, because the recipient shard secondary was stale.
- profilerHasSingleMatchingEntryOrThrow({
- profileDB: donorShardSecondary.getDB('test'),
- filter: {
- "ns": "test.foo",
- "command.count": "foo",
- "command.query": {x: 1},
- "command.shardVersion": {"$exists": true},
- "command.$readPreference": {"mode": "secondary"},
- "command.readConcern": {"level": "local"},
- "errCode": ErrorCodes.StaleConfig
- }
- });
+// The recipient shard secondary will also return stale shardVersion once, even though the
+// mongos is fresh, because the recipient shard secondary was stale.
+profilerHasSingleMatchingEntryOrThrow({
+ profileDB: donorShardSecondary.getDB('test'),
+ filter: {
+ "ns": "test.foo",
+ "command.count": "foo",
+ "command.query": {x: 1},
+ "command.shardVersion": {"$exists": true},
+ "command.$readPreference": {"mode": "secondary"},
+ "command.readConcern": {"level": "local"},
+ "errCode": ErrorCodes.StaleConfig
+ }
+});
- // Check that the recipient shard secondary received the query and returned results.
- profilerHasSingleMatchingEntryOrThrow({
- profileDB: recipientShardSecondary.getDB('test'),
- filter: {
- "ns": "test.foo",
- "command.count": "foo",
- "command.query": {x: 1},
- "command.shardVersion": {"$exists": true},
- "command.$readPreference": {"mode": "secondary"},
- "command.readConcern": {"level": "local"},
- "errCode": {"$exists": false}
- }
- });
+// Check that the recipient shard secondary received the query and returned results.
+profilerHasSingleMatchingEntryOrThrow({
+ profileDB: recipientShardSecondary.getDB('test'),
+ filter: {
+ "ns": "test.foo",
+ "command.count": "foo",
+ "command.query": {x: 1},
+ "command.shardVersion": {"$exists": true},
+ "command.$readPreference": {"mode": "secondary"},
+ "command.readConcern": {"level": "local"},
+ "errCode": {"$exists": false}
+ }
+});
- st.stop();
+st.stop();
})();
View Lorry Controller Status