mirror of https://github.com/mongodb/mongo
69 lines
2.0 KiB
JavaScript
69 lines
2.0 KiB
JavaScript
/**
|
|
* @tags: [
|
|
* multiversion_incompatible,
|
|
* ]
|
|
*/
|
|
|
|
// Don't check for UUID index consistency,orphans and routine table across the cluster at the end,
|
|
// since the test shuts down a mongos
|
|
TestData.skipCheckingUUIDsConsistentAcrossCluster = true;
|
|
TestData.skipCheckingIndexesConsistentAcrossCluster = true;
|
|
TestData.skipCheckOrphans = true;
|
|
TestData.skipCheckRoutingTableConsistency = true;
|
|
TestData.skipCheckShardFilteringMetadata = true;
|
|
|
|
// Do not check metadata consistency as mongos is stopped for testing purposes.
|
|
TestData.skipCheckMetadataConsistency = true;
|
|
|
|
import {configureFailPoint} from "jstests/libs/fail_point_util.js";
|
|
import {Thread} from "jstests/libs/parallelTester.js";
|
|
import {ShardingTest} from "jstests/libs/shardingtest.js";
|
|
|
|
const st = new ShardingTest({
|
|
mongos: 1,
|
|
config: 1,
|
|
shards: 2,
|
|
});
|
|
const dbName = "test";
|
|
const collName = "mycoll";
|
|
const fpData = {
|
|
"cmdName": "insert",
|
|
"ns": dbName + "." + collName,
|
|
};
|
|
const hangBeforeCheckInterruptFailPoint = configureFailPoint(st.s, "hangBeforeCheckingMongosShutdownInterrupt", fpData);
|
|
|
|
const insertThread = new Thread(
|
|
function insertDoc(host, dbName, collName) {
|
|
let lsid = UUID();
|
|
const conn = new Mongo(host);
|
|
const retrySession = conn.startSession({retryWrites: true});
|
|
const retrySessionDB = retrySession.getDatabase(dbName);
|
|
|
|
try {
|
|
let res = assert.commandWorked(
|
|
retrySessionDB.runCommand({
|
|
insert: "mycoll",
|
|
documents: [{x: 0}, {x: 1}],
|
|
ordered: true,
|
|
lsid: {id: lsid},
|
|
txnNumber: NumberLong(1),
|
|
}),
|
|
);
|
|
} catch (e) {
|
|
assert.eq(e.errorLabels, ["RetryableWriteError"], e);
|
|
}
|
|
retrySession.endSession();
|
|
},
|
|
st.s.host,
|
|
dbName,
|
|
collName,
|
|
);
|
|
|
|
insertThread.start();
|
|
hangBeforeCheckInterruptFailPoint.wait();
|
|
|
|
st.stopMongos(0);
|
|
insertThread.join();
|
|
|
|
st.stop();
|