diff options
Diffstat (limited to 'jstests/sharding/all_config_servers_blackholed_from_mongos.js')
-rw-r--r-- | jstests/sharding/all_config_servers_blackholed_from_mongos.js | 55 |
1 files changed, 27 insertions, 28 deletions
diff --git a/jstests/sharding/all_config_servers_blackholed_from_mongos.js b/jstests/sharding/all_config_servers_blackholed_from_mongos.js index d13499cc551..53d6e435dd1 100644 --- a/jstests/sharding/all_config_servers_blackholed_from_mongos.js +++ b/jstests/sharding/all_config_servers_blackholed_from_mongos.js @@ -9,41 +9,40 @@ TestData.skipCheckingUUIDsConsistentAcrossCluster = true; (function() { - 'use strict'; +'use strict'; - var st = new ShardingTest({ - shards: 2, - mongos: 1, - useBridge: true, - }); +var st = new ShardingTest({ + 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({}).maxTimeMS(15000).itcount(); - }); +// This shouldn't stall +jsTest.log('Doing read operation on the sharded collection'); +assert.throws(function() { + testDB.ShardedColl.find({}).maxTimeMS(15000).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'}, - {maxTimeMS: 15000})); - - st.stop(); +// 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'}, {maxTimeMS: 15000})); +st.stop(); }()); |