1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
// Test keep-alive when using mongod's internal HttpClient.
// @tags: [requires_http_client]
(function() {
'use strict';
load('jstests/noPassthrough/libs/configExpand/lib.js');
function runTest(mongod, web) {
assert(mongod);
const admin = mongod.getDB('admin');
// Only bother with this test when using curl >= 7.57.0.
const http_status = admin.adminCommand({serverStatus: 1, http_client: 1});
const http_client = assert.commandWorked(http_status).http_client;
if (http_client.type !== 'curl') {
print("*** Skipping test, not using curl");
return;
}
printjson(http_client);
if (http_client.running.version_num < 0x73900) {
// 39 hex == 57 dec, so 0x73900 == 7.57.0
print(
"*** Skipping test, curl < 7.57.0 does not support connection pooling via share interface");
return;
}
// Issue a series of requests to the mock server.
for (let i = 0; i < 10; ++i) {
const cmd = admin.runCommand({httpClientRequest: 1, uri: web.getStringReflectionURL(i)});
const reflect = assert.commandWorked(cmd).body;
assert.eq(reflect, i, "Mock server reflected something unexpected.");
}
// Check connect count.
const countCmd = admin.runCommand({httpClientRequest: 1, uri: web.getURL() + '/connect_count'});
const count = assert.commandWorked(countCmd).body;
assert.eq(count, 1, "Connections were not kept alive.");
// Force the open connection to close.
const closeCmd =
admin.runCommand({httpClientRequest: 1, uri: web.getURL() + '/connection_close'});
const close = assert.commandWorked(closeCmd).body;
assert.eq(close, 'closed');
// Check count with new connection.
const connectsCmd =
admin.runCommand({httpClientRequest: 1, uri: web.getURL() + '/connect_count'});
const connects = assert.commandWorked(connectsCmd).body;
assert.eq(connects, 2, "Connection count incorrect.");
// Check 404 returns failure.
const failedCmd = assert.commandWorked(
admin.runCommand({httpClientRequest: 1, uri: web.getURL() + '/no_such_path'}));
assert.eq(failedCmd.code, 404);
}
const web = new ConfigExpandRestServer();
web.start();
const mongod = MongoRunner.runMongod({setParameter: 'enableTestCommands=1'});
runTest(mongod, web);
MongoRunner.stopMongod(mongod);
web.stop();
})();
|
