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
|
/**
* Test that unfinishedMigrationFromPreviousPrimary field in shardingStatistics reports the
* expected number.
*/
(function() {
"use strict";
load('./jstests/libs/chunk_manipulation_util.js');
// Test calls step down on primaries.
TestData.skipCheckingUUIDsConsistentAcrossCluster = true;
// For startParallelOps to write its state
var staticMongod = MongoRunner.runMongod({});
let st = new ShardingTest({shards: 2, rs: {nodes: 2}});
assert.commandWorked(st.s.adminCommand({enableSharding: 'test'}));
st.ensurePrimaryShard('test', st.shard0.shardName);
assert.commandWorked(st.s.adminCommand({shardCollection: 'test.user', key: {x: 1}}));
let priConn = st.rs0.getPrimary();
let serverStatusRes = priConn.adminCommand({serverStatus: 1});
assert.eq(0,
serverStatusRes.shardingStatistics.unfinishedMigrationFromPreviousPrimary,
tojson(serverStatusRes));
pauseMoveChunkAtStep(priConn, moveChunkStepNames.reachedSteadyState);
var joinMoveChunk =
moveChunkParallel(staticMongod, st.s0.host, {x: 0}, null, 'test.user', st.shard1.shardName);
waitForMoveChunkStep(st.shard0, moveChunkStepNames.reachedSteadyState);
try {
priConn.adminCommand({replSetStepDown: 60});
} catch (ex) {
print(`Caught expected exception calling step down: ${tojson(ex)}`);
}
unpauseMoveChunkAtStep(priConn, moveChunkStepNames.reachedSteadyState);
st.rs0.awaitNodesAgreeOnPrimary();
// Wait for migration coordinator recovery to complete before checking server status.
priConn = st.rs0.getPrimary();
assert.soon(() => {
return priConn.getDB('config').migrationCoordinators.count() == 0;
});
serverStatusRes = st.rs0.getPrimary().adminCommand({serverStatus: 1});
assert.eq(1,
serverStatusRes.shardingStatistics.unfinishedMigrationFromPreviousPrimary,
tojson(serverStatusRes));
try {
joinMoveChunk();
} catch (ex) {
print(`Caught expected exception due to step down during migration: ${tojson(ex)}`);
}
st.stop();
MongoRunner.stopMongod(staticMongod);
})();
|
