summaryrefslogtreecommitdiff
path: root/jstests
diff options
context:
space:
mode:
authorMax Hirschhorn <max.hirschhorn@mongodb.com>2021-09-20 22:56:56 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2021-09-20 23:11:25 +0000
commit9923a9019d2798e06e5bef0a70410eb85cd01e7d (patch)
treead343198a7ebfb312d1ed82389d444246fae1d80 /jstests
parent4ef58d7c0b03435f5a6b773998296a65f71677b2 (diff)
downloadmongo-9923a9019d2798e06e5bef0a70410eb85cd01e7d.tar.gz
Revert "SERVER-55648 Return correct response in case of shutdown"
This reverts commit 211007fa4a705c02e7c373dd6fc148aa4de3a038.
Diffstat (limited to 'jstests')
-rw-r--r--jstests/sharding/retryable_mongos_write_errors.js57
1 files changed, 0 insertions, 57 deletions
diff --git a/jstests/sharding/retryable_mongos_write_errors.js b/jstests/sharding/retryable_mongos_write_errors.js
deleted file mode 100644
index 6d10f1c4f14..00000000000
--- a/jstests/sharding/retryable_mongos_write_errors.js
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * Tests that retryable write errors in MongoS return a top level error message.
- */
-
-(function() {
- "use strict";
-
- load("jstests/libs/fail_point_util.js");
- load('jstests/libs/parallelTester.js'); // for ScopedThread.
-
- // Creates a new connection, uses it to get the database from the parameter name and inserts
- // multiple documents to the provided collection.
- function insertHandler(host, databaseName, collectionName) {
- const conn = new Mongo(host);
- const database = conn.getDB(databaseName);
- // creates an array with 10 documents
- const docs = Array.from(Array(10).keys()).map((i) => ({a: i, b: "retryable"}));
- return database.runCommand({insert: collectionName, documents: docs});
- }
-
- const dbName = "test";
- const collName = "retryable_mongos_write_errors";
- const ns = dbName + "." + collName;
-
- const st = new ShardingTest({config: 1, mongos: 1, shards: 1});
- const shard0Primary = st.rs0.getPrimary();
-
- const insertFailPoint =
- configureFailPoint(shard0Primary, "hangAfterCollectionInserts", {collectionNS: ns});
-
- const insertThread = new Thread(insertHandler, st.s.host, dbName, collName);
- jsTest.log("Starting To Insert Documents");
- insertThread.start();
- insertFailPoint.wait();
- MongoRunner.stopMongos(st.s);
-
- try {
- const commandResponse = insertThread.returnData();
- jsTest.log("Command Response: " + tojson(commandResponse) + "." + commandResponse.code);
- // assert that retryableInsertRes failed with the HostUnreachableError or
- // InterruptedAtShutdown error code
- assert.eq(commandResponse.code, ErrorCodes.InterruptedAtShutdown, tojson(commandResponse));
- } catch (e) {
- jsTest.log("Error ocurred: " + e);
- if (!isNetworkError(e)) {
- throw e;
- }
- }
-
- jsTest.log("Finished Assertions, Turning Off Failpoint");
-
- insertFailPoint.off();
- st.s = MongoRunner.runMongos(st.s);
-
- jsTest.log('Shutting down sharding test');
- st.stop();
-}()); \ No newline at end of file