summaryrefslogtreecommitdiff
path: root/jstests/sharding/migration_ignore_interrupts_2.js
diff options
context:
space:
mode:
authorclang-format-7.0.1 <adam.martin@10gen.com>2019-07-26 18:20:35 -0400
committerADAM David Alan Martin <adam.martin@10gen.com>2019-07-27 11:02:23 -0400
commit134a4083953270e8a11430395357fb70a29047ad (patch)
treedd428e1230e31d92b20b393dfdc17ffe7fa79cb6 /jstests/sharding/migration_ignore_interrupts_2.js
parent1e46b5049003f427047e723ea5fab15b5a9253ca (diff)
downloadmongo-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.js76
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);
})();