543 lines
25 KiB
JavaScript
543 lines
25 KiB
JavaScript
/**
|
|
* Util functions used by cluster server parameter tests.
|
|
*
|
|
* When adding new cluster server parameter, do the following:
|
|
* If it's test-only, add its definition to kTestOnlyClusterParameters.
|
|
* Otherwise, add to kNonTestOnlyClusterParameters.
|
|
* The keyname will be the name of the cluster-wide server parameter,
|
|
* it's value will be an object with at least three keys named:
|
|
* * 'default': Properties to expect on an unset CWSP
|
|
* * 'testValues': List of two other valid values of the CWSP to set for testing purposes
|
|
* An additional property 'featureFlag' may also be set if the
|
|
* parameter depends on a featureFlag.
|
|
* Use the name of the featureFlag if it is required in
|
|
* order to consider the parameter.
|
|
* Prefix the name with a bang '!' if it is only considered
|
|
* when the featureFlag is disabled.
|
|
*/
|
|
|
|
load("jstests/libs/feature_flag_util.js");
|
|
|
|
const kNonTestOnlyClusterParameters = {
|
|
changeStreamOptions: {
|
|
default: {preAndPostImages: {expireAfterSeconds: 'off'}},
|
|
testValues: [
|
|
{preAndPostImages: {expireAfterSeconds: 30}},
|
|
{preAndPostImages: {expireAfterSeconds: 20}}
|
|
],
|
|
featureFlag: '!ServerlessChangeStreams',
|
|
},
|
|
changeStreams: {
|
|
default: {expireAfterSeconds: NumberLong(3600)},
|
|
testValues: [{expireAfterSeconds: 30}, {expireAfterSeconds: 10}],
|
|
featureFlag: 'ServerlessChangeStreams',
|
|
setParameters: {'multitenancySupport': true},
|
|
serverless: true,
|
|
},
|
|
};
|
|
|
|
const kTestOnlyClusterParameters = {
|
|
cwspTestNeedsFeatureFlagClusterWideToaster: {
|
|
default: {intData: 16},
|
|
testValues: [{intData: 17}, {intData: 18}],
|
|
featureFlag: 'ClusterWideToaster',
|
|
},
|
|
testStrClusterParameter: {
|
|
default: {strData: 'off'},
|
|
testValues: [{strData: 'on'}, {strData: 'sleep'}],
|
|
},
|
|
testIntClusterParameter: {
|
|
default: {intData: 16},
|
|
testValues: [{intData: 17}, {intData: 18}],
|
|
},
|
|
testBoolClusterParameter: {
|
|
default: {boolData: false},
|
|
testValues: [{boolData: true}, {boolData: false}],
|
|
},
|
|
};
|
|
|
|
const kAllClusterParameters =
|
|
Object.assign({}, kNonTestOnlyClusterParameters, kTestOnlyClusterParameters);
|
|
const kAllClusterParameterNames = Object.keys(kAllClusterParameters);
|
|
const kAllClusterParameterDefaults = kAllClusterParameterNames.map(
|
|
(name) => Object.assign({_id: name}, kAllClusterParameters[name].default));
|
|
const kAllClusterParameterValues1 = kAllClusterParameterNames.map(
|
|
(name) => Object.assign({_id: name}, kAllClusterParameters[name].testValues[0]));
|
|
const kAllClusterParameterValues2 = kAllClusterParameterNames.map(
|
|
(name) => Object.assign({_id: name}, kAllClusterParameters[name].testValues[1]));
|
|
|
|
const kNonTestOnlyClusterParameterDefaults =
|
|
Object.keys(kNonTestOnlyClusterParameters)
|
|
.map((name) => Object.assign({_id: name}, kAllClusterParameters[name].default));
|
|
|
|
function considerParameter(paramName, conn) {
|
|
// { featureFlag: 'name' } indicates that the CWSP should only be considered with the FF
|
|
// enabled. { featureFlag: '!name' } indicates that the CWSP should only be considered with the
|
|
// FF disabled.
|
|
function validateFeatureFlag(cp) {
|
|
if (cp.featureFlag) {
|
|
const considerWhenFFEnabled = cp.featureFlag[0] !== '!';
|
|
const ff = cp.featureFlag.substr(considerWhenFFEnabled ? 0 : 1);
|
|
return FeatureFlagUtil.isEnabled(conn, ff) === considerWhenFFEnabled;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
// A dictionary of 'setParameters' that should be validated while considering the current CWSP.
|
|
function validateSetParameter(cp) {
|
|
if (cp.setParameters) {
|
|
for ([param, value] of Object.entries(cp.setParameters)) {
|
|
const resp = conn.getDB("admin").runCommand({getParameter: 1, param: 1});
|
|
const hasParam = resp.hasOwnProperty(param) && resp[param] === value;
|
|
if (!hasParam) {
|
|
return false;
|
|
}
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
// Check if the current CWSP should be run in the serverless.
|
|
function validateServerless(cp) {
|
|
if (cp.hasOwnProperty("serverless")) {
|
|
const resp =
|
|
assert.commandWorked(conn.getDB("admin").adminCommand({getCmdLineOpts: 1}));
|
|
return cp.serverless === resp.parsed && resp.parsed.replication &&
|
|
resp.parsed.replication.serverless;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
const cp = kAllClusterParameters[paramName] || {};
|
|
return validateFeatureFlag(cp) && validateSetParameter(cp) && validateServerless(cp);
|
|
}
|
|
|
|
function tenantCommand(command, tenantId) {
|
|
if (tenantId === undefined) {
|
|
return command;
|
|
} else {
|
|
return Object.assign({}, command, {"$tenant": tenantId});
|
|
}
|
|
}
|
|
|
|
// Set the log level for get/setClusterParameter logging to appear.
|
|
function setupNode(conn) {
|
|
const adminDB = conn.getDB('admin');
|
|
adminDB.setLogLevel(2);
|
|
}
|
|
|
|
function setupReplicaSet(rst) {
|
|
setupNode(rst.getPrimary());
|
|
|
|
rst.getSecondaries().forEach(function(secondary) {
|
|
setupNode(secondary);
|
|
});
|
|
}
|
|
|
|
function setupSharded(st) {
|
|
setupNode(st.s0);
|
|
|
|
const shards = [st.rs0, st.rs1, st.rs2];
|
|
shards.forEach(function(shard) {
|
|
setupReplicaSet(shard);
|
|
});
|
|
}
|
|
|
|
// Upserts config.clusterParameters document with w:majority via setClusterParameter.
|
|
function runSetClusterParameter(conn, update, tenantId) {
|
|
const paramName = update._id;
|
|
if (!considerParameter(paramName, conn)) {
|
|
return;
|
|
}
|
|
let updateCopy = Object.assign({}, update);
|
|
delete updateCopy._id;
|
|
delete updateCopy.clusterParameterTime;
|
|
const setClusterParameterDoc = {
|
|
[paramName]: updateCopy,
|
|
};
|
|
|
|
const adminDB = conn.getDB('admin');
|
|
assert.commandWorked(
|
|
adminDB.runCommand(tenantCommand({setClusterParameter: setClusterParameterDoc}, tenantId)));
|
|
}
|
|
|
|
// Runs getClusterParameter on a specific mongod or mongos node and returns true/false depending
|
|
// on whether the expected values were returned.
|
|
function runGetClusterParameterNode(
|
|
conn, getClusterParameterArgs, expectedClusterParameters, tenantId) {
|
|
const adminDB = conn.getDB('admin');
|
|
|
|
// Filter out parameters that we don't care about.
|
|
if (Array.isArray(getClusterParameterArgs)) {
|
|
getClusterParameterArgs =
|
|
getClusterParameterArgs.filter((name) => considerParameter(name, conn));
|
|
} else if ((typeof getClusterParameterArgs === 'string') &&
|
|
!considerParameter(getClusterParameterArgs, conn)) {
|
|
return true;
|
|
}
|
|
|
|
const actualClusterParameters =
|
|
assert
|
|
.commandWorked(adminDB.runCommand(
|
|
tenantCommand({getClusterParameter: getClusterParameterArgs}, tenantId)))
|
|
.clusterParameters;
|
|
|
|
// Reindex actual based on name, and remove irrelevant field.
|
|
let actual = {};
|
|
actualClusterParameters.forEach(function(acp) {
|
|
actual[acp._id] = acp;
|
|
delete actual[acp._id].clusterParameterTime;
|
|
});
|
|
|
|
for (let i = 0; i < expectedClusterParameters.length; i++) {
|
|
if (!considerParameter(expectedClusterParameters[i]._id, conn)) {
|
|
continue;
|
|
}
|
|
|
|
const id = expectedClusterParameters[i]._id;
|
|
if (actual[id] === undefined) {
|
|
jsTest.log('Expected to retreive ' + id + ' but it was not returned');
|
|
return false;
|
|
}
|
|
|
|
if (bsonWoCompare(expectedClusterParameters[i], actual[id]) !== 0) {
|
|
jsTest.log('Server parameter mismatch on node: ' + conn.host + '\n' +
|
|
'Expected: ' + tojson(expectedClusterParameters[i]) + '\n' +
|
|
'Actual: ' + tojson(actual[id]));
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
// Runs getClusterParameter on each replica set node and asserts that the response matches the
|
|
// expected parameter objects on at least a majority of nodes.
|
|
function runGetClusterParameterReplicaSet(
|
|
rst, getClusterParameterArgs, expectedClusterParameters, tenantId) {
|
|
let numMatches = 0;
|
|
const numTotalNodes = rst.getSecondaries().length + 1;
|
|
if (runGetClusterParameterNode(
|
|
rst.getPrimary(), getClusterParameterArgs, expectedClusterParameters, tenantId)) {
|
|
numMatches++;
|
|
}
|
|
|
|
rst.getSecondaries().forEach(function(secondary) {
|
|
if (runGetClusterParameterNode(
|
|
secondary, getClusterParameterArgs, expectedClusterParameters, tenantId)) {
|
|
numMatches++;
|
|
}
|
|
});
|
|
|
|
assert((numMatches / numTotalNodes) > 0.5);
|
|
}
|
|
|
|
// Runs getClusterParameter on mongos, each mongod in each shard replica set, and each mongod in
|
|
// the config server replica set.
|
|
function runGetClusterParameterSharded(
|
|
st, getClusterParameterArgs, expectedClusterParameters, tenantId) {
|
|
runGetClusterParameterNode(st.s0, getClusterParameterArgs, expectedClusterParameters, tenantId);
|
|
|
|
runGetClusterParameterReplicaSet(
|
|
st.configRS, getClusterParameterArgs, expectedClusterParameters, tenantId);
|
|
const shards = [st.rs0, st.rs1, st.rs2];
|
|
shards.forEach(function(shard) {
|
|
runGetClusterParameterReplicaSet(
|
|
shard, getClusterParameterArgs, expectedClusterParameters, tenantId);
|
|
});
|
|
}
|
|
|
|
// Tests valid usages of set/getClusterParameter and verifies that the expected values are returned.
|
|
function testValidClusterParameterCommands(conn) {
|
|
if (conn instanceof ReplSetTest) {
|
|
// Run getClusterParameter in list format and '*' and ensure it returns all default values
|
|
// on all nodes in the replica set.
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterDefaults);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterDefaults);
|
|
|
|
// For each parameter, run setClusterParameter and verify that getClusterParameter
|
|
// returns the updated value on all nodes in the replica set.
|
|
for (let i = 0; i < kAllClusterParameterNames.length; i++) {
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues1[i]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]]);
|
|
|
|
// Verify that document updates are also handled properly.
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues2[i]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues2[i]]);
|
|
}
|
|
|
|
// Finally, run getClusterParameter in list format and '*' and ensure that they now all
|
|
// return updated values.
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterValues2);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterValues2);
|
|
} else {
|
|
// Run getClusterParameter in list format and '*' and ensure it returns all default values
|
|
// on all nodes in the sharded cluster.
|
|
runGetClusterParameterSharded(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterDefaults);
|
|
runGetClusterParameterSharded(conn, '*', kAllClusterParameterDefaults);
|
|
|
|
// For each parameter, simulate setClusterParameter and verify that getClusterParameter
|
|
// returns the updated value on all nodes in the sharded cluster.
|
|
for (let i = 0; i < kAllClusterParameterNames.length; i++) {
|
|
runSetClusterParameter(conn.s0, kAllClusterParameterValues1[i]);
|
|
runGetClusterParameterSharded(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]]);
|
|
|
|
// Verify that document updates are also handled properly.
|
|
runSetClusterParameter(conn.s0, kAllClusterParameterValues2[i]);
|
|
runGetClusterParameterSharded(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues2[i]]);
|
|
}
|
|
|
|
// Finally, run getClusterParameter in list format and '*' and ensure that they now all
|
|
// return updated values.
|
|
runGetClusterParameterSharded(conn, kAllClusterParameterNames, kAllClusterParameterValues2);
|
|
runGetClusterParameterSharded(conn, '*', kAllClusterParameterValues2);
|
|
}
|
|
}
|
|
|
|
const tenantId1 = ObjectId();
|
|
const tenantId2 = ObjectId();
|
|
|
|
// Tests valid usages of set/getClusterParameter on a serverless replica set and verifies that the
|
|
// expected values are returned.
|
|
function testValidServerlessClusterParameterCommands(conn) {
|
|
// TODO SERVER-69663 Add serverless sharded cluster tests once supported.
|
|
assert(conn instanceof ReplSetTest);
|
|
assert(
|
|
!considerParameter("changeStreamOptions", conn.getPrimary()),
|
|
"As changeStreamOptions is not supported for serverless configurations, the feature flag ServerlessChangeStreams must be enabled to run this test.");
|
|
|
|
// Run getClusterParameter in list format and '*' and ensure it returns all default values
|
|
// on all nodes in the replica set, with and without tenantId set.
|
|
runGetClusterParameterReplicaSet(conn, kAllClusterParameterNames, kAllClusterParameterDefaults);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterDefaults);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterDefaults, tenantId1);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterDefaults, tenantId1);
|
|
|
|
// For each parameter, run setClusterParameter and verify that getClusterParameter
|
|
// returns the updated value on all nodes in the replica set for the tenant it was set on.
|
|
for (let i = 0; i < kAllClusterParameterNames.length; i++) {
|
|
// Test inserts for tenant1 and default tenant.
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues1[i], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterDefaults[i]], tenantId2);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterDefaults[i]]);
|
|
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues2[i]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues2[i]]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterDefaults[i]], tenantId2);
|
|
|
|
// Test updates for tenant1 and default tenant.
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues1[i]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterDefaults[i]], tenantId2);
|
|
|
|
runSetClusterParameter(conn.getPrimary(), kAllClusterParameterValues2[i], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues1[i]]);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterValues2[i]], tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames[i], [kAllClusterParameterDefaults[i]], tenantId2);
|
|
}
|
|
|
|
// Finally, run getClusterParameter in list format and '*' and ensure that they now all
|
|
// return updated values.
|
|
runGetClusterParameterReplicaSet(conn, kAllClusterParameterNames, kAllClusterParameterValues1);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterValues1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterValues2, tenantId1);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterValues2, tenantId1);
|
|
runGetClusterParameterReplicaSet(
|
|
conn, kAllClusterParameterNames, kAllClusterParameterDefaults, tenantId2);
|
|
runGetClusterParameterReplicaSet(conn, '*', kAllClusterParameterDefaults, tenantId2);
|
|
}
|
|
|
|
// Assert that explicitly getting a disabled cluster server parameter fails on a node.
|
|
function testExplicitDisabledGetClusterParameter(conn, tenantId) {
|
|
const adminDB = conn.getDB('admin');
|
|
assert.commandFailedWithCode(adminDB.runCommand(tenantCommand(
|
|
{getClusterParameter: "testIntClusterParameter"}, tenantId)),
|
|
ErrorCodes.BadValue);
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand(
|
|
{getClusterParameter: ["changeStreamOptions", "testIntClusterParameter"]}, tenantId)),
|
|
ErrorCodes.BadValue);
|
|
}
|
|
|
|
// Tests that disabled cluster server parameters return errors or are filtered out as appropriate
|
|
// by get/setClusterParameter.
|
|
function testDisabledClusterParameters(conn, tenantId) {
|
|
if (conn instanceof ReplSetTest) {
|
|
// Assert that explicitly setting a disabled cluster server parameter fails.
|
|
const adminDB = conn.getPrimary().getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.BadValue);
|
|
|
|
// Assert that explicitly getting a disabled cluster server parameter fails on the primary.
|
|
testExplicitDisabledGetClusterParameter(conn.getPrimary(), tenantId);
|
|
|
|
// Assert that explicitly getting a disabled cluster server parameter fails on secondaries.
|
|
conn.getSecondaries().forEach(function(secondary) {
|
|
testExplicitDisabledGetClusterParameter(secondary, tenantId);
|
|
});
|
|
|
|
// Assert that getClusterParameter: '*' succeeds but only returns enabled cluster
|
|
// parameters.
|
|
runGetClusterParameterReplicaSet(conn, '*', kNonTestOnlyClusterParameterDefaults, tenantId);
|
|
} else {
|
|
// Assert that explicitly setting a disabled cluster server parameter fails.
|
|
const adminDB = conn.s0.getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.IllegalOperation);
|
|
|
|
// Assert that explicitly getting a disabled cluster server parameter fails on mongos.
|
|
testExplicitDisabledGetClusterParameter(conn.s0, tenantId);
|
|
|
|
// Assert that explicitly getting a disabled cluster server parameter on each shard replica
|
|
// set and the config replica set fails.
|
|
const shards = [conn.rs0, conn.rs1, conn.rs2];
|
|
const configRS = conn.configRS;
|
|
shards.forEach(function(shard) {
|
|
testExplicitDisabledGetClusterParameter(shard.getPrimary(), tenantId);
|
|
shard.getSecondaries().forEach(function(secondary) {
|
|
testExplicitDisabledGetClusterParameter(secondary, tenantId);
|
|
});
|
|
});
|
|
|
|
testExplicitDisabledGetClusterParameter(configRS.getPrimary());
|
|
configRS.getSecondaries().forEach(function(secondary) {
|
|
testExplicitDisabledGetClusterParameter(secondary, tenantId);
|
|
});
|
|
|
|
// Assert that getClusterParameter: '*' succeeds but only returns enabled cluster
|
|
// parameters.
|
|
runGetClusterParameterSharded(conn, '*', kNonTestOnlyClusterParameterDefaults, tenantId);
|
|
}
|
|
}
|
|
|
|
// Tests that invalid uses of getClusterParameter fails on a given node.
|
|
function testInvalidGetClusterParameter(conn, tenantId) {
|
|
const adminDB = conn.getDB('admin');
|
|
// Assert that specifying a nonexistent parameter returns an error.
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand({getClusterParameter: "nonexistentParam"}, tenantId)),
|
|
ErrorCodes.NoSuchKey);
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand({getClusterParameter: ["nonexistentParam"]}, tenantId)),
|
|
ErrorCodes.NoSuchKey);
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand(
|
|
{getClusterParameter: ["testIntClusterParameter", "nonexistentParam"]}, tenantId)),
|
|
ErrorCodes.NoSuchKey);
|
|
assert.commandFailedWithCode(
|
|
adminDB.runCommand(tenantCommand({getClusterParameter: []}, tenantId)),
|
|
ErrorCodes.BadValue);
|
|
}
|
|
|
|
// Tests that invalid uses of set/getClusterParameter fail with the appropriate errors.
|
|
function testInvalidClusterParameterCommands(conn, tenantId) {
|
|
if (conn instanceof ReplSetTest) {
|
|
const adminDB = conn.getPrimary().getDB('admin');
|
|
|
|
// Assert that invalid uses of getClusterParameter fail on the primary.
|
|
testInvalidGetClusterParameter(conn.getPrimary(), tenantId);
|
|
|
|
// Assert that setting a nonexistent parameter on the primary returns an error.
|
|
assert.commandFailed(adminDB.runCommand(
|
|
tenantCommand({setClusterParameter: {nonexistentParam: {intData: 5}}}, tenantId)));
|
|
|
|
// Assert that running setClusterParameter with a scalar value fails.
|
|
assert.commandFailed(adminDB.runCommand(
|
|
tenantCommand({setClusterParameter: {testIntClusterParameter: 5}}, tenantId)));
|
|
|
|
conn.getSecondaries().forEach(function(secondary) {
|
|
// Assert that setClusterParameter cannot be run on a secondary.
|
|
const secondaryAdminDB = secondary.getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
secondaryAdminDB.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.NotWritablePrimary);
|
|
// Assert that invalid uses of getClusterParameter fail on secondaries.
|
|
testInvalidGetClusterParameter(secondary, tenantId);
|
|
});
|
|
} else {
|
|
const adminDB = conn.s0.getDB('admin');
|
|
|
|
// Assert that invalid uses of getClusterParameter fail on mongos.
|
|
testInvalidGetClusterParameter(conn.s0, tenantId);
|
|
|
|
// Assert that setting a nonexistent parameter on the mongos returns an error.
|
|
assert.commandFailed(adminDB.runCommand(
|
|
tenantCommand({setClusterParameter: {nonexistentParam: {intData: 5}}}, tenantId)));
|
|
|
|
// Assert that running setClusterParameter with a scalar value fails.
|
|
assert.commandFailed(adminDB.runCommand(
|
|
tenantCommand({setClusterParameter: {testIntClusterParameter: 5}}, tenantId)));
|
|
|
|
const shards = [conn.rs0, conn.rs1, conn.rs2];
|
|
shards.forEach(function(shard) {
|
|
// Assert that setClusterParameter cannot be run directly on a shard primary.
|
|
const shardPrimaryAdmin = shard.getPrimary().getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
shardPrimaryAdmin.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.NotImplemented);
|
|
// Assert that invalid forms of getClusterParameter fail on the shard primary.
|
|
testInvalidGetClusterParameter(shard.getPrimary(), tenantId);
|
|
shard.getSecondaries().forEach(function(secondary) {
|
|
// Assert that setClusterParameter cannot be run on a shard secondary.
|
|
const shardSecondaryAdmin = secondary.getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
shardSecondaryAdmin.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.NotWritablePrimary);
|
|
// Assert that invalid forms of getClusterParameter fail on shard secondaries.
|
|
testInvalidGetClusterParameter(secondary, tenantId);
|
|
});
|
|
});
|
|
|
|
// Assert that setClusterParameter cannot be run directly on the configsvr primary.
|
|
const configRS = conn.configRS;
|
|
const configPrimaryAdmin = configRS.getPrimary().getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
configPrimaryAdmin.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.NotImplemented);
|
|
// Assert that invalid forms of getClusterParameter fail on the configsvr primary.
|
|
testInvalidGetClusterParameter(configRS.getPrimary(), tenantId);
|
|
configRS.getSecondaries().forEach(function(secondary) {
|
|
// Assert that setClusterParameter cannot be run on a configsvr secondary.
|
|
const configSecondaryAdmin = secondary.getDB('admin');
|
|
assert.commandFailedWithCode(
|
|
configSecondaryAdmin.runCommand(tenantCommand(
|
|
{setClusterParameter: {testIntClusterParameter: {intData: 5}}}, tenantId)),
|
|
ErrorCodes.NotWritablePrimary);
|
|
// Assert that invalid forms of getClusterParameter fail on configsvr secondaries.
|
|
testInvalidGetClusterParameter(secondary, tenantId);
|
|
});
|
|
}
|
|
}
|