diff options
author | Max Hirschhorn <max.hirschhorn@mongodb.com> | 2021-09-20 22:56:56 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-09-20 23:11:25 +0000 |
commit | 9923a9019d2798e06e5bef0a70410eb85cd01e7d (patch) | |
tree | ad343198a7ebfb312d1ed82389d444246fae1d80 /jstests | |
parent | 4ef58d7c0b03435f5a6b773998296a65f71677b2 (diff) | |
download | mongo-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.js | 57 |
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 |