blob: ec3029217cba5b53ab0a04ecbd3920747f57d426 (
plain)
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
|
/**
* Tests that a stale mongos does not return a stale shardVersion error to the client for explain
* of a find command.
*/
(function() {
"use strict";
const dbName = "test";
const collName = "foo";
const ns = dbName + "." + collName;
const st = new ShardingTest({mongos: 2, shards: 1, verbose: 2});
let staleMongos = st.s0;
let freshMongos = st.s1;
jsTest.log("Make the stale mongos load a cache entry for db " + dbName + " once");
assert.commandWorked(staleMongos.getDB(dbName).getCollection(collName).insert({_id: 1}));
jsTest.log("Call shardCollection on " + ns + " from the fresh mongos");
assert.commandWorked(freshMongos.adminCommand({enableSharding: dbName}));
assert.commandWorked(freshMongos.adminCommand({shardCollection: ns, key: {"_id": 1}}));
jsTest.log("Ensure the shard knows " + ns + " is sharded");
const clusterVersionInfo = st.getClusterVersionInfo();
if (clusterVersionInfo.isMixedVersion) {
assert.commandWorked(
st.shard0.adminCommand({_flushRoutingTableCacheUpdates: ns, syncFromConfig: true}));
} else {
// _flushRoutingTableCacheUpdatesWithWriteConcern did not exist in older versions of the server.
// Confirm that flushing the routing table with write concern does not change the existing
// behavior of this test.
assert.commandWorked(st.shard0.adminCommand({
_flushRoutingTableCacheUpdatesWithWriteConcern: ns,
syncFromConfig: true,
writeConcern: {w: "majority"}
}));
}
jsTest.log("Run explain find on " + ns + " from the stale mongos");
staleMongos.getDB(dbName).getCollection(collName).explain().find().next();
st.stop();
})();
|
