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
|
'use strict';
load("jstests/sharding/libs/find_chunks_util.js");
var CheckOrphansAreDeletedHelpers = (function() {
function runCheck(mongosConn, shardConn, shardId) {
const configDB = shardConn.getDB('config');
let migrationCoordinatorDocs = [];
assert.soon(
() => {
try {
migrationCoordinatorDocs = configDB.migrationCoordinators.find().toArray();
return migrationCoordinatorDocs.length === 0;
} catch (exp) {
// Primary purpose is to stabilize shell repl set monitor to recognize the
// current primary.
print('caught exception while checking migration coordinators, ' +
'will retry again unless timed out: ' + tojson(exp));
}
},
() => {
return 'timed out waiting for migrationCoordinators to be empty @ ' + shardId +
', last known contents: ' + tojson(migrationCoordinatorDocs);
},
5 * 60 * 1000,
1000);
// TODO SERVER-51881: Remove the checking for 'dropped: {$ne: true}' after 5.0 is released
mongosConn.getDB('config').collections.find({dropped: {$ne: true}}).forEach(collDoc => {
const ns = collDoc._id;
const tempNsArray = ns.split('.');
const dbName = tempNsArray.shift();
const collName = tempNsArray.join('.');
// It is possible for a test to drop the shard key index. We skip running the check for
// orphan documents being deleted from that collection if it doesn't have a shard key
// index.
const hintRes = shardConn.getDB(dbName).runCommand({
find: collName,
hint: collDoc.key,
limit: 1,
singleBatch: true,
});
if (hintRes.ok !== 1) {
assert(
/hint provided does not correspond to an existing index/.test(hintRes.errmsg),
() => {
return 'expected query failure due to bad hint: ' + tojson(hintRes);
});
print('Failed to find shard key index on ' + ns +
' so skipping check for orphan documents being deleted');
return;
}
print('Checking that orphan documents on shard ' + shardId +
' have been deleted from namespace ' + ns);
let rangeDeletions = [];
assert.soon(
() => {
rangeDeletions = configDB.rangeDeletions.find({nss: ns}).toArray();
return rangeDeletions.length === 0;
},
() => {
return 'timed out waiting for rangeDeletions on ' + ns + ' to be empty @ ' +
shardId + ', last known contents: ' + tojson(rangeDeletions);
});
const coll = shardConn.getDB(dbName)[collName];
findChunksUtil.findChunksByNs(mongosConn.getDB('config'), ns, {shard: {$ne: shardId}})
.forEach(chunkDoc => {
// Use $min/$max so this will also work with hashed and compound shard keys.
const orphans = coll.find({})
.hint(collDoc.key)
.min(chunkDoc.min)
.max(chunkDoc.max)
.toArray();
assert.eq(0,
orphans.length,
'found orphans @ ' + shardId + ' within chunk: ' + tojson(chunkDoc) +
', orphans: ' + tojson(orphans));
});
});
}
return {
runCheck: runCheck,
};
})();
|
