summaryrefslogtreecommitdiff
path: root/jstests/sharding/all_config_servers_blackholed_from_mongos.js
diff options
context:
space:
mode:
Diffstat (limited to 'jstests/sharding/all_config_servers_blackholed_from_mongos.js')
-rw-r--r--jstests/sharding/all_config_servers_blackholed_from_mongos.js57
1 files changed, 27 insertions, 30 deletions
diff --git a/jstests/sharding/all_config_servers_blackholed_from_mongos.js b/jstests/sharding/all_config_servers_blackholed_from_mongos.js
index cf5ec266093..c3ed68e97de 100644
--- a/jstests/sharding/all_config_servers_blackholed_from_mongos.js
+++ b/jstests/sharding/all_config_servers_blackholed_from_mongos.js
@@ -1,44 +1,41 @@
// Ensures that if the config servers are blackholed from the point of view of MongoS, metadata
// operations do not get stuck forever.
(function() {
-'use strict';
+ 'use strict';
-var st = new ShardingTest({
- name: 'all_config_servers_blackholed_from_mongos',
- shards: 2,
- mongos: 1,
- useBridge: true,
-});
+ var st = new ShardingTest({
+ name: 'all_config_servers_blackholed_from_mongos',
+ shards: 2,
+ mongos: 1,
+ useBridge: true,
+ });
-var testDB = st.s.getDB('BlackHoleDB');
+ var testDB = st.s.getDB('BlackHoleDB');
-assert.commandWorked(testDB.adminCommand({ enableSharding: 'BlackHoleDB' }));
-assert.commandWorked(testDB.adminCommand({
- shardCollection: testDB.ShardedColl.getFullName(),
- key: { _id: 1 }
-}));
+ assert.commandWorked(testDB.adminCommand({enableSharding: 'BlackHoleDB'}));
+ assert.commandWorked(
+ testDB.adminCommand({shardCollection: testDB.ShardedColl.getFullName(), key: {_id: 1}}));
-assert.writeOK(testDB.ShardedColl.insert({ a: 1 }));
+ assert.writeOK(testDB.ShardedColl.insert({a: 1}));
-jsTest.log('Making all the config servers appear as a blackhole to mongos');
-st._configServers.forEach(function(configSvr) {
- configSvr.discardMessagesFrom(st.s, 1.0);
-});
+ jsTest.log('Making all the config servers appear as a blackhole to mongos');
+ st._configServers.forEach(function(configSvr) {
+ configSvr.discardMessagesFrom(st.s, 1.0);
+ });
-assert.commandWorked(testDB.adminCommand({ flushRouterConfig: 1 }));
+ assert.commandWorked(testDB.adminCommand({flushRouterConfig: 1}));
-// This shouldn't stall
-jsTest.log('Doing read operation on the sharded collection');
-assert.throws(function() {
- testDB.ShardedColl.find({}).itcount();
-});
+ // This shouldn't stall
+ jsTest.log('Doing read operation on the sharded collection');
+ assert.throws(function() {
+ testDB.ShardedColl.find({}).itcount();
+ });
-// This should fail, because the primary is not available
-jsTest.log('Doing write operation on a new database and collection');
-assert.writeError(st.s.getDB('NonExistentDB').TestColl.insert({
- _id: 0,
- value: 'This value will never be inserted' }));
+ // This should fail, because the primary is not available
+ jsTest.log('Doing write operation on a new database and collection');
+ assert.writeError(st.s.getDB('NonExistentDB')
+ .TestColl.insert({_id: 0, value: 'This value will never be inserted'}));
-st.stop();
+ st.stop();
}());