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
|
'use strict';
/**
* Concurrently performs DDL commands and verifies guarantees are not broken.
*
* @tags: [
* requires_sharding,
* # TODO (SERVER-56879): Support add/remove shards in new DDL paths
* does_not_support_add_remove_shards,
* featureFlagShardingFullDDLSupport,
* ]
*/
const dbPrefix = 'fsmDB_';
const dbCount = 2;
const collPrefix = 'sharded_coll_';
const collCount = 2;
function getRandomDb(db) {
return db.getSiblingDB(dbPrefix + Random.randInt(dbCount));
}
function getRandomCollection(db) {
return db[collPrefix + Random.randInt(collCount)];
}
var $config = (function() {
let states = {
create: function(db, collName, connCache) {
db = getRandomDb(db);
const coll = getRandomCollection(db);
const fullNs = coll.getFullName();
jsTestLog('Executing create state: ' + fullNs);
assertAlways.commandWorked(
db.adminCommand({shardCollection: fullNs, key: {_id: 1}, unique: false}));
},
drop: function(db, collName, connCache) {
db = getRandomDb(db);
const coll = getRandomCollection(db);
jsTestLog('Executing drop state: ' + coll.getFullName());
assertAlways.eq(coll.drop(), true);
},
rename: function(db, collName, connCache) {
db = getRandomDb(db);
const srcColl = getRandomCollection(db);
const srcCollName = srcColl.getFullName();
// Rename collection
const destCollNS = getRandomCollection(db).getFullName();
const destCollName = destCollNS.split('.')[1];
jsTestLog('Executing rename state:' + srcCollName + ' to ' + destCollNS);
assertAlways.commandWorkedOrFailedWithCode(
srcColl.renameCollection(destCollName, true /* dropTarget */), [
ErrorCodes.NamespaceNotFound,
ErrorCodes.ConflictingOperationInProgress,
ErrorCodes.IllegalOperation
]);
}
};
let setup = function(db, collName, connCache) {
for (var i = 0; i < dbCount; i++) {
const dbName = dbPrefix + i;
const newDb = db.getSiblingDB(dbName);
newDb.adminCommand({enablesharding: dbName});
}
};
let teardown = function(db, collName, cluster) {};
let transitions = {
create: {create: 0.33, drop: 0.33, rename: 0.34},
drop: {create: 0.34, drop: 0.33, rename: 0.33},
rename: {create: 0.33, drop: 0.34, rename: 0.33}
};
return {
threadCount: 12,
iterations: 64,
startState: 'create',
states: states,
transitions: transitions,
data: {},
setup: setup,
teardown: teardown,
passConnectionCache: true
};
})();
|
