mirror of https://github.com/mongodb/mongo
66 lines
2.5 KiB
JavaScript
66 lines
2.5 KiB
JavaScript
/**
|
|
* Tests that a drop can't happen while resharding is in progress.
|
|
* @tags: [
|
|
* requires_fcv_53,
|
|
* featureFlagRecoverableShardsvrReshardCollectionCoordinator,
|
|
* ]
|
|
*/
|
|
import {configureFailPoint} from "jstests/libs/fail_point_util.js";
|
|
import {ReplSetTest} from "jstests/libs/replsettest.js";
|
|
import {ShardingTest} from "jstests/libs/shardingtest.js";
|
|
|
|
let st = new ShardingTest({
|
|
shards: {rs0: {nodes: 2}},
|
|
config: TestData.configShard ? 2 : 1,
|
|
mongos: 1,
|
|
other: {
|
|
configOptions: {setParameter: {reshardingCriticalSectionTimeoutMillis: 24 * 60 * 60 * 1000}},
|
|
},
|
|
// By default, our test infrastructure sets the election timeout to a very high value (24
|
|
// hours). For this test, we need a shorter election timeout because it relies on nodes running
|
|
// an election when they do not detect an active primary. Therefore, we are setting the
|
|
// electionTimeoutMillis to its default value.
|
|
initiateWithDefaultElectionTimeout: true,
|
|
});
|
|
|
|
const dbName = "test";
|
|
const collName = "foo";
|
|
const ns = dbName + "." + collName;
|
|
const db = st.s.getDB(dbName);
|
|
|
|
assert.commandWorked(st.s.adminCommand({enableSharding: dbName}));
|
|
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {_id: 1}}));
|
|
|
|
const reshardingPauseCoordinatorBeforeInitializingFailpoint = configureFailPoint(
|
|
st.configRS.getPrimary(),
|
|
"reshardingPauseCoordinatorBeforeInitializing",
|
|
);
|
|
|
|
assert.commandFailedWithCode(
|
|
db.adminCommand({reshardCollection: ns, key: {newKey: 1}, maxTimeMS: 1000, numInitialChunks: 1}),
|
|
ErrorCodes.MaxTimeMSExpired,
|
|
);
|
|
|
|
// Wait for resharding to start running on the configsvr
|
|
reshardingPauseCoordinatorBeforeInitializingFailpoint.wait();
|
|
|
|
// Drop cannot progress while resharding is in progress
|
|
assert.commandFailedWithCode(db.runCommand({drop: collName, maxTimeMS: 5000}), ErrorCodes.MaxTimeMSExpired);
|
|
|
|
// Stepdown the DB primary shard
|
|
const shard0Primary = st.rs0.getPrimary();
|
|
assert.commandWorked(shard0Primary.adminCommand({replSetStepDown: ReplSetTest.kForeverSecs, force: true}));
|
|
st.rs0.awaitNodesAgreeOnPrimary();
|
|
|
|
// Even after stepdown, drop cannot progress due to the in-progress resharding
|
|
assert.commandFailedWithCode(db.runCommand({drop: collName, maxTimeMS: 5000}), ErrorCodes.MaxTimeMSExpired);
|
|
|
|
// Finish resharding
|
|
reshardingPauseCoordinatorBeforeInitializingFailpoint.off();
|
|
assert.commandWorked(db.adminCommand({reshardCollection: ns, key: {newKey: 1}, numInitialChunks: 1}));
|
|
|
|
// Now the drop can complete
|
|
assert.commandWorked(db.runCommand({drop: collName}));
|
|
|
|
st.stop();
|