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
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
/*
* Tests that migrations behave correctly between v4.4 and v4.7+ when one or both nodes have the
* 'disableResumableRangeDeleter' parameter set to true.
*
* requires_persistence because this test restarts shards and expects them to have their data files.
* @tags: [requires_persistence]
*/
(function() {
"use strict";
const dbName = "test";
function getNewNs(dbName) {
if (typeof getNewNs.counter == 'undefined') {
getNewNs.counter = 0;
}
getNewNs.counter++;
const collName = "ns" + getNewNs.counter;
return [collName, dbName + "." + collName];
}
function setDisableResumableRangeDeleter(value, rs) {
const getParameterRes =
rs.getPrimary().adminCommand({getParameter: 1, disableResumableRangeDeleter: 1});
assert.commandWorked(getParameterRes);
if (getParameterRes.disableResumableRangeDeleter == value) {
return;
}
rs.stopSet(null /* signal */, true /* forRestart */);
rs.startSet({restart: true, setParameter: {disableResumableRangeDeleter: value}});
}
const st = new ShardingTest({
shards: {rs0: {nodes: [{binVersion: "latest"}]}, rs1: {nodes: [{binVersion: "last-lts"}]}},
other: {mongosOptions: {binVersion: "last-lts"}}
});
assert.commandWorked(st.s.adminCommand({enableSharding: dbName}));
assert.commandWorked(st.s.adminCommand({movePrimary: dbName, to: st.shard0.shardName}));
const vLatestShard = st.rs0;
const v44shard = st.rs1;
//
// Tests with v4.7+ donor, v4.4 recipient
//
(() => {
jsTestLog("v4.7+ donor, v4.4 recipient, both disableResumableRangeDeleter=false");
setDisableResumableRangeDeleter(false, vLatestShard);
setDisableResumableRangeDeleter(false, v44shard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: v44shard.name}));
})();
(() => {
jsTestLog(
"v4.7+ donor with disableResumableRangeDeleter=true, v4.4 recipient with disableResumableRangeDeleter=false");
setDisableResumableRangeDeleter(true, vLatestShard);
setDisableResumableRangeDeleter(false, v44shard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: v44shard.name}));
})();
(() => {
jsTestLog("v4.7+ donor, v4.4 recipient, both disableResumableRangeDeleter=true");
setDisableResumableRangeDeleter(true, vLatestShard);
setDisableResumableRangeDeleter(true, v44shard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: v44shard.name}));
})();
(() => {
jsTestLog(
"v4.7+ donor with disableResumableRangeDeleter=false, v4.4 recipient with disableResumableRangeDeleter=true");
setDisableResumableRangeDeleter(false, vLatestShard);
setDisableResumableRangeDeleter(true, v44shard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: v44shard.name}));
})();
//
// Tests with v4.4 donor, v4.7+ recipient
//
assert.commandWorked(st.s.adminCommand({movePrimary: dbName, to: st.shard1.shardName}));
(() => {
jsTestLog("v4.4 donor, v4.7+ recipient, both disableResumableRangeDeleter=false");
setDisableResumableRangeDeleter(false, v44shard);
setDisableResumableRangeDeleter(false, vLatestShard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: vLatestShard.name}));
})();
(() => {
jsTestLog(
"v4.4 donor with disableResumableRangeDeleter=true, v4.7+ recipient with disableResumableRangeDeleter=false");
setDisableResumableRangeDeleter(true, v44shard);
setDisableResumableRangeDeleter(false, vLatestShard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: vLatestShard.name}));
})();
(() => {
jsTestLog("v4.4 donor, v4.7+ recipient, both disableResumableRangeDeleter=true");
setDisableResumableRangeDeleter(true, v44shard);
setDisableResumableRangeDeleter(true, vLatestShard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: vLatestShard.name}));
})();
(() => {
jsTestLog(
"v4.4 donor with disableResumableRangeDeleter=false, v4.7+ recipient with disableResumableRangeDeleter=true");
setDisableResumableRangeDeleter(false, v44shard);
setDisableResumableRangeDeleter(true, vLatestShard);
const [collName, ns] = getNewNs(dbName);
assert.commandWorked(st.s.adminCommand({shardCollection: ns, key: {x: 1}}));
assert.commandWorked(st.s.adminCommand({moveChunk: ns, find: {x: 0}, to: vLatestShard.name}));
})();
st.stop();
})();
|
