diff options
author | Kevin Albertson <kevin.albertson@10gen.com> | 2018-04-25 07:53:19 -0400 |
---|---|---|
committer | Max Hirschhorn <max.hirschhorn@mongodb.com> | 2018-04-25 07:53:19 -0400 |
commit | 03f89bb1588cfa2592586e4fbabc6eb14edd6591 (patch) | |
tree | 1275b019dd4dfbbd2a05598533192e1cbc2f133f /jstests/replsets | |
parent | da6a8e6c7842e8f17acf89bfbf7a89384d5cc49d (diff) | |
download | mongo-03f89bb1588cfa2592586e4fbabc6eb14edd6591.tar.gz |
SERVER-25640 terminate running processes in jstests
(cherry picked from commit c556e377094792e7253a95cb5fedcd703a99bf2c)
Diffstat (limited to 'jstests/replsets')
71 files changed, 88 insertions, 12 deletions
diff --git a/jstests/replsets/apply_ops_create_indexes.js b/jstests/replsets/apply_ops_create_indexes.js index 8a9e5303916..4fe813b5ed4 100644 --- a/jstests/replsets/apply_ops_create_indexes.js +++ b/jstests/replsets/apply_ops_create_indexes.js @@ -97,4 +97,6 @@ localDB = rst.getPrimary().getDB("local"); ensureOplogEntryExists(localDB, insertFormatIndexName); + + rst.stopSet(); }()); diff --git a/jstests/replsets/apply_ops_create_view.js b/jstests/replsets/apply_ops_create_view.js index 4554ea2dc76..0aac71ee490 100644 --- a/jstests/replsets/apply_ops_create_view.js +++ b/jstests/replsets/apply_ops_create_view.js @@ -14,4 +14,6 @@ const cmd = {applyOps: [{op: "c", ns: db + ".$cmd", o: {create: "foo", viewOn: "bar"}}]}; assert.commandWorked(db.runCommand(cmd), tojson(cmd)); assert.eq(db.foo.findOne({a: 1}).b, "hi"); + + replTest.stopSet(); }()); diff --git a/jstests/replsets/apply_ops_create_with_uuid.js b/jstests/replsets/apply_ops_create_with_uuid.js index 3628d6700f2..d3f69fc2a71 100644 --- a/jstests/replsets/apply_ops_create_with_uuid.js +++ b/jstests/replsets/apply_ops_create_with_uuid.js @@ -47,4 +47,5 @@ assert.eq(db.getCollectionInfos({name: "foo"}).length, 0, "expected foo collection to no longer exist"); + replTest.stopSet(); }()); diff --git a/jstests/replsets/apply_ops_idempotency.js b/jstests/replsets/apply_ops_idempotency.js index 3a2f6d4f3d7..7173bbd0301 100644 --- a/jstests/replsets/apply_ops_idempotency.js +++ b/jstests/replsets/apply_ops_idempotency.js @@ -194,4 +194,6 @@ for (let f in tests) testIdempotency(rst.getPrimary(), tests[f], f); + + rst.stopSet(); })(); diff --git a/jstests/replsets/apply_ops_wc.js b/jstests/replsets/apply_ops_wc.js index f44993705f9..793a9f43e99 100644 --- a/jstests/replsets/apply_ops_wc.js +++ b/jstests/replsets/apply_ops_wc.js @@ -135,4 +135,5 @@ secondaries[0].getDB('admin').runCommand({configureFailPoint: 'rsSyncApplyStop', mode: 'off'}); secondaries[1].getDB('admin').runCommand({configureFailPoint: 'rsSyncApplyStop', mode: 'off'}); + replTest.stopSet(); })(); diff --git a/jstests/replsets/auth1.js b/jstests/replsets/auth1.js index 9ab12cc7157..211beb9016e 100644 --- a/jstests/replsets/auth1.js +++ b/jstests/replsets/auth1.js @@ -207,4 +207,6 @@ load("jstests/replsets/rslib.js"); } return true; }); + MongoRunner.stopMongod(conn); + rs.stopSet(); })(); diff --git a/jstests/replsets/catchup.js b/jstests/replsets/catchup.js index c58dde887c0..82d542e9bbd 100644 --- a/jstests/replsets/catchup.js +++ b/jstests/replsets/catchup.js @@ -206,4 +206,5 @@ rst.awaitReplication(); checkOpInOplog(steppedDownPrimary, stepUpResults.latestOpOnOldPrimary, 1); + rst.stopSet(); })(); diff --git a/jstests/replsets/catchup_takeover_two_nodes_ahead.js b/jstests/replsets/catchup_takeover_two_nodes_ahead.js index 2c0fd0eb5fa..f4a59cb567b 100644 --- a/jstests/replsets/catchup_takeover_two_nodes_ahead.js +++ b/jstests/replsets/catchup_takeover_two_nodes_ahead.js @@ -56,4 +56,5 @@ replSet.waitForState(2, ReplSetTest.State.SECONDARY, replSet.kDefaultTimeoutMS); // Let the nodes catchup. restartServerReplication(nodes.slice(1, 5)); + replSet.stopSet(); })(); diff --git a/jstests/replsets/collate_id.js b/jstests/replsets/collate_id.js index 73a34c22433..6e6d56bc67d 100644 --- a/jstests/replsets/collate_id.js +++ b/jstests/replsets/collate_id.js @@ -62,4 +62,5 @@ secondaryDB.adminCommand({configureFailPoint: "rsSyncApplyStop", mode: "off"})); replTest.awaitReplication(); assert.eq(0, secondaryColl.find().itcount()); + replTest.stopSet(); })(); diff --git a/jstests/replsets/commands_that_write_accept_wc.js b/jstests/replsets/commands_that_write_accept_wc.js index 08af483b93a..b2dd90d2886 100644 --- a/jstests/replsets/commands_that_write_accept_wc.js +++ b/jstests/replsets/commands_that_write_accept_wc.js @@ -148,4 +148,5 @@ load('jstests/libs/write_concern_util.js'); testInvalidWriteConcern(cmd); }); + replTest.stopSet(); })(); diff --git a/jstests/replsets/copydb.js b/jstests/replsets/copydb.js index 2746035f6ef..e63f6e4b393 100644 --- a/jstests/replsets/copydb.js +++ b/jstests/replsets/copydb.js @@ -93,4 +93,5 @@ assert.eq(primaryTargetDB.foo.getIndexes().length, secondaryTargetDB.foo.getIndexes().length, 'incorrect number of indexes in target collection on secondary after copy'); + replTest.stopSet(); }()); diff --git a/jstests/replsets/dbhash_system_collections.js b/jstests/replsets/dbhash_system_collections.js index c55156a4992..c60532dfe1c 100644 --- a/jstests/replsets/dbhash_system_collections.js +++ b/jstests/replsets/dbhash_system_collections.js @@ -51,4 +51,5 @@ var primaryMd5 = checkDbHash(primary); var secondaryMd5 = checkDbHash(secondary); assert.eq(primaryMd5, secondaryMd5, 'dbhash is different on the primary and the secondary'); + rst.stopSet(); })(); diff --git a/jstests/replsets/double_rollback.js b/jstests/replsets/double_rollback.js index fe2eaccf165..9faf66263a4 100644 --- a/jstests/replsets/double_rollback.js +++ b/jstests/replsets/double_rollback.js @@ -143,5 +143,5 @@ // Verify data consistency between nodes. rst.checkReplicatedDataHashes(); rst.checkOplogs(); - + rst.stopSet(); }()); diff --git a/jstests/replsets/drain.js b/jstests/replsets/drain.js index 1f60713a6a6..41e8d475f83 100644 --- a/jstests/replsets/drain.js +++ b/jstests/replsets/drain.js @@ -106,4 +106,5 @@ // secondary and we cannot guarantee all writes reached the secondary's op queue prior to // shutting down the original primary. assert.gte(primary.getDB("foo").foo.find().itcount(), 2); + replSet.stopSet(); })(); diff --git a/jstests/replsets/drop_oplog.js b/jstests/replsets/drop_oplog.js index 8e2a7c2e1d2..2ba8dc44c72 100644 --- a/jstests/replsets/drop_oplog.js +++ b/jstests/replsets/drop_oplog.js @@ -32,5 +32,5 @@ renameOutput = localDB.foo.renameCollection("oplog.rs"); assert.eq(renameOutput.ok, 0); assert.eq(renameOutput.errmsg, "can't rename to live oplog while replicating"); - + rt.stopSet(); }()); diff --git a/jstests/replsets/election_id.js b/jstests/replsets/election_id.js index ff079ca1172..c6259020003 100644 --- a/jstests/replsets/election_id.js +++ b/jstests/replsets/election_id.js @@ -96,5 +96,6 @@ load("jstests/replsets/rslib.js"); var newElectionId = res.repl.electionId; assert.lt(oldElectionId.valueOf(), newElectionId.valueOf()); oldElectionId = newElectionId; + rst.stopSet(); })(); diff --git a/jstests/replsets/emptycapped.js b/jstests/replsets/emptycapped.js index 39a5c0eac56..c6b08fff9dc 100644 --- a/jstests/replsets/emptycapped.js +++ b/jstests/replsets/emptycapped.js @@ -92,4 +92,5 @@ {create: "view1", viewOn: "collection", pipeline: [{$match: {}}]})); assert.commandFailedWithCode(primaryTestDB.runCommand({emptycapped: "system.views"}), ErrorCodes.IllegalOperation); + rst.stopSet(); })(); diff --git a/jstests/replsets/explain_slaveok.js b/jstests/replsets/explain_slaveok.js index 8cd715af648..68eda89bce7 100644 --- a/jstests/replsets/explain_slaveok.js +++ b/jstests/replsets/explain_slaveok.js @@ -151,3 +151,4 @@ explainOut = secondary.getDB("test").runCommand({ verbosity: "executionStats" }); assert.commandFailed(explainOut, "explain write op on secondary, slaveOk true"); +replTest.stopSet(); diff --git a/jstests/replsets/get_replication_info_helper.js b/jstests/replsets/get_replication_info_helper.js index cd6ef7d8a10..920b729f636 100644 --- a/jstests/replsets/get_replication_info_helper.js +++ b/jstests/replsets/get_replication_info_helper.js @@ -51,5 +51,5 @@ assert.soon(function() { return rawMongoProgramOutput().match("behind the freshest"); }); - + replSet.stopSet(); })(); diff --git a/jstests/replsets/index_delete.js b/jstests/replsets/index_delete.js index c89a3d47348..5f64979dbc3 100644 --- a/jstests/replsets/index_delete.js +++ b/jstests/replsets/index_delete.js @@ -121,3 +121,5 @@ assert.soon(function() { return 1 == secondDB[collName].getIndexes().length; }, "Indexes not dropped on secondary"); assert.eq(1, secondDB[collName].getIndexes().length); + +replTest.stopSet(); diff --git a/jstests/replsets/index_restart_secondary.js b/jstests/replsets/index_restart_secondary.js index be328ede8bc..0b391d5f8e2 100644 --- a/jstests/replsets/index_restart_secondary.js +++ b/jstests/replsets/index_restart_secondary.js @@ -75,3 +75,5 @@ if (conns[0].getDB('test').serverBuildInfo().bits !== 32) { jsTest.log("index-restart-secondary.js complete"); } + +replTest.stopSet(); diff --git a/jstests/replsets/initial_sync4.js b/jstests/replsets/initial_sync4.js index e0ff50af4a2..89b5f42f39a 100644 --- a/jstests/replsets/initial_sync4.js +++ b/jstests/replsets/initial_sync4.js @@ -81,6 +81,6 @@ assert.eq(mc.getIndexKeys().length, sc.getIndexKeys().length); assert.eq(mc.find().sort({x: 1}).itcount(), sc.find().sort({x: 1}).itcount()); - + MongoRunner.stopMongod(s); replTest.stopSet(15); -}());
\ No newline at end of file +}()); diff --git a/jstests/replsets/initial_sync_applier_error.js b/jstests/replsets/initial_sync_applier_error.js index 7a280242024..36182e58c39 100644 --- a/jstests/replsets/initial_sync_applier_error.js +++ b/jstests/replsets/initial_sync_applier_error.js @@ -52,4 +52,5 @@ assert.eq(0, secondary.getDB('test').getCollection(name).count()); assert.eq(1, secondary.getDB('test').getCollection(newCollName).count()); assert.eq("hi", secondary.getDB('test').getCollection(newCollName).findOne({_id: 0}).content); + replSet.stopSet(); })(); diff --git a/jstests/replsets/initial_sync_capped_index.js b/jstests/replsets/initial_sync_capped_index.js index 2100b6f14bc..66895864d03 100644 --- a/jstests/replsets/initial_sync_capped_index.js +++ b/jstests/replsets/initial_sync_capped_index.js @@ -122,5 +122,5 @@ var failMsg = "Index validation of '" + secondaryCappedColl.name + "' failed: " + tojson(validate_result); assert(validate_result.valid, failMsg); - + replTest.stopSet(); })(); diff --git a/jstests/replsets/initial_sync_move_forward.js b/jstests/replsets/initial_sync_move_forward.js index 410b1eb707a..17f12a881d0 100644 --- a/jstests/replsets/initial_sync_move_forward.js +++ b/jstests/replsets/initial_sync_move_forward.js @@ -95,4 +95,5 @@ var indexSpec = GetIndexHelpers.findByKeyPattern(secondaryColl.getIndexes(), {x: 1}); assert.neq(null, indexSpec); assert.eq(true, indexSpec.unique); -})();
\ No newline at end of file + rst.stopSet(); +})(); diff --git a/jstests/replsets/initial_sync_oplog_rollover.js b/jstests/replsets/initial_sync_oplog_rollover.js index 95c93566f12..1ffdc6220c2 100644 --- a/jstests/replsets/initial_sync_oplog_rollover.js +++ b/jstests/replsets/initial_sync_oplog_rollover.js @@ -62,4 +62,5 @@ assert.eq(0, secondary.getDB('local')['temp_oplog_buffer'].find().itcount(), "Oplog buffer was not dropped after initial sync"); + replSet.stopSet(); })(); diff --git a/jstests/replsets/initial_sync_replSetGetStatus.js b/jstests/replsets/initial_sync_replSetGetStatus.js index 5d8398b5802..abb5e5c563f 100644 --- a/jstests/replsets/initial_sync_replSetGetStatus.js +++ b/jstests/replsets/initial_sync_replSetGetStatus.js @@ -87,4 +87,5 @@ assert.eq(0, secondary.getDB('local')['temp_oplog_buffer'].find().itcount(), "Oplog buffer was not dropped after initial sync"); + replSet.stopSet(); })(); diff --git a/jstests/replsets/initiate_replset_on_downgraded_standalone_node.js b/jstests/replsets/initiate_replset_on_downgraded_standalone_node.js index 9593c69c1cf..309a9cfd207 100644 --- a/jstests/replsets/initiate_replset_on_downgraded_standalone_node.js +++ b/jstests/replsets/initiate_replset_on_downgraded_standalone_node.js @@ -37,4 +37,5 @@ // Check an arbitrary collection's uuid field. assert.eq(undefined, getUUIDFromListCollections(conn.getDB("local"), "startup_log")); + MongoRunner.stopMongod(conn); }()); diff --git a/jstests/replsets/last_op_visible.js b/jstests/replsets/last_op_visible.js index f5a50596ea4..99b081d8a26 100644 --- a/jstests/replsets/last_op_visible.js +++ b/jstests/replsets/last_op_visible.js @@ -52,5 +52,5 @@ load("jstests/replsets/rslib.js"); {"$replData": 1}); assert.commandWorked(res.commandReply); assert.eq(last_op_visible, res.metadata["$replData"].lastOpVisible); - + replTest.stopSet(); }()); diff --git a/jstests/replsets/lastop.js b/jstests/replsets/lastop.js index e1bf6c6fbd4..497afa1c9c5 100644 --- a/jstests/replsets/lastop.js +++ b/jstests/replsets/lastop.js @@ -130,5 +130,5 @@ m1.getCollection("test.foo").update({m1: 1}, {$set: {m1: 4}}); noOp = m1.getCollection("test.foo").getDB().getLastErrorObj().lastOp; assert.eq(noOp, fifthteenthOp); - + replTest.stopSet(); })(); diff --git a/jstests/replsets/linearizable_read_concern.js b/jstests/replsets/linearizable_read_concern.js index 80c435aaccb..da544cc9e55 100644 --- a/jstests/replsets/linearizable_read_concern.js +++ b/jstests/replsets/linearizable_read_concern.js @@ -122,4 +122,5 @@ load('jstests/libs/write_concern_util.js'); print('replSetStepDown did not throw exception but returned: ' + tojson(result)); }); parallelShell(); + replTest.stopSet(); }()); diff --git a/jstests/replsets/maintenance.js b/jstests/replsets/maintenance.js index 8b4765212b8..77934123e68 100644 --- a/jstests/replsets/maintenance.js +++ b/jstests/replsets/maintenance.js @@ -93,3 +93,4 @@ result = conns[1].getDB("admin").runCommand({replSetMaintenance: 0}); assert.eq(result.ok, 1, tojson(result)); secondarySoon(); +replTest.stopSet(); diff --git a/jstests/replsets/maintenance_non-blocking.js b/jstests/replsets/maintenance_non-blocking.js index 4606bcc1985..5581ffe3546 100644 --- a/jstests/replsets/maintenance_non-blocking.js +++ b/jstests/replsets/maintenance_non-blocking.js @@ -41,6 +41,7 @@ doTest = function() { print("******* fsyncUnlock'n secondary ************* "); sDB.fsyncUnlock(); + replTest.stopSet(); }; doTest(); diff --git a/jstests/replsets/no_chaining.js b/jstests/replsets/no_chaining.js index 07a67c3ea2b..8aea02776eb 100644 --- a/jstests/replsets/no_chaining.js +++ b/jstests/replsets/no_chaining.js @@ -60,3 +60,5 @@ if (!_isWindows()) { var config = master.getDB("local").system.replset.findOne(); assert.eq(false, config.settings.chainingAllowed, tojson(config)); } + +replTest.stopSet(); diff --git a/jstests/replsets/noop_writes_wait_for_write_concern.js b/jstests/replsets/noop_writes_wait_for_write_concern.js index 61ffc518df4..455a99f1456 100644 --- a/jstests/replsets/noop_writes_wait_for_write_concern.js +++ b/jstests/replsets/noop_writes_wait_for_write_concern.js @@ -232,4 +232,5 @@ testCommandWithWriteConcern(cmd); }); -})();
\ No newline at end of file + replTest.stopSet(); +})(); diff --git a/jstests/replsets/oplog_term.js b/jstests/replsets/oplog_term.js index 76ba6babfa7..70339e0d523 100644 --- a/jstests/replsets/oplog_term.js +++ b/jstests/replsets/oplog_term.js @@ -53,4 +53,6 @@ assert.eq(status.term, oplogEntry.t, 'term in oplog entry does not match term in status: ' + tojson(oplogEntry)); + + replSet.stopSet(); })(); diff --git a/jstests/replsets/oplog_wallclock.js b/jstests/replsets/oplog_wallclock.js index bedb27e95e0..b11b125923b 100644 --- a/jstests/replsets/oplog_wallclock.js +++ b/jstests/replsets/oplog_wallclock.js @@ -26,4 +26,5 @@ assert.writeOK(collection.remove({_id: 1})); assertLastOplogHasWT(primary, 'remove'); + replSet.stopSet(); })(); diff --git a/jstests/replsets/pipelineout.js b/jstests/replsets/pipelineout.js index 44441e63d5c..8849a356b02 100644 --- a/jstests/replsets/pipelineout.js +++ b/jstests/replsets/pipelineout.js @@ -30,3 +30,5 @@ assert.throws(function() { primary.coll.aggregate({$out: "out"}).itcount(); replTest.awaitReplication(); assert.eq(primary.out.find().sort({x: 1}).toArray(), secondary.out.find().sort({x: 1}).toArray()); + +replTest.stopSet(); diff --git a/jstests/replsets/plan_cache_slaveok.js b/jstests/replsets/plan_cache_slaveok.js index 2de5749f086..1703620a0d5 100644 --- a/jstests/replsets/plan_cache_slaveok.js +++ b/jstests/replsets/plan_cache_slaveok.js @@ -70,3 +70,5 @@ assertPlanCacheCommandsFail(secondary.getDB("test")); // With slave ok true, the commands should succeed on the secondary. secondary.getDB("test").getMongo().setSlaveOk(true); assertPlanCacheCommandsSucceed(secondary.getDB("test")); + +replTest.stopSet(); diff --git a/jstests/replsets/priority_takeover_cascading_priorities.js b/jstests/replsets/priority_takeover_cascading_priorities.js index e210d250f10..f55997aa5c2 100644 --- a/jstests/replsets/priority_takeover_cascading_priorities.js +++ b/jstests/replsets/priority_takeover_cascading_priorities.js @@ -32,4 +32,5 @@ replSet.waitForState(2, ReplSetTest.State.PRIMARY); // Cannot stop any more nodes because we will not have a majority. + replSet.stopSet(); })(); diff --git a/jstests/replsets/priority_takeover_one_node_higher_priority.js b/jstests/replsets/priority_takeover_one_node_higher_priority.js index 3059ea2cd00..b4385cc2376 100644 --- a/jstests/replsets/priority_takeover_one_node_higher_priority.js +++ b/jstests/replsets/priority_takeover_one_node_higher_priority.js @@ -42,4 +42,5 @@ // Eventually node 0 will stand for election again because it has a higher priorty. replSet.waitForState(replSet.nodes[0], ReplSetTest.State.PRIMARY); + replSet.stopSet(); })(); diff --git a/jstests/replsets/priority_takeover_two_nodes_equal_priority.js b/jstests/replsets/priority_takeover_two_nodes_equal_priority.js index 10f31796b2a..e05805b1e96 100644 --- a/jstests/replsets/priority_takeover_two_nodes_equal_priority.js +++ b/jstests/replsets/priority_takeover_two_nodes_equal_priority.js @@ -52,5 +52,6 @@ load('jstests/replsets/rslib.js'); jsTestLog("Waiting for the other high priority node to become PRIMARY."); var expectedNewPrimary = replTest.nodes[expectedNewPrimaryIndex]; replTest.waitForState(expectedNewPrimary, ReplSetTest.State.PRIMARY); + replTest.stopSet(); })(); diff --git a/jstests/replsets/protocol_version_upgrade_downgrade.js b/jstests/replsets/protocol_version_upgrade_downgrade.js index 06bd26f2d94..8233babe999 100644 --- a/jstests/replsets/protocol_version_upgrade_downgrade.js +++ b/jstests/replsets/protocol_version_upgrade_downgrade.js @@ -88,5 +88,6 @@ load("jstests/replsets/rslib.js"); res = primary.adminCommand({replSetGetStatus: 1}); assert.commandWorked(res); assert.eq(res.members[0].optime.ts, null); + rst.stopSet(); })(); diff --git a/jstests/replsets/read_committed.js b/jstests/replsets/read_committed.js index 22424ce020a..899778dd7b5 100644 --- a/jstests/replsets/read_committed.js +++ b/jstests/replsets/read_committed.js @@ -172,4 +172,5 @@ load("jstests/replsets/rslib.js"); // For startSetIfSupportsReadMajority. assert.eq(doCommittedRead(secondaryColl), test.expectedAfter); } } + replTest.stopSet(); }()); diff --git a/jstests/replsets/read_committed_after_rollback.js b/jstests/replsets/read_committed_after_rollback.js index 9276449b488..68a80b7bdda 100644 --- a/jstests/replsets/read_committed_after_rollback.js +++ b/jstests/replsets/read_committed_after_rollback.js @@ -150,4 +150,5 @@ load("jstests/replsets/rslib.js"); // For startSetIfSupportsReadMajority. // Verify data consistency between nodes. replTest.checkReplicatedDataHashes(); replTest.checkOplogs(); + replTest.stopSet(); }()); diff --git a/jstests/replsets/read_committed_lookup.js b/jstests/replsets/read_committed_lookup.js index 7e7f1f47ae3..1f4ea4452f9 100644 --- a/jstests/replsets/read_committed_lookup.js +++ b/jstests/replsets/read_committed_lookup.js @@ -41,4 +41,5 @@ load("jstests/libs/read_committed_lib.js"); // For testReadCommittedLookup testReadCommittedLookup(rst.getPrimary().getDB("test"), shardSecondary, rst); + rst.stopSet(); })(); diff --git a/jstests/replsets/read_committed_no_snapshots.js b/jstests/replsets/read_committed_no_snapshots.js index 120129f3a57..ce83b2e2247 100644 --- a/jstests/replsets/read_committed_no_snapshots.js +++ b/jstests/replsets/read_committed_no_snapshots.js @@ -80,4 +80,5 @@ load("jstests/replsets/rslib.js"); // For reconfig and startSetIfSupportsReadMa // Ensure maxTimeMS times out while waiting for this snapshot assert.commandFailed(primary.getSiblingDB(name).foo.runCommand( 'find', {"readConcern": {"level": "majority"}, "maxTimeMS": 1000})); + replTest.stopSet(); })(); diff --git a/jstests/replsets/read_committed_with_catalog_changes.js b/jstests/replsets/read_committed_with_catalog_changes.js index 8a48593ec3b..00a73c72161 100644 --- a/jstests/replsets/read_committed_with_catalog_changes.js +++ b/jstests/replsets/read_committed_with_catalog_changes.js @@ -349,4 +349,6 @@ load("jstests/replsets/rslib.js"); // For startSetIfSupportsReadMajority. threads.forEach(thread => thread.join()); } } + + replTest.stopSet(); }()); diff --git a/jstests/replsets/rename_collection_temp.js b/jstests/replsets/rename_collection_temp.js index 3add505a4f6..c52808b14fd 100644 --- a/jstests/replsets/rename_collection_temp.js +++ b/jstests/replsets/rename_collection_temp.js @@ -75,4 +75,6 @@ replTest.awaitReplication(); checkCollectionTemp(secondaryFoo, "permanentColl", false); + + replTest.stopSet(); }()); diff --git a/jstests/replsets/replset6.js b/jstests/replsets/replset6.js index 4afd7268bf7..c0419f3c4db 100644 --- a/jstests/replsets/replset6.js +++ b/jstests/replsets/replset6.js @@ -65,3 +65,4 @@ assert.eq(1, s.getDB(second).two.findOne().a); // Make sure the source collection no longer exists. assert.eq(-1, s.getDB(first).getCollectionNames().indexOf("one")); +rt.stopSet(); diff --git a/jstests/replsets/replset8.js b/jstests/replsets/replset8.js index 8027ce72a2b..23169a2ff6a 100644 --- a/jstests/replsets/replset8.js +++ b/jstests/replsets/replset8.js @@ -82,4 +82,5 @@ slave.getDB('d')['c'].count() + ')'); jsTestLog("finished"); + rt.stopSet(); })(); diff --git a/jstests/replsets/replsetprio1.js b/jstests/replsets/replsetprio1.js index 7ee42a18a64..dc2d5295e4e 100644 --- a/jstests/replsets/replsetprio1.js +++ b/jstests/replsets/replsetprio1.js @@ -51,4 +51,5 @@ assert(master.getDB("foo").bar.findOne({i: i}) != null, 'checking ' + i); assert(master.getDB("bar").baz.findOne({i: i}) != null, 'checking ' + i); } + replTest.stopSet(); }()); diff --git a/jstests/replsets/replsetrestart1.js b/jstests/replsets/replsetrestart1.js index 870cdcfe233..388de3e1b71 100644 --- a/jstests/replsets/replsetrestart1.js +++ b/jstests/replsets/replsetrestart1.js @@ -66,4 +66,5 @@ replTest.awaitSecondaryNodes(); var config2 = master.getDB("local").system.replset.findOne(); compare_configs(config1, config2); + replTest.stopSet(); }()); diff --git a/jstests/replsets/replsets_killop.js b/jstests/replsets/replsets_killop.js index 7d31f313633..4e41046f8c8 100644 --- a/jstests/replsets/replsets_killop.js +++ b/jstests/replsets/replsets_killop.js @@ -68,3 +68,4 @@ function allReplicated() { // Wait for the correct number of (replicated) documents to be present on the secondary. assert.soon(allReplicated, "didn't replicate all docs", 5 * 60 * 1000); +replTest.stopSet(); diff --git a/jstests/replsets/request_primary_stepdown.js b/jstests/replsets/request_primary_stepdown.js index b9997e03a23..2b95377a153 100644 --- a/jstests/replsets/request_primary_stepdown.js +++ b/jstests/replsets/request_primary_stepdown.js @@ -41,5 +41,5 @@ assert.eq(logContents.indexOf("stepdown period must be longer than secondaryCatchUpPeriodSecs"), -1, "_requestRemotePrimaryStepDown sent an invalid replSetStepDown command"); - + replSet.stopSet(); })(); diff --git a/jstests/replsets/restore_term.js b/jstests/replsets/restore_term.js index b5bb7b013bd..a303d92d0db 100644 --- a/jstests/replsets/restore_term.js +++ b/jstests/replsets/restore_term.js @@ -64,4 +64,5 @@ load("jstests/replsets/rslib.js"); // After restart, the new primary stands up with the newer term. assert.gte(getCurrentTerm(primary), firstSuccessfulTerm + 1); + rst.stopSet(); })(); diff --git a/jstests/replsets/rollback_with_socket_error_then_steady_state.js b/jstests/replsets/rollback_with_socket_error_then_steady_state.js index 98dfc368f7e..48aac9a91b3 100644 --- a/jstests/replsets/rollback_with_socket_error_then_steady_state.js +++ b/jstests/replsets/rollback_with_socket_error_then_steady_state.js @@ -136,5 +136,6 @@ // Verify data consistency between nodes. rst.checkReplicatedDataHashes(); rst.checkOplogs(); + rst.stopSet(); }()); diff --git a/jstests/replsets/single_server_majority.js b/jstests/replsets/single_server_majority.js index c36f021c989..2b70d05280a 100644 --- a/jstests/replsets/single_server_majority.js +++ b/jstests/replsets/single_server_majority.js @@ -9,4 +9,5 @@ col = db.getCollection("single_server_majority"); col.drop(); // see if we can get a majority write on this single server -assert.writeOK(col.save({a: "test"}, {writeConcern: {w: 'majority'}}));
\ No newline at end of file +assert.writeOK(col.save({a: "test"}, {writeConcern: {w: 'majority'}})); +MongoRunner.stopMongod(mongod); diff --git a/jstests/replsets/startParallelShell.js b/jstests/replsets/startParallelShell.js index b04e4abf2f3..0027c5600e3 100644 --- a/jstests/replsets/startParallelShell.js +++ b/jstests/replsets/startParallelShell.js @@ -32,4 +32,5 @@ var db; return db.coll0.find({test: "explicit port"}).count() === 1; }); awaitShell(); + replSet.stopSet(); })(); diff --git a/jstests/replsets/step_down_during_draining.js b/jstests/replsets/step_down_during_draining.js index 0ea89a27275..03f6a29d58f 100644 --- a/jstests/replsets/step_down_during_draining.js +++ b/jstests/replsets/step_down_during_draining.js @@ -130,4 +130,5 @@ load("jstests/replsets/rslib.js"); // Check that all writes reached the secondary's op queue prior to // stepping down the original primary and got applied. assert.eq(secondary.getDB("foo").foo.find().itcount(), numDocuments); + replSet.stopSet(); })(); diff --git a/jstests/replsets/step_down_during_draining2.js b/jstests/replsets/step_down_during_draining2.js index 611a80872bb..2d91910fbca 100644 --- a/jstests/replsets/step_down_during_draining2.js +++ b/jstests/replsets/step_down_during_draining2.js @@ -170,4 +170,5 @@ assert.writeOK(secondary.getDB("foo").flag.insert({sentinel: 1}, {writeConcern: {w: 3}})); // Check that no writes were lost. assert.eq(secondary.getDB("foo").foo.find().itcount(), numDocuments); + replSet.stopSet(); })(); diff --git a/jstests/replsets/step_down_during_draining3.js b/jstests/replsets/step_down_during_draining3.js index a9148eb5b44..b62e288e6d8 100644 --- a/jstests/replsets/step_down_during_draining3.js +++ b/jstests/replsets/step_down_during_draining3.js @@ -126,4 +126,5 @@ assert.soon(function() { return secondary.getDB("foo").foo.find().itcount() == numDocuments; }); + replSet.stopSet(); })(); diff --git a/jstests/replsets/stepdown_kill_other_ops.js b/jstests/replsets/stepdown_kill_other_ops.js index a1e7e49c380..2974ef3624e 100644 --- a/jstests/replsets/stepdown_kill_other_ops.js +++ b/jstests/replsets/stepdown_kill_other_ops.js @@ -70,4 +70,5 @@ var exitCode = evalRunner({checkExitSuccess: false}); assert.neq( 0, exitCode, "expected shell to exit abnormally due to JS execution being terminated"); + replSet.stopSet(); })(); diff --git a/jstests/replsets/stepdown_killop.js b/jstests/replsets/stepdown_killop.js index 3ef89adc6fa..bd8fd10cb5b 100644 --- a/jstests/replsets/stepdown_killop.js +++ b/jstests/replsets/stepdown_killop.js @@ -78,4 +78,5 @@ assert.writeOK(primary.getDB(name).foo.remove({})); restartServerReplication(secondary); + replSet.stopSet(); })(); diff --git a/jstests/replsets/stepdown_long_wait_time.js b/jstests/replsets/stepdown_long_wait_time.js index c7c6306cf11..f38a6add12f 100644 --- a/jstests/replsets/stepdown_long_wait_time.js +++ b/jstests/replsets/stepdown_long_wait_time.js @@ -72,4 +72,5 @@ jsTestLog("Wait for SECONDARY " + secondary.host + " to become PRIMARY"); replSet.waitForState(secondary, ReplSetTest.State.PRIMARY); + replSet.stopSet(); })(); diff --git a/jstests/replsets/stepup.js b/jstests/replsets/stepup.js index 0e89fc25252..f50e6d2d8ab 100644 --- a/jstests/replsets/stepup.js +++ b/jstests/replsets/stepup.js @@ -56,4 +56,5 @@ load("jstests/replsets/rslib.js"); // Make sure the step up succeeded. assert.eq(secondary, rst.getPrimary()); + rst.stopSet(); })(); diff --git a/jstests/replsets/sync_passive.js b/jstests/replsets/sync_passive.js index 321a198e9af..d1d18bb79a8 100644 --- a/jstests/replsets/sync_passive.js +++ b/jstests/replsets/sync_passive.js @@ -79,3 +79,5 @@ replTest.awaitReplication(); print("bring #1 back up, make sure everything's okay"); replTest.restart(1); + +replTest.stopSet(); diff --git a/jstests/replsets/system_profile.js b/jstests/replsets/system_profile.js index ae524df1c75..7e1250da6dd 100644 --- a/jstests/replsets/system_profile.js +++ b/jstests/replsets/system_profile.js @@ -45,4 +45,5 @@ assert.eq( op, getLatestOp(), "oplog entry created when system.profile was emptied via emptycapped"); assert(primaryDB.system.profile.drop()); + rst.stopSet(); })(); diff --git a/jstests/replsets/system_profile_secondary.js b/jstests/replsets/system_profile_secondary.js index 69ab259f191..7c62e126323 100644 --- a/jstests/replsets/system_profile_secondary.js +++ b/jstests/replsets/system_profile_secondary.js @@ -22,4 +22,5 @@ jsTestLog('Check the query is in the profile and turn profiling off.'); assert.eq(numProfileEntries(secondaryDB.doesntexist), 1, 'expected a single profile entry'); assert.commandWorked(secondaryDB.runCommand({profile: 0})); + rst.stopSet(); })(); diff --git a/jstests/replsets/test_command.js b/jstests/replsets/test_command.js index abaf10bc56d..cc4ef0f0d0f 100644 --- a/jstests/replsets/test_command.js +++ b/jstests/replsets/test_command.js @@ -141,4 +141,5 @@ waitForDrainFinish: 0, }), 'node 1' + primary.host + ' failed to wait for drain to finish'); + replSet.stopSet(); })(); diff --git a/jstests/replsets/user_management_wc.js b/jstests/replsets/user_management_wc.js index 1b28112c541..c8ac612b597 100644 --- a/jstests/replsets/user_management_wc.js +++ b/jstests/replsets/user_management_wc.js @@ -160,4 +160,5 @@ load('jstests/multiVersion/libs/auth_helpers.js'); testInvalidWriteConcern(cmd); }); + replTest.stopSet(); })(); |