mongodb/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SERVER-110848: improve failure logging in rejected connection pool request.js (#41293)

Browse Source 
GitOrigin-RevId: cd97ae3cf9de3d1a6eb81d971de9163c8377d1d1
This commit is contained in:
David Goffredo 2025-09-15 12:15:29 -04:00 committed by MongoDB Bot
parent 512da4ead9
commit 39a82bbf50
2 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -227,6 +227,7 @@ selected_tests_config
codereview.rc
# Python venvs and virtualenvs
python-venv
python3-venv
python2-venv

19
jstests/noPassthrough/network/rejected_connection_pool_request.js
View File

@ -39,7 +39,9 @@ assert.commandWorked(database.runCommand({create: collectionName, writeConcern:
assert.commandWorked(database.runCommand({find: collectionName}));
const kMaxWaitTimeInSeconds = 10;
const kFailPointTimeoutInSeconds = 5;
const kMaxWaitTimeInSeconds = 30;
const kRetryIntervalInMilliseconds = 1000;
const kMaxQueueDepth = 2;
const kMaxPoolSize = 2;
admin.runCommand({setParameter: 1, ShardingTaskExecutorPoolMaxQueueDepth: kMaxQueueDepth});
@ -57,7 +59,7 @@ for (let i = 0; i < kMaxPoolSize; ++i) {
t.start();
}
primaryFP.wait(5000, kMaxPoolSize);
primaryFP.wait(1000 * kFailPointTimeoutInSeconds, kMaxPoolSize);
// New requests should go and wait in the queue.
for (let i = 0; i < kMaxQueueDepth; ++i) {
@ -67,11 +69,18 @@ for (let i = 0; i < kMaxQueueDepth; ++i) {
}
// Wait until new requests populate the queue.
const actuals = [];
const expected = kMaxQueueDepth;
assert.soon(
() => getPendingCount() == kMaxQueueDepth,
"Failed to wait for the queue size to reach the limit",
() => {
const actual = getPendingCount();
actuals.push(actual);
return expected == actual;
},
() =>
`Failed to wait for the queue size to reach the limit. Was expecting the pending connection count to reach ${expected}, but instead it had the following values: ${tojson(actuals)}`,
1000 * kMaxWaitTimeInSeconds,
1000,
kRetryIntervalInMilliseconds,
);
const res = database.runCommand({find: collectionName});