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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
|
/**
* @tags: [featureFlagLoadBalancer]
*
* Test the extension to the mongos `hello` command by which clients
* that have arrived through a load balancer affirm that they are
* compatible with the way mongos handles load-balanced clients.
* See `src/mongo/s/load_balancing_support.h`.
*/
(() => {
"use strict";
load('jstests/libs/fail_point_util.js');
/**
* The whole ShardingTest is restarted just to get a fresh connection.
* Obviously this could be accomplished much more efficiently.
*/
var runInShardingTest = (func) => {
var st = new ShardingTest({shards: 1, mongos: 1});
try {
func(st.s0.getDB("admin"));
} finally {
st.stop();
}
};
var doHello = (admin, {lbConnection, lbHello, expectServiceId}) => {
if (lbConnection)
assert.commandWorked(admin.adminCommand(
{configureFailPoint: 'clientIsFromLoadBalancer', mode: 'alwaysOn'}));
try {
var helloDoc = {};
if (lbHello)
helloDoc['loadBalanced'] = true;
return admin.runCommand("hello", helloDoc);
} finally {
assert.commandWorked(
admin.adminCommand({configureFailPoint: 'clientIsFromLoadBalancer', mode: 'off'}));
}
};
var assertServiceId = (res) => {
assert.commandWorked(res);
assert(res.hasOwnProperty("serviceId"),
"serviceId missing from hello response:" + tojson(res));
assert(res.serviceId.isObjectId, "res.serviceId = " + tojson(res.serviceId));
};
var assertNoServiceId = (res) => {
assert.commandWorked(res);
assert(!res.hasOwnProperty("serviceId"), "res.serviceId = " + tojson(res.serviceId));
};
/*
* The ordinary baseline non-load-balanced case.
*/
runInShardingTest((admin) => {
// Before getting started, confirm that the feature is enabled.
assert(admin.adminCommand({getParameter: 1, featureFlagLoadBalancer: 1})
.featureFlagLoadBalancer.value,
'featureFlagLoadBalancer should be enabled for this test');
jsTestLog("Initial hello command");
assertNoServiceId(doHello(admin, {}));
jsTestLog("Non-initial hello command");
assertNoServiceId(doHello(admin, {}));
});
/*
* Good case: client arrived via load balancer, and load balancing declared by client.
* The load balancing `serviceId` reporting applies only to the initial hello.
* The `loadBalanced` option is ignored in subsequent `hello` commands.
*/
runInShardingTest((admin) => {
assertServiceId(doHello(admin, {lbConnection: true, lbHello: true}));
assertNoServiceId(doHello(admin, {lbConnection: true, lbHello: true}));
});
/*
* Client did not arrive via load-balancer, but load balancing support declared by client.
* We tolerate the `isLoadBalanced` option but ignore it.
*/
runInShardingTest((admin) => {
assertNoServiceId(doHello(admin, {lbHello: true}));
});
/*
* Client arrived via load balancer, but load balancing support was not declared by client.
* This is an error that should result in a disconnection.
*/
runInShardingTest((admin) => {
var res = doHello(admin, {lbConnection: true});
assert.commandFailedWithCode(res, ErrorCodes.LoadBalancerSupportMismatch);
});
})();
|
