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
|
'use strict';
/**
* Perform continuous moveChunk on multiple collections/databases.
*
* @tags: [
* requires_sharding,
* assumes_balancer_off,
* does_not_support_add_remove_shards,
* ]
*/
load('jstests/concurrency/fsm_libs/extend_workload.js');
load('jstests/concurrency/fsm_workloads/random_moveChunk_base.js');
const dbNames = ['db0', 'db1', 'db2'];
const collNames = ['collA', 'collB', 'collC'];
const withSkipRetryOnNetworkError = (fn) => {
const previousSkipRetryOnNetworkError = TestData.skipRetryOnNetworkError;
TestData.skipRetryOnNetworkError = true;
let res = undefined;
try {
res = fn();
} catch (e) {
throw e;
} finally {
TestData.skipRetryOnNetworkError = previousSkipRetryOnNetworkError;
}
return res;
};
const runWithManualRetriesIfInStepdownSuite = (fn) => {
if (TestData.runningWithShardStepdowns) {
var result = undefined;
assert.soonNoExcept(() => {
result = withSkipRetryOnNetworkError(fn);
return true;
});
return result;
} else {
return fn();
}
};
var $config = extendWorkload($config, function($config, $super) {
$config.threadCount = dbNames.length * collNames.length;
$config.iterations = 64;
// Number of documents per partition. (One chunk per partition and one partition per thread).
$config.data.partitionSize = 100;
$config.states.moveChunk = function moveChunk(db, collName, connCache) {
const dbName = dbNames[Random.randInt(dbNames.length)];
db = db.getSiblingDB(dbName);
collName = collNames[Random.randInt(collNames.length)];
$super.states.moveChunk.apply(this, [db, collName, connCache]);
};
$config.states.init = function init(db, collName, connCache) {
for (var i = 0; i < dbNames.length; i++) {
const dbName = dbNames[i];
db = db.getSiblingDB(dbName);
for (var j = 0; j < collNames.length; j++) {
collName = collNames[j];
if (TestData.runningWithShardStepdowns) {
fsm.forceRunningOutsideTransaction(this);
runWithManualRetriesIfInStepdownSuite(() => {
$super.states.init.apply(this, [db, collName, connCache]);
});
} else {
$super.states.init.apply(this, [db, collName, connCache]);
}
}
}
};
$config.transitions = {
init: {moveChunk: 1.0},
moveChunk: {moveChunk: 1.0},
};
$config.setup = function setup(db, collName, cluster) {
const shards = Object.keys(cluster.getSerializedCluster().shards);
const numShards = shards.length;
// Initialize `dbNames.length` databases
for (var i = 0; i < dbNames.length; i++) {
const dbName = dbNames[i];
db = db.getSiblingDB(dbName);
db.adminCommand({enablesharding: dbName, primaryShard: shards[i % numShards]});
// Initialize `collNames.length` sharded collections per db
for (var j = 0; j < collNames.length; j++) {
collName = collNames[j];
const ns = dbName + '.' + collName;
assertAlways.commandWorked(
db.adminCommand({shardCollection: ns, key: this.shardKey}));
$super.setup.apply(this, [db, collName, cluster]);
}
}
};
return $config;
});
|
