diff options
author | clang-format-7.0.1 <adam.martin@10gen.com> | 2019-07-26 18:20:35 -0400 |
---|---|---|
committer | ADAM David Alan Martin <adam.martin@10gen.com> | 2019-07-27 11:02:23 -0400 |
commit | 134a4083953270e8a11430395357fb70a29047ad (patch) | |
tree | dd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /jstests/sharding/migration_ignore_interrupts_2.js | |
parent | 1e46b5049003f427047e723ea5fab15b5a9253ca (diff) | |
download | mongo-134a4083953270e8a11430395357fb70a29047ad.tar.gz |
SERVER-41772 Apply clang-format 7.0.1 to the codebase
Diffstat (limited to 'jstests/sharding/migration_ignore_interrupts_2.js')
-rw-r--r-- | jstests/sharding/migration_ignore_interrupts_2.js | 76 |
1 files changed, 38 insertions, 38 deletions
diff --git a/jstests/sharding/migration_ignore_interrupts_2.js b/jstests/sharding/migration_ignore_interrupts_2.js index 718c6a347ff..b60fa50ccf2 100644 --- a/jstests/sharding/migration_ignore_interrupts_2.js +++ b/jstests/sharding/migration_ignore_interrupts_2.js @@ -4,54 +4,54 @@ load('./jstests/libs/chunk_manipulation_util.js'); (function() { - "use strict"; +"use strict"; - var staticMongod = MongoRunner.runMongod({}); // For startParallelOps. +var staticMongod = MongoRunner.runMongod({}); // For startParallelOps. - var st = new ShardingTest({shards: 2}); +var st = new ShardingTest({shards: 2}); - var mongos = st.s0, admin = mongos.getDB('admin'), dbName = "testDB", ns1 = dbName + ".foo", - coll1 = mongos.getCollection(ns1), shard0 = st.shard0, shard1 = st.shard1, - shard0Coll1 = shard0.getCollection(ns1), shard1Coll1 = shard1.getCollection(ns1); +var mongos = st.s0, admin = mongos.getDB('admin'), dbName = "testDB", ns1 = dbName + ".foo", + coll1 = mongos.getCollection(ns1), shard0 = st.shard0, shard1 = st.shard1, + shard0Coll1 = shard0.getCollection(ns1), shard1Coll1 = shard1.getCollection(ns1); - assert.commandWorked(admin.runCommand({enableSharding: dbName})); - st.ensurePrimaryShard(dbName, st.shard0.shardName); - assert.commandWorked(admin.runCommand({shardCollection: ns1, key: {a: 1}})); - assert.writeOK(coll1.insert({a: 0})); - assert.eq(1, shard0Coll1.find().itcount()); - assert.eq(0, shard1Coll1.find().itcount()); - assert.eq(1, coll1.find().itcount()); +assert.commandWorked(admin.runCommand({enableSharding: dbName})); +st.ensurePrimaryShard(dbName, st.shard0.shardName); +assert.commandWorked(admin.runCommand({shardCollection: ns1, key: {a: 1}})); +assert.writeOK(coll1.insert({a: 0})); +assert.eq(1, shard0Coll1.find().itcount()); +assert.eq(0, shard1Coll1.find().itcount()); +assert.eq(1, coll1.find().itcount()); - // Shard0: - // coll1: [-inf, +inf) - // Shard1: +// Shard0: +// coll1: [-inf, +inf) +// Shard1: - jsTest.log("Set up complete, now proceeding to test that migration interruption fails."); +jsTest.log("Set up complete, now proceeding to test that migration interruption fails."); - // Start a migration between shard0 and shard1 on coll1, pause in steady state before commit. - pauseMoveChunkAtStep(shard0, moveChunkStepNames.reachedSteadyState); - var joinMoveChunk = moveChunkParallel( - staticMongod, st.s0.host, {a: 0}, null, coll1.getFullName(), st.shard1.shardName); - waitForMoveChunkStep(shard0, moveChunkStepNames.reachedSteadyState); +// Start a migration between shard0 and shard1 on coll1, pause in steady state before commit. +pauseMoveChunkAtStep(shard0, moveChunkStepNames.reachedSteadyState); +var joinMoveChunk = moveChunkParallel( + staticMongod, st.s0.host, {a: 0}, null, coll1.getFullName(), st.shard1.shardName); +waitForMoveChunkStep(shard0, moveChunkStepNames.reachedSteadyState); - jsTest.log('Sending false commit command....'); - assert.commandFailed( - shard1.adminCommand({'_recvChunkCommit': 1, 'sessionId': "fake-migration-session-id"})); +jsTest.log('Sending false commit command....'); +assert.commandFailed( + shard1.adminCommand({'_recvChunkCommit': 1, 'sessionId': "fake-migration-session-id"})); - jsTest.log("Checking migration recipient is still in steady state, waiting for commit...."); - var res = shard1.adminCommand('_recvChunkStatus'); - assert.commandWorked(res); - assert.eq(true, res.state === "steady", "False commit command succeeded."); +jsTest.log("Checking migration recipient is still in steady state, waiting for commit...."); +var res = shard1.adminCommand('_recvChunkStatus'); +assert.commandWorked(res); +assert.eq(true, res.state === "steady", "False commit command succeeded."); - // Finish migration. - unpauseMoveChunkAtStep(shard0, moveChunkStepNames.reachedSteadyState); - assert.doesNotThrow(function() { - joinMoveChunk(); - }); +// Finish migration. +unpauseMoveChunkAtStep(shard0, moveChunkStepNames.reachedSteadyState); +assert.doesNotThrow(function() { + joinMoveChunk(); +}); - assert.eq(0, shard0Coll1.find().itcount()); - assert.eq(1, shard1Coll1.find().itcount()); +assert.eq(0, shard0Coll1.find().itcount()); +assert.eq(1, shard1Coll1.find().itcount()); - st.stop(); - MongoRunner.stopMongod(staticMongod); +st.stop(); +MongoRunner.stopMongod(staticMongod); })(); |