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
|
/**
* Test for the ReshardingTest fixture itself.
*
* Verifies that an exception is thrown if a recipient shard has a document it doesn't actually own.
*
* @tags: [
* uses_atclustertime,
* ]
*/
(function() {
"use strict";
load('jstests/libs/discover_topology.js');
load("jstests/sharding/libs/resharding_test_fixture.js");
load('jstests/sharding/libs/shard_versioning_util.js');
// The test purposely emplaces documents on a shard that doesn't own them.
TestData.skipCheckOrphans = true;
const reshardingTest = new ReshardingTest({numDonors: 1, numRecipients: 2});
reshardingTest.setup();
const ns = "reshardingDb.coll";
const donorShardNames = reshardingTest.donorShardNames;
const sourceCollection = reshardingTest.createShardedCollection({
ns,
shardKeyPattern: {oldKey: 1},
chunks: [{min: {oldKey: MinKey}, max: {oldKey: MaxKey}, shard: donorShardNames[0]}],
});
// Perform some inserts before resharding starts so there's data to clone.
assert.commandWorked(sourceCollection.insert([
{_id: "moves to recipient0", oldKey: -10, newKey: -10},
{_id: "moves to recipient1", oldKey: 10, newKey: 10},
]));
const mongos = sourceCollection.getMongo();
const topology = DiscoverTopology.findConnectedNodes(mongos);
const recipientShardNames = reshardingTest.recipientShardNames;
const recipient0 = new Mongo(topology.shards[recipientShardNames[0]].primary);
const err = assert.throws(() => {
reshardingTest.withReshardingInBackground(
{
newShardKeyPattern: {newKey: 1},
newChunks: [
{min: {newKey: MinKey}, max: {newKey: 0}, shard: recipientShardNames[0]},
{min: {newKey: 0}, max: {newKey: MaxKey}, shard: recipientShardNames[1]},
],
},
(tempNs) => {
// Wait for the recipients to have finished cloning so the temporary resharding
// collection is known to exist.
assert.soon(() => {
const coordinatorDoc =
mongos.getCollection("config.reshardingOperations").findOne();
return coordinatorDoc !== null && coordinatorDoc.state === "applying";
});
// Insert a document directly into recipient0 that is truly owned by recipient1.
const tempColl = recipient0.getCollection(tempNs);
assert.commandWorked(tempColl.runCommand("insert", {
documents: [{_id: "unowned by recipient0", oldKey: 10, newKey: 10}],
shardVersion: ShardVersioningUtil.kIgnoredShardVersion
}));
});
});
assert(/temporary resharding collection had unowned documents/.test(err.message), err);
// The ReshardingTest fixture will have interrupted the reshardCollection command on mongos so the
// JavaScript thread running the command can be joined. The resharding operation is still active on
// config server so we must manually wait for it to complete.
assert.soon(() => {
const coordinatorDoc = mongos.getCollection("config.reshardingOperations").findOne();
return coordinatorDoc === null;
});
reshardingTest.teardown();
})();
|
