diff options
Diffstat (limited to 'jstests/sharding/safe_secondary_reads_drop_recreate.js')
| -rw-r--r-- | jstests/sharding/safe_secondary_reads_drop_recreate.js | 1140 |
1 files changed, 568 insertions, 572 deletions
diff --git a/jstests/sharding/safe_secondary_reads_drop_recreate.js b/jstests/sharding/safe_secondary_reads_drop_recreate.js index 86bec870263..975c6311f3a 100644 --- a/jstests/sharding/safe_secondary_reads_drop_recreate.js +++ b/jstests/sharding/safe_secondary_reads_drop_recreate.js @@ -17,592 +17,588 @@ * "versioned". Determines what system profiler checks are performed. */ (function() { - "use strict"; - - load('jstests/libs/profiler.js'); - load('jstests/sharding/libs/last_stable_mongos_commands.js'); - - let db = "test"; - let coll = "foo"; - let nss = db + "." + coll; - - // Check that a test case is well-formed. - let validateTestCase = function(test) { - assert(test.setUp && typeof(test.setUp) === "function"); - assert(test.command && typeof(test.command) === "object"); - assert(test.checkResults && typeof(test.checkResults) === "function"); - assert(test.behavior === "unshardedOnly" || - test.behavior === "targetsPrimaryUsesConnectionVersioning" || - test.behavior === "versioned"); - }; - - let testCases = { - _addShard: {skip: "primary only"}, - _shardsvrCloneCatalogData: {skip: "primary only"}, - _configsvrAddShard: {skip: "primary only"}, - _configsvrAddShardToZone: {skip: "primary only"}, - _configsvrBalancerStart: {skip: "primary only"}, - _configsvrBalancerStatus: {skip: "primary only"}, - _configsvrBalancerStop: {skip: "primary only"}, - _configsvrCommitChunkMerge: {skip: "primary only"}, - _configsvrCommitChunkMigration: {skip: "primary only"}, - _configsvrCommitChunkSplit: {skip: "primary only"}, - _configsvrCommitMovePrimary: {skip: "primary only"}, - _configsvrDropCollection: {skip: "primary only"}, - _configsvrDropDatabase: {skip: "primary only"}, - _configsvrMoveChunk: {skip: "primary only"}, - _configsvrMovePrimary: {skip: "primary only"}, - _configsvrRemoveShardFromZone: {skip: "primary only"}, - _configsvrShardCollection: {skip: "primary only"}, - _configsvrUpdateZoneKeyRange: {skip: "primary only"}, - _flushRoutingTableCacheUpdates: {skip: "does not return user data"}, - _getUserCacheGeneration: {skip: "does not return user data"}, - _hashBSONElement: {skip: "does not return user data"}, - _isSelf: {skip: "does not return user data"}, - _mergeAuthzCollections: {skip: "primary only"}, - _migrateClone: {skip: "primary only"}, - _shardsvrMovePrimary: {skip: "primary only"}, - _recvChunkAbort: {skip: "primary only"}, - _recvChunkCommit: {skip: "primary only"}, - _recvChunkStart: {skip: "primary only"}, - _recvChunkStatus: {skip: "primary only"}, - _transferMods: {skip: "primary only"}, - abortTransaction: {skip: "primary only"}, - addShard: {skip: "primary only"}, - addShardToZone: {skip: "primary only"}, - aggregate: { - setUp: function(mongosConn) { - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - }, - command: {aggregate: coll, pipeline: [{$match: {x: 1}}], cursor: {batchSize: 10}}, - checkResults: function(res) { - assert.commandWorked(res); - assert.eq(0, res.cursor.firstBatch.length, tojson(res)); - }, - behavior: "versioned" +"use strict"; + +load('jstests/libs/profiler.js'); +load('jstests/sharding/libs/last_stable_mongos_commands.js'); + +let db = "test"; +let coll = "foo"; +let nss = db + "." + coll; + +// Check that a test case is well-formed. +let validateTestCase = function(test) { + assert(test.setUp && typeof (test.setUp) === "function"); + assert(test.command && typeof (test.command) === "object"); + assert(test.checkResults && typeof (test.checkResults) === "function"); + assert(test.behavior === "unshardedOnly" || + test.behavior === "targetsPrimaryUsesConnectionVersioning" || + test.behavior === "versioned"); +}; + +let testCases = { + _addShard: {skip: "primary only"}, + _shardsvrCloneCatalogData: {skip: "primary only"}, + _configsvrAddShard: {skip: "primary only"}, + _configsvrAddShardToZone: {skip: "primary only"}, + _configsvrBalancerStart: {skip: "primary only"}, + _configsvrBalancerStatus: {skip: "primary only"}, + _configsvrBalancerStop: {skip: "primary only"}, + _configsvrCommitChunkMerge: {skip: "primary only"}, + _configsvrCommitChunkMigration: {skip: "primary only"}, + _configsvrCommitChunkSplit: {skip: "primary only"}, + _configsvrCommitMovePrimary: {skip: "primary only"}, + _configsvrDropCollection: {skip: "primary only"}, + _configsvrDropDatabase: {skip: "primary only"}, + _configsvrMoveChunk: {skip: "primary only"}, + _configsvrMovePrimary: {skip: "primary only"}, + _configsvrRemoveShardFromZone: {skip: "primary only"}, + _configsvrShardCollection: {skip: "primary only"}, + _configsvrUpdateZoneKeyRange: {skip: "primary only"}, + _flushRoutingTableCacheUpdates: {skip: "does not return user data"}, + _getUserCacheGeneration: {skip: "does not return user data"}, + _hashBSONElement: {skip: "does not return user data"}, + _isSelf: {skip: "does not return user data"}, + _mergeAuthzCollections: {skip: "primary only"}, + _migrateClone: {skip: "primary only"}, + _shardsvrMovePrimary: {skip: "primary only"}, + _recvChunkAbort: {skip: "primary only"}, + _recvChunkCommit: {skip: "primary only"}, + _recvChunkStart: {skip: "primary only"}, + _recvChunkStatus: {skip: "primary only"}, + _transferMods: {skip: "primary only"}, + abortTransaction: {skip: "primary only"}, + addShard: {skip: "primary only"}, + addShardToZone: {skip: "primary only"}, + aggregate: { + setUp: function(mongosConn) { + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); }, - appendOplogNote: {skip: "primary only"}, - applyOps: {skip: "primary only"}, - authSchemaUpgrade: {skip: "primary only"}, - authenticate: {skip: "does not return user data"}, - availableQueryOptions: {skip: "does not return user data"}, - balancerStart: {skip: "primary only"}, - balancerStatus: {skip: "primary only"}, - balancerStop: {skip: "primary only"}, - buildInfo: {skip: "does not return user data"}, - captrunc: {skip: "primary only"}, - checkShardingIndex: {skip: "primary only"}, - cleanupOrphaned: {skip: "primary only"}, - clearLog: {skip: "does not return user data"}, - clone: {skip: "primary only"}, - cloneCollectionAsCapped: {skip: "primary only"}, - collMod: {skip: "primary only"}, - collStats: {skip: "does not return user data"}, - commitTransaction: {skip: "primary only"}, - compact: {skip: "does not return user data"}, - configureFailPoint: {skip: "does not return user data"}, - connPoolStats: {skip: "does not return user data"}, - connPoolSync: {skip: "does not return user data"}, - connectionStatus: {skip: "does not return user data"}, - convertToCapped: {skip: "primary only"}, - count: { - setUp: function(mongosConn) { - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - }, - command: {count: coll, query: {x: 1}}, - checkResults: function(res) { - assert.commandWorked(res); - assert.eq(0, res.n, tojson(res)); - }, - behavior: "versioned" + command: {aggregate: coll, pipeline: [{$match: {x: 1}}], cursor: {batchSize: 10}}, + checkResults: function(res) { + assert.commandWorked(res); + assert.eq(0, res.cursor.firstBatch.length, tojson(res)); }, - cpuload: {skip: "does not return user data"}, - create: {skip: "primary only"}, - createIndexes: {skip: "primary only"}, - createRole: {skip: "primary only"}, - createUser: {skip: "primary only"}, - currentOp: {skip: "does not return user data"}, - dataSize: {skip: "does not return user data"}, - dbHash: {skip: "does not return user data"}, - dbStats: {skip: "does not return user data"}, - delete: {skip: "primary only"}, - distinct: { - setUp: function(mongosConn) { - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - }, - command: {distinct: coll, key: "x"}, - checkResults: function(res) { - assert.commandWorked(res); - assert.eq(0, res.values.length, tojson(res)); - }, - behavior: "versioned" + behavior: "versioned" + }, + appendOplogNote: {skip: "primary only"}, + applyOps: {skip: "primary only"}, + authSchemaUpgrade: {skip: "primary only"}, + authenticate: {skip: "does not return user data"}, + availableQueryOptions: {skip: "does not return user data"}, + balancerStart: {skip: "primary only"}, + balancerStatus: {skip: "primary only"}, + balancerStop: {skip: "primary only"}, + buildInfo: {skip: "does not return user data"}, + captrunc: {skip: "primary only"}, + checkShardingIndex: {skip: "primary only"}, + cleanupOrphaned: {skip: "primary only"}, + clearLog: {skip: "does not return user data"}, + clone: {skip: "primary only"}, + cloneCollectionAsCapped: {skip: "primary only"}, + collMod: {skip: "primary only"}, + collStats: {skip: "does not return user data"}, + commitTransaction: {skip: "primary only"}, + compact: {skip: "does not return user data"}, + configureFailPoint: {skip: "does not return user data"}, + connPoolStats: {skip: "does not return user data"}, + connPoolSync: {skip: "does not return user data"}, + connectionStatus: {skip: "does not return user data"}, + convertToCapped: {skip: "primary only"}, + count: { + setUp: function(mongosConn) { + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); }, - driverOIDTest: {skip: "does not return user data"}, - drop: {skip: "primary only"}, - dropAllRolesFromDatabase: {skip: "primary only"}, - dropAllUsersFromDatabase: {skip: "primary only"}, - dropConnections: {skip: "does not return user data"}, - dropDatabase: {skip: "primary only"}, - dropIndexes: {skip: "primary only"}, - dropRole: {skip: "primary only"}, - dropUser: {skip: "primary only"}, - echo: {skip: "does not return user data"}, - emptycapped: {skip: "primary only"}, - enableSharding: {skip: "primary only"}, - endSessions: {skip: "does not return user data"}, - explain: {skip: "TODO SERVER-30068"}, - features: {skip: "does not return user data"}, - filemd5: {skip: "does not return user data"}, - find: { - setUp: function(mongosConn) { - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - }, - command: {find: coll, filter: {x: 1}}, - checkResults: function(res) { - assert.commandWorked(res); - assert.eq(0, res.cursor.firstBatch.length, tojson(res)); - }, - behavior: "versioned" + command: {count: coll, query: {x: 1}}, + checkResults: function(res) { + assert.commandWorked(res); + assert.eq(0, res.n, tojson(res)); }, - findAndModify: {skip: "primary only"}, - flushRouterConfig: {skip: "does not return user data"}, - forceerror: {skip: "does not return user data"}, - fsync: {skip: "does not return user data"}, - fsyncUnlock: {skip: "does not return user data"}, - geoSearch: {skip: "not supported in mongos"}, - getCmdLineOpts: {skip: "does not return user data"}, - getDiagnosticData: {skip: "does not return user data"}, - getLastError: {skip: "primary only"}, - getLog: {skip: "does not return user data"}, - getMore: {skip: "shard version already established"}, - getParameter: {skip: "does not return user data"}, - getShardMap: {skip: "does not return user data"}, - getShardVersion: {skip: "primary only"}, - getnonce: {skip: "does not return user data"}, - godinsert: {skip: "for testing only"}, - grantPrivilegesToRole: {skip: "primary only"}, - grantRolesToRole: {skip: "primary only"}, - grantRolesToUser: {skip: "primary only"}, - handshake: {skip: "does not return user data"}, - hostInfo: {skip: "does not return user data"}, - insert: {skip: "primary only"}, - invalidateUserCache: {skip: "does not return user data"}, - isdbgrid: {skip: "does not return user data"}, - isMaster: {skip: "does not return user data"}, - killAllSessions: {skip: "does not return user data"}, - killAllSessionsByPattern: {skip: "does not return user data"}, - killCursors: {skip: "does not return user data"}, - killOp: {skip: "does not return user data"}, - killSessions: {skip: "does not return user data"}, - listCollections: {skip: "primary only"}, - listCommands: {skip: "does not return user data"}, - listDatabases: {skip: "primary only"}, - listIndexes: {skip: "primary only"}, - listShards: {skip: "does not return user data"}, - lockInfo: {skip: "primary only"}, - logApplicationMessage: {skip: "primary only"}, - logRotate: {skip: "does not return user data"}, - logout: {skip: "does not return user data"}, - makeSnapshot: {skip: "does not return user data"}, - mapReduce: { - setUp: function(mongosConn) { - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); - }, - command: { - mapReduce: coll, - map: function() { - emit(this.x, 1); - }, - reduce: function(key, values) { - return Array.sum(values); - }, - out: {inline: 1} - }, - checkResults: function(res) { - assert.commandWorked(res); - assert.eq(0, res.results.length, tojson(res)); - }, - behavior: "targetsPrimaryUsesConnectionVersioning" + behavior: "versioned" + }, + cpuload: {skip: "does not return user data"}, + create: {skip: "primary only"}, + createIndexes: {skip: "primary only"}, + createRole: {skip: "primary only"}, + createUser: {skip: "primary only"}, + currentOp: {skip: "does not return user data"}, + dataSize: {skip: "does not return user data"}, + dbHash: {skip: "does not return user data"}, + dbStats: {skip: "does not return user data"}, + delete: {skip: "primary only"}, + distinct: { + setUp: function(mongosConn) { + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); }, - mergeChunks: {skip: "primary only"}, - moveChunk: {skip: "primary only"}, - movePrimary: {skip: "primary only"}, - multicast: {skip: "does not return user data"}, - netstat: {skip: "does not return user data"}, - ping: {skip: "does not return user data"}, - planCacheClear: {skip: "does not return user data"}, - planCacheClearFilters: {skip: "does not return user data"}, - planCacheListFilters: {skip: "does not return user data"}, - planCacheListPlans: {skip: "does not return user data"}, - planCacheListQueryShapes: {skip: "does not return user data"}, - planCacheSetFilter: {skip: "does not return user data"}, - profile: {skip: "primary only"}, - reapLogicalSessionCacheNow: {skip: "does not return user data"}, - refineCollectionShardKey: {skip: "primary only"}, - refreshLogicalSessionCacheNow: {skip: "does not return user data"}, - refreshSessions: {skip: "does not return user data"}, - refreshSessionsInternal: {skip: "does not return user data"}, - removeShard: {skip: "primary only"}, - removeShardFromZone: {skip: "primary only"}, - renameCollection: {skip: "primary only"}, - repairCursor: {skip: "does not return user data"}, - replSetAbortPrimaryCatchUp: {skip: "does not return user data"}, - replSetFreeze: {skip: "does not return user data"}, - replSetGetConfig: {skip: "does not return user data"}, - replSetGetRBID: {skip: "does not return user data"}, - replSetGetStatus: {skip: "does not return user data"}, - replSetHeartbeat: {skip: "does not return user data"}, - replSetInitiate: {skip: "does not return user data"}, - replSetMaintenance: {skip: "does not return user data"}, - replSetReconfig: {skip: "does not return user data"}, - replSetRequestVotes: {skip: "does not return user data"}, - replSetStepDown: {skip: "does not return user data"}, - replSetStepUp: {skip: "does not return user data"}, - replSetSyncFrom: {skip: "does not return user data"}, - replSetTest: {skip: "does not return user data"}, - replSetUpdatePosition: {skip: "does not return user data"}, - replSetResizeOplog: {skip: "does not return user data"}, - resetError: {skip: "does not return user data"}, - restartCatalog: {skip: "internal-only command"}, - resync: {skip: "primary only"}, - revokePrivilegesFromRole: {skip: "primary only"}, - revokeRolesFromRole: {skip: "primary only"}, - revokeRolesFromUser: {skip: "primary only"}, - rolesInfo: {skip: "primary only"}, - saslContinue: {skip: "primary only"}, - saslStart: {skip: "primary only"}, - serverStatus: {skip: "does not return user data"}, - setCommittedSnapshot: {skip: "does not return user data"}, - setIndexCommitQuorum: {skip: "primary only"}, - setFeatureCompatibilityVersion: {skip: "primary only"}, - setFreeMonitoring: {skip: "primary only"}, - setParameter: {skip: "does not return user data"}, - setShardVersion: {skip: "does not return user data"}, - shardCollection: {skip: "primary only"}, - shardConnPoolStats: {skip: "does not return user data"}, - shardingState: {skip: "does not return user data"}, - shutdown: {skip: "does not return user data"}, - sleep: {skip: "does not return user data"}, - split: {skip: "primary only"}, - splitChunk: {skip: "primary only"}, - splitVector: {skip: "primary only"}, - stageDebug: {skip: "primary only"}, - startRecordingTraffic: {skip: "does not return user data"}, - startSession: {skip: "does not return user data"}, - stopRecordingTraffic: {skip: "does not return user data"}, - top: {skip: "does not return user data"}, - touch: {skip: "does not return user data"}, - unsetSharding: {skip: "does not return user data"}, - update: {skip: "primary only"}, - updateRole: {skip: "primary only"}, - updateUser: {skip: "primary only"}, - updateZoneKeyRange: {skip: "primary only"}, - usersInfo: {skip: "primary only"}, - validate: {skip: "does not return user data"}, - waitForOngoingChunkSplits: {skip: "does not return user data"}, - whatsmyuri: {skip: "does not return user data"} - }; - - commandsRemovedFromMongosIn42.forEach(function(cmd) { - testCases[cmd] = {skip: "must define test coverage for 4.0 backwards compatibility"}; - }); - - let scenarios = { - dropRecreateAsUnshardedOnSameShard: function( - staleMongos, freshMongos, test, commandProfile) { - let primaryShardPrimary = st.rs0.getPrimary(); - let primaryShardSecondary = st.rs0.getSecondary(); - - // Drop and recreate the collection. - assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); - assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); - - // Ensure the latest version changes have been persisted and propagate to the secondary - // before we target it with versioned commands. - assert.commandWorked(st.rs0.getPrimary().getDB('admin').runCommand( - {_flushRoutingTableCacheUpdates: nss})); - st.rs0.awaitReplication(); - - let res = staleMongos.getDB(db).runCommand(Object.assign( - {}, - test.command, - {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); - - test.checkResults(res); - - if (test.behavior === "unshardedOnly") { - profilerHasZeroMatchingEntriesOrThrow( - {profileDB: primaryShardSecondary.getDB(db), filter: commandProfile}); - } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { - // Check that the primary shard primary received the request without a shardVersion - // field and returned success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardPrimary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": false}, - "command.$readPreference": {$exists: false}, - "command.readConcern": {"level": "local"}, - "errCode": {"$exists": false} - }, - commandProfile) - }); - } else if (test.behavior == "versioned") { - // Check that the primary shard secondary returned stale shardVersion. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": ErrorCodes.StaleConfig - }, - commandProfile) - }); - - // Check that the primary shard secondary received the request again and returned - // success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": {"$ne": ErrorCodes.StaleConfig}, - }, - commandProfile) - }); - } + command: {distinct: coll, key: "x"}, + checkResults: function(res) { + assert.commandWorked(res); + assert.eq(0, res.values.length, tojson(res)); }, - dropRecreateAsShardedOnSameShard: function(staleMongos, freshMongos, test, commandProfile) { - let primaryShardPrimary = st.rs0.getPrimary(); - let primaryShardSecondary = st.rs0.getSecondary(); - - // Drop and recreate the collection as sharded. - assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); - assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); - assert.commandWorked(freshMongos.adminCommand({shardCollection: nss, key: {x: 1}})); - - // We do this because we expect staleMongos to see that the collection is sharded, which - // it may not if the "nearest" config server it contacts has not replicated the - // shardCollection writes (or has not heard that they have reached a majority). - st.configRS.awaitReplication(); - - // Ensure the latest version changes have been persisted and propagate to the secondary - // before we target it with versioned commands. - assert.commandWorked(st.rs0.getPrimary().getDB('admin').runCommand( - {_flushRoutingTableCacheUpdates: nss})); - st.rs0.awaitReplication(); - - let res = staleMongos.getDB(db).runCommand(Object.assign( - {}, - test.command, - {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); - - test.checkResults(res); - - if (test.behavior === "unshardedOnly") { - profilerHasZeroMatchingEntriesOrThrow( - {profileDB: primaryShardSecondary.getDB(db), filter: commandProfile}); - } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { - // Check that the primary shard primary received the request without a shardVersion - // field and returned success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardPrimary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": false}, - "command.$readPreference": {$exists: false}, - "command.readConcern": {"level": "local"}, - "errCode": {"$exists": false}, - }, - commandProfile) - }); - } else if (test.behavior == "versioned") { - // Check that the primary shard secondary returned stale shardVersion. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": ErrorCodes.StaleConfig - }, - commandProfile) - }); - - // Check that the primary shard secondary received the request again and returned - // success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: primaryShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": {"$ne": ErrorCodes.StaleConfig}, - }, - commandProfile) - }); - } + behavior: "versioned" + }, + driverOIDTest: {skip: "does not return user data"}, + drop: {skip: "primary only"}, + dropAllRolesFromDatabase: {skip: "primary only"}, + dropAllUsersFromDatabase: {skip: "primary only"}, + dropConnections: {skip: "does not return user data"}, + dropDatabase: {skip: "primary only"}, + dropIndexes: {skip: "primary only"}, + dropRole: {skip: "primary only"}, + dropUser: {skip: "primary only"}, + echo: {skip: "does not return user data"}, + emptycapped: {skip: "primary only"}, + enableSharding: {skip: "primary only"}, + endSessions: {skip: "does not return user data"}, + explain: {skip: "TODO SERVER-30068"}, + features: {skip: "does not return user data"}, + filemd5: {skip: "does not return user data"}, + find: { + setUp: function(mongosConn) { + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); }, - dropRecreateAsUnshardedOnDifferentShard: function( - staleMongos, freshMongos, test, commandProfile) { - // There is no way to drop and recreate the collection as unsharded on a *different* - // shard without calling movePrimary, and it is known that a stale mongos will not - // refresh its notion of the primary shard after it loads it once. + command: {find: coll, filter: {x: 1}}, + checkResults: function(res) { + assert.commandWorked(res); + assert.eq(0, res.cursor.firstBatch.length, tojson(res)); + }, + behavior: "versioned" + }, + findAndModify: {skip: "primary only"}, + flushRouterConfig: {skip: "does not return user data"}, + forceerror: {skip: "does not return user data"}, + fsync: {skip: "does not return user data"}, + fsyncUnlock: {skip: "does not return user data"}, + geoSearch: {skip: "not supported in mongos"}, + getCmdLineOpts: {skip: "does not return user data"}, + getDiagnosticData: {skip: "does not return user data"}, + getLastError: {skip: "primary only"}, + getLog: {skip: "does not return user data"}, + getMore: {skip: "shard version already established"}, + getParameter: {skip: "does not return user data"}, + getShardMap: {skip: "does not return user data"}, + getShardVersion: {skip: "primary only"}, + getnonce: {skip: "does not return user data"}, + godinsert: {skip: "for testing only"}, + grantPrivilegesToRole: {skip: "primary only"}, + grantRolesToRole: {skip: "primary only"}, + grantRolesToUser: {skip: "primary only"}, + handshake: {skip: "does not return user data"}, + hostInfo: {skip: "does not return user data"}, + insert: {skip: "primary only"}, + invalidateUserCache: {skip: "does not return user data"}, + isdbgrid: {skip: "does not return user data"}, + isMaster: {skip: "does not return user data"}, + killAllSessions: {skip: "does not return user data"}, + killAllSessionsByPattern: {skip: "does not return user data"}, + killCursors: {skip: "does not return user data"}, + killOp: {skip: "does not return user data"}, + killSessions: {skip: "does not return user data"}, + listCollections: {skip: "primary only"}, + listCommands: {skip: "does not return user data"}, + listDatabases: {skip: "primary only"}, + listIndexes: {skip: "primary only"}, + listShards: {skip: "does not return user data"}, + lockInfo: {skip: "primary only"}, + logApplicationMessage: {skip: "primary only"}, + logRotate: {skip: "does not return user data"}, + logout: {skip: "does not return user data"}, + makeSnapshot: {skip: "does not return user data"}, + mapReduce: { + setUp: function(mongosConn) { + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); + assert.writeOK(mongosConn.getCollection(nss).insert({x: 1})); + }, + command: { + mapReduce: coll, + map: function() { + emit(this.x, 1); + }, + reduce: function(key, values) { + return Array.sum(values); + }, + out: {inline: 1} }, - dropRecreateAsShardedOnDifferentShard: function( - staleMongos, freshMongos, test, commandProfile) { - let donorShardSecondary = st.rs0.getSecondary(); - let recipientShardPrimary = st.rs1.getPrimary(); - let recipientShardSecondary = st.rs1.getSecondary(); - - // Drop and recreate the collection as sharded, and move the chunk to the other shard. - assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); - assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); - assert.commandWorked(freshMongos.adminCommand({shardCollection: nss, key: {x: 1}})); - - // We do this because we expect staleMongos to see that the collection is sharded, which - // it may not if the "nearest" config server it contacts has not replicated the - // shardCollection writes (or has not heard that they have reached a majority). - st.configRS.awaitReplication(); - - // Use {w:2} (all) write concern in the moveChunk operation so the metadata change gets - // persisted to the secondary before versioned commands are sent against the secondary. - assert.commandWorked(freshMongos.adminCommand({ - moveChunk: nss, - find: {x: 0}, - to: st.shard1.shardName, - _secondaryThrottle: true, - writeConcern: {w: 2}, - })); - - let res = staleMongos.getDB(db).runCommand(Object.assign( - {}, - test.command, - {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); - - test.checkResults(res); - - if (test.behavior === "unshardedOnly") { - profilerHasZeroMatchingEntriesOrThrow( - {profileDB: donorShardSecondary.getDB(db), filter: commandProfile}); - profilerHasZeroMatchingEntriesOrThrow( - {profileDB: recipientShardSecondary.getDB(db), filter: commandProfile}); - } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { - // Check that the recipient shard primary received the request without a - // shardVersion field and returned success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: recipientShardPrimary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": false}, - "command.$readPreference": {$exists: false}, - "command.readConcern": {"level": "local"}, - "errCode": {"$exists": false}, - }, - commandProfile) - }); - } else if (test.behavior == "versioned") { - // Check that the donor shard secondary returned stale shardVersion. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: donorShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": ErrorCodes.StaleConfig - }, - commandProfile) - }); - - // Check that the recipient shard secondary received the request and returned - // success. - profilerHasSingleMatchingEntryOrThrow({ - profileDB: recipientShardSecondary.getDB(db), - filter: Object.extend({ - "command.shardVersion": {"$exists": true}, - "command.$readPreference": {"mode": "secondary"}, - "command.readConcern": {"level": "local"}, - "errCode": {"$ne": ErrorCodes.StaleConfig}, - }, - commandProfile) - }); - } + checkResults: function(res) { + assert.commandWorked(res); + assert.eq(0, res.results.length, tojson(res)); + }, + behavior: "targetsPrimaryUsesConnectionVersioning" + }, + mergeChunks: {skip: "primary only"}, + moveChunk: {skip: "primary only"}, + movePrimary: {skip: "primary only"}, + multicast: {skip: "does not return user data"}, + netstat: {skip: "does not return user data"}, + ping: {skip: "does not return user data"}, + planCacheClear: {skip: "does not return user data"}, + planCacheClearFilters: {skip: "does not return user data"}, + planCacheListFilters: {skip: "does not return user data"}, + planCacheListPlans: {skip: "does not return user data"}, + planCacheListQueryShapes: {skip: "does not return user data"}, + planCacheSetFilter: {skip: "does not return user data"}, + profile: {skip: "primary only"}, + reapLogicalSessionCacheNow: {skip: "does not return user data"}, + refineCollectionShardKey: {skip: "primary only"}, + refreshLogicalSessionCacheNow: {skip: "does not return user data"}, + refreshSessions: {skip: "does not return user data"}, + refreshSessionsInternal: {skip: "does not return user data"}, + removeShard: {skip: "primary only"}, + removeShardFromZone: {skip: "primary only"}, + renameCollection: {skip: "primary only"}, + repairCursor: {skip: "does not return user data"}, + replSetAbortPrimaryCatchUp: {skip: "does not return user data"}, + replSetFreeze: {skip: "does not return user data"}, + replSetGetConfig: {skip: "does not return user data"}, + replSetGetRBID: {skip: "does not return user data"}, + replSetGetStatus: {skip: "does not return user data"}, + replSetHeartbeat: {skip: "does not return user data"}, + replSetInitiate: {skip: "does not return user data"}, + replSetMaintenance: {skip: "does not return user data"}, + replSetReconfig: {skip: "does not return user data"}, + replSetRequestVotes: {skip: "does not return user data"}, + replSetStepDown: {skip: "does not return user data"}, + replSetStepUp: {skip: "does not return user data"}, + replSetSyncFrom: {skip: "does not return user data"}, + replSetTest: {skip: "does not return user data"}, + replSetUpdatePosition: {skip: "does not return user data"}, + replSetResizeOplog: {skip: "does not return user data"}, + resetError: {skip: "does not return user data"}, + restartCatalog: {skip: "internal-only command"}, + resync: {skip: "primary only"}, + revokePrivilegesFromRole: {skip: "primary only"}, + revokeRolesFromRole: {skip: "primary only"}, + revokeRolesFromUser: {skip: "primary only"}, + rolesInfo: {skip: "primary only"}, + saslContinue: {skip: "primary only"}, + saslStart: {skip: "primary only"}, + serverStatus: {skip: "does not return user data"}, + setCommittedSnapshot: {skip: "does not return user data"}, + setIndexCommitQuorum: {skip: "primary only"}, + setFeatureCompatibilityVersion: {skip: "primary only"}, + setFreeMonitoring: {skip: "primary only"}, + setParameter: {skip: "does not return user data"}, + setShardVersion: {skip: "does not return user data"}, + shardCollection: {skip: "primary only"}, + shardConnPoolStats: {skip: "does not return user data"}, + shardingState: {skip: "does not return user data"}, + shutdown: {skip: "does not return user data"}, + sleep: {skip: "does not return user data"}, + split: {skip: "primary only"}, + splitChunk: {skip: "primary only"}, + splitVector: {skip: "primary only"}, + stageDebug: {skip: "primary only"}, + startRecordingTraffic: {skip: "does not return user data"}, + startSession: {skip: "does not return user data"}, + stopRecordingTraffic: {skip: "does not return user data"}, + top: {skip: "does not return user data"}, + touch: {skip: "does not return user data"}, + unsetSharding: {skip: "does not return user data"}, + update: {skip: "primary only"}, + updateRole: {skip: "primary only"}, + updateUser: {skip: "primary only"}, + updateZoneKeyRange: {skip: "primary only"}, + usersInfo: {skip: "primary only"}, + validate: {skip: "does not return user data"}, + waitForOngoingChunkSplits: {skip: "does not return user data"}, + whatsmyuri: {skip: "does not return user data"} +}; + +commandsRemovedFromMongosIn42.forEach(function(cmd) { + testCases[cmd] = {skip: "must define test coverage for 4.0 backwards compatibility"}; +}); + +let scenarios = { + dropRecreateAsUnshardedOnSameShard: function(staleMongos, freshMongos, test, commandProfile) { + let primaryShardPrimary = st.rs0.getPrimary(); + let primaryShardSecondary = st.rs0.getSecondary(); + + // Drop and recreate the collection. + assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); + assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); + + // Ensure the latest version changes have been persisted and propagate to the secondary + // before we target it with versioned commands. + assert.commandWorked( + st.rs0.getPrimary().getDB('admin').runCommand({_flushRoutingTableCacheUpdates: nss})); + st.rs0.awaitReplication(); + + let res = staleMongos.getDB(db).runCommand( + Object.assign({}, + test.command, + {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); + + test.checkResults(res); + + if (test.behavior === "unshardedOnly") { + profilerHasZeroMatchingEntriesOrThrow( + {profileDB: primaryShardSecondary.getDB(db), filter: commandProfile}); + } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { + // Check that the primary shard primary received the request without a shardVersion + // field and returned success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardPrimary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": false}, + "command.$readPreference": {$exists: false}, + "command.readConcern": {"level": "local"}, + "errCode": {"$exists": false} + }, + commandProfile) + }); + } else if (test.behavior == "versioned") { + // Check that the primary shard secondary returned stale shardVersion. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": ErrorCodes.StaleConfig + }, + commandProfile) + }); + + // Check that the primary shard secondary received the request again and returned + // success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": {"$ne": ErrorCodes.StaleConfig}, + }, + commandProfile) + }); + } + }, + dropRecreateAsShardedOnSameShard: function(staleMongos, freshMongos, test, commandProfile) { + let primaryShardPrimary = st.rs0.getPrimary(); + let primaryShardSecondary = st.rs0.getSecondary(); + + // Drop and recreate the collection as sharded. + assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); + assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); + assert.commandWorked(freshMongos.adminCommand({shardCollection: nss, key: {x: 1}})); + + // We do this because we expect staleMongos to see that the collection is sharded, which + // it may not if the "nearest" config server it contacts has not replicated the + // shardCollection writes (or has not heard that they have reached a majority). + st.configRS.awaitReplication(); + + // Ensure the latest version changes have been persisted and propagate to the secondary + // before we target it with versioned commands. + assert.commandWorked( + st.rs0.getPrimary().getDB('admin').runCommand({_flushRoutingTableCacheUpdates: nss})); + st.rs0.awaitReplication(); + + let res = staleMongos.getDB(db).runCommand( + Object.assign({}, + test.command, + {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); + + test.checkResults(res); + + if (test.behavior === "unshardedOnly") { + profilerHasZeroMatchingEntriesOrThrow( + {profileDB: primaryShardSecondary.getDB(db), filter: commandProfile}); + } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { + // Check that the primary shard primary received the request without a shardVersion + // field and returned success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardPrimary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": false}, + "command.$readPreference": {$exists: false}, + "command.readConcern": {"level": "local"}, + "errCode": {"$exists": false}, + }, + commandProfile) + }); + } else if (test.behavior == "versioned") { + // Check that the primary shard secondary returned stale shardVersion. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": ErrorCodes.StaleConfig + }, + commandProfile) + }); + + // Check that the primary shard secondary received the request again and returned + // success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: primaryShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": {"$ne": ErrorCodes.StaleConfig}, + }, + commandProfile) + }); } - }; + }, + dropRecreateAsUnshardedOnDifferentShard: function( + staleMongos, freshMongos, test, commandProfile) { + // There is no way to drop and recreate the collection as unsharded on a *different* + // shard without calling movePrimary, and it is known that a stale mongos will not + // refresh its notion of the primary shard after it loads it once. + }, + dropRecreateAsShardedOnDifferentShard: function( + staleMongos, freshMongos, test, commandProfile) { + let donorShardSecondary = st.rs0.getSecondary(); + let recipientShardPrimary = st.rs1.getPrimary(); + let recipientShardSecondary = st.rs1.getSecondary(); + + // Drop and recreate the collection as sharded, and move the chunk to the other shard. + assert.commandWorked(freshMongos.getDB(db).runCommand({drop: coll})); + assert.commandWorked(freshMongos.getDB(db).runCommand({create: coll})); + assert.commandWorked(freshMongos.adminCommand({shardCollection: nss, key: {x: 1}})); + + // We do this because we expect staleMongos to see that the collection is sharded, which + // it may not if the "nearest" config server it contacts has not replicated the + // shardCollection writes (or has not heard that they have reached a majority). + st.configRS.awaitReplication(); + + // Use {w:2} (all) write concern in the moveChunk operation so the metadata change gets + // persisted to the secondary before versioned commands are sent against the secondary. + assert.commandWorked(freshMongos.adminCommand({ + moveChunk: nss, + find: {x: 0}, + to: st.shard1.shardName, + _secondaryThrottle: true, + writeConcern: {w: 2}, + })); + + let res = staleMongos.getDB(db).runCommand( + Object.assign({}, + test.command, + {$readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); + + test.checkResults(res); + + if (test.behavior === "unshardedOnly") { + profilerHasZeroMatchingEntriesOrThrow( + {profileDB: donorShardSecondary.getDB(db), filter: commandProfile}); + profilerHasZeroMatchingEntriesOrThrow( + {profileDB: recipientShardSecondary.getDB(db), filter: commandProfile}); + } else if (test.behavior === "targetsPrimaryUsesConnectionVersioning") { + // Check that the recipient shard primary received the request without a + // shardVersion field and returned success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: recipientShardPrimary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": false}, + "command.$readPreference": {$exists: false}, + "command.readConcern": {"level": "local"}, + "errCode": {"$exists": false}, + }, + commandProfile) + }); + } else if (test.behavior == "versioned") { + // Check that the donor shard secondary returned stale shardVersion. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: donorShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": ErrorCodes.StaleConfig + }, + commandProfile) + }); + + // Check that the recipient shard secondary received the request and returned + // success. + profilerHasSingleMatchingEntryOrThrow({ + profileDB: recipientShardSecondary.getDB(db), + filter: Object.extend({ + "command.shardVersion": {"$exists": true}, + "command.$readPreference": {"mode": "secondary"}, + "command.readConcern": {"level": "local"}, + "errCode": {"$ne": ErrorCodes.StaleConfig}, + }, + commandProfile) + }); + } + } +}; - // Set the secondaries to priority 0 and votes 0 to prevent the primaries from stepping down. - let rsOpts = {nodes: [{rsConfig: {votes: 1}}, {rsConfig: {priority: 0, votes: 0}}]}; - let st = new ShardingTest({mongos: 2, shards: {rs0: rsOpts, rs1: rsOpts}}); +// Set the secondaries to priority 0 and votes 0 to prevent the primaries from stepping down. +let rsOpts = {nodes: [{rsConfig: {votes: 1}}, {rsConfig: {priority: 0, votes: 0}}]}; +let st = new ShardingTest({mongos: 2, shards: {rs0: rsOpts, rs1: rsOpts}}); - let freshMongos = st.s0; - let staleMongos = st.s1; +let freshMongos = st.s0; +let staleMongos = st.s1; - let res = st.s.adminCommand({listCommands: 1}); - assert.commandWorked(res); +let res = st.s.adminCommand({listCommands: 1}); +assert.commandWorked(res); - let commands = Object.keys(res.commands); - for (let command of commands) { - let test = testCases[command]; - assert(test !== undefined, - "coverage failure: must define a safe secondary reads test for " + command); +let commands = Object.keys(res.commands); +for (let command of commands) { + let test = testCases[command]; + assert(test !== undefined, + "coverage failure: must define a safe secondary reads test for " + command); - if (test.skip !== undefined) { - print("skipping " + command + ": " + test.skip); - continue; - } - validateTestCase(test); - - // Build the query to identify the operation in the system profiler. - let commandProfile = buildCommandProfile(test.command, true /* sharded */); - - for (let scenario in scenarios) { - jsTest.log("testing command " + tojson(command) + " under scenario " + scenario); - - // Each scenario starts with a sharded collection with shard0 as the primary shard. - assert.commandWorked(staleMongos.adminCommand({enableSharding: db})); - st.ensurePrimaryShard(db, st.shard0.shardName); - assert.commandWorked(staleMongos.adminCommand({shardCollection: nss, key: {x: 1}})); - - // We do this because we expect staleMongos to see that the collection is sharded, which - // it may not if the "nearest" config server it contacts has not replicated the - // shardCollection writes (or has not heard that they have reached a majority). - st.configRS.awaitReplication(); - - // Do any test-specific setup. - test.setUp(staleMongos); - - // Wait for replication as a safety net, in case the individual setup function for a - // test case did not specify writeConcern itself - st.rs0.awaitReplication(); - st.rs1.awaitReplication(); - - // Do dummy read from the stale mongos so it loads the routing table into memory once. - // Additionally, do a secondary read to ensure that the secondary has loaded the initial - // routing table -- the first read to the primary will refresh the mongos' shardVersion, - // which will then be used against the secondary to ensure the secondary is fresh. - assert.commandWorked(staleMongos.getDB(db).runCommand({find: coll})); - assert.commandWorked(freshMongos.getDB(db).runCommand({ - find: coll, - $readPreference: {mode: 'secondary'}, - readConcern: {'level': 'local'} - })); - // Wait for drop of previous database to replicate before beginning profiling - st.rs0.awaitReplication(); - st.rs1.awaitReplication(); - assert.commandWorked(st.rs0.getPrimary().getDB(db).setProfilingLevel(2)); - assert.commandWorked(st.rs0.getSecondary().getDB(db).setProfilingLevel(2)); - assert.commandWorked(st.rs1.getPrimary().getDB(db).setProfilingLevel(2)); - assert.commandWorked(st.rs1.getSecondary().getDB(db).setProfilingLevel(2)); - - scenarios[scenario](staleMongos, freshMongos, test, commandProfile); - - // Clean up the database by dropping it; this is the only way to drop the profiler - // collection on secondaries. - // Do this from staleMongos, so staleMongos purges the database entry from its cache. - assert.commandWorked(staleMongos.getDB(db).runCommand({dropDatabase: 1})); - } + if (test.skip !== undefined) { + print("skipping " + command + ": " + test.skip); + continue; + } + validateTestCase(test); + + // Build the query to identify the operation in the system profiler. + let commandProfile = buildCommandProfile(test.command, true /* sharded */); + + for (let scenario in scenarios) { + jsTest.log("testing command " + tojson(command) + " under scenario " + scenario); + + // Each scenario starts with a sharded collection with shard0 as the primary shard. + assert.commandWorked(staleMongos.adminCommand({enableSharding: db})); + st.ensurePrimaryShard(db, st.shard0.shardName); + assert.commandWorked(staleMongos.adminCommand({shardCollection: nss, key: {x: 1}})); + + // We do this because we expect staleMongos to see that the collection is sharded, which + // it may not if the "nearest" config server it contacts has not replicated the + // shardCollection writes (or has not heard that they have reached a majority). + st.configRS.awaitReplication(); + + // Do any test-specific setup. + test.setUp(staleMongos); + + // Wait for replication as a safety net, in case the individual setup function for a + // test case did not specify writeConcern itself + st.rs0.awaitReplication(); + st.rs1.awaitReplication(); + + // Do dummy read from the stale mongos so it loads the routing table into memory once. + // Additionally, do a secondary read to ensure that the secondary has loaded the initial + // routing table -- the first read to the primary will refresh the mongos' shardVersion, + // which will then be used against the secondary to ensure the secondary is fresh. + assert.commandWorked(staleMongos.getDB(db).runCommand({find: coll})); + assert.commandWorked(freshMongos.getDB(db).runCommand( + {find: coll, $readPreference: {mode: 'secondary'}, readConcern: {'level': 'local'}})); + // Wait for drop of previous database to replicate before beginning profiling + st.rs0.awaitReplication(); + st.rs1.awaitReplication(); + assert.commandWorked(st.rs0.getPrimary().getDB(db).setProfilingLevel(2)); + assert.commandWorked(st.rs0.getSecondary().getDB(db).setProfilingLevel(2)); + assert.commandWorked(st.rs1.getPrimary().getDB(db).setProfilingLevel(2)); + assert.commandWorked(st.rs1.getSecondary().getDB(db).setProfilingLevel(2)); + + scenarios[scenario](staleMongos, freshMongos, test, commandProfile); + + // Clean up the database by dropping it; this is the only way to drop the profiler + // collection on secondaries. + // Do this from staleMongos, so staleMongos purges the database entry from its cache. + assert.commandWorked(staleMongos.getDB(db).runCommand({dropDatabase: 1})); } +} - st.stop(); +st.stop(); })(); |