mirror of https://github.com/mongodb/mongo
67 lines
2.3 KiB
JavaScript
67 lines
2.3 KiB
JavaScript
/**
|
|
* Tests that during resharding building index phase, we can see how many indexes to build and how
|
|
* many indexes are built.
|
|
*
|
|
* @tags: [
|
|
* requires_fcv_72,
|
|
* ]
|
|
*/
|
|
|
|
import {DiscoverTopology} from "jstests/libs/discover_topology.js";
|
|
import {configureFailPoint} from "jstests/libs/fail_point_util.js";
|
|
import {ReshardingTest} from "jstests/sharding/libs/resharding_test_fixture.js";
|
|
|
|
const reshardingTest = new ReshardingTest({numDonors: 2, enableElections: true});
|
|
reshardingTest.setup();
|
|
|
|
const kDbName = "reshardingDb";
|
|
const kCollName = "resharding_build_index_metrics";
|
|
const ns = kDbName + "." + kCollName;
|
|
|
|
const donorShardNames = reshardingTest.donorShardNames;
|
|
const sourceCollection = reshardingTest.createShardedCollection({
|
|
ns,
|
|
shardKeyPattern: {oldKey: 1},
|
|
chunks: [
|
|
{min: {oldKey: MinKey}, max: {oldKey: 0}, shard: donorShardNames[0]},
|
|
{min: {oldKey: 0}, max: {oldKey: MaxKey}, shard: donorShardNames[1]},
|
|
],
|
|
});
|
|
|
|
const mongos = sourceCollection.getMongo();
|
|
const topology = DiscoverTopology.findConnectedNodes(mongos);
|
|
|
|
const recipientShardNames = reshardingTest.recipientShardNames;
|
|
const recipient = new Mongo(topology.shards[recipientShardNames[0]].primary);
|
|
|
|
// Create an index on oldKey.
|
|
assert.commandWorked(
|
|
mongos.getCollection(ns).insert([
|
|
{oldKey: 1, newKey: -1},
|
|
{oldKey: 2, newKey: -2},
|
|
]),
|
|
);
|
|
assert.commandWorked(mongos.getCollection(ns).createIndex({oldKey: 1}));
|
|
const hangAfterInitializingIndexBuildFailPoint = configureFailPoint(recipient, "hangAfterInitializingIndexBuild");
|
|
|
|
reshardingTest.withReshardingInBackground(
|
|
{
|
|
newShardKeyPattern: {newKey: 1},
|
|
newChunks: [{min: {newKey: MinKey}, max: {newKey: MaxKey}, shard: recipientShardNames[0]}],
|
|
},
|
|
() => {
|
|
hangAfterInitializingIndexBuildFailPoint.wait();
|
|
|
|
jsTestLog("Entered building index phase, check currentOp");
|
|
const report = recipient.getDB("admin").currentOp({ns, desc: {$regex: "ReshardingMetricsRecipientService"}});
|
|
assert.eq(report.inprog.length, 1);
|
|
const curOp = report.inprog[0];
|
|
jsTestLog("Fetched currentOp: " + tojson(curOp));
|
|
// There should be 2 indexes in progress: oldKey and newKey.
|
|
assert.eq(curOp["indexesToBuild"] - curOp["indexesBuilt"], 2);
|
|
hangAfterInitializingIndexBuildFailPoint.off();
|
|
},
|
|
);
|
|
|
|
reshardingTest.teardown();
|