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
|
'use strict';
/**
* Performs these actions in parallel:
* 1. Refine a collection's shard key.
* 2. Perform deletes in transactions without the shard key.
* 3. Move random chunks.
* 4. Flushes the router's cached metadata for all sharded collections.
*
* @tags: [
* assumes_balancer_off,
* # The init() state function populates each document owned by a particular thread with a
* # "groupId" value. Doing so may take longer than the configured stepdown interval. It is
* # therefore unsafe to automatically run inside a multi-statement transaction because its
* # progress will continually be interrupted.
* operations_longer_than_stepdown_interval_in_txns,
* requires_non_retryable_writes,
* requires_sharding,
* uses_transactions,
* ]
*/
load('jstests/concurrency/fsm_libs/extend_workload.js');
load('jstests/concurrency/fsm_workloads/random_moveChunk_refine_collection_shard_key.js');
load('jstests/concurrency/fsm_workload_helpers/delete_in_transaction_states.js');
var $config = extendWorkload($config, function($config, $super) {
$config.iterations = 10;
$config.states.exactIdDelete = function(db, collName, connCache) {
exactIdDelete(db, this.getCurrentOrPreviousLatchCollName(collName), this.session);
};
$config.states.multiDelete = function(db, collName, connCache) {
multiDelete(db, this.getCurrentOrPreviousLatchCollName(collName), this.session, this.tid);
};
$config.states.verifyDocuments = function(db, collName, connCache) {
verifyDocuments(db, this.getCurrentOrPreviousLatchCollName(collName), this.tid);
};
/**
* 1. Set up the base workloads.
* 2. Start a session.
* 3. Initialize the state necessary for each latch collection to update documents inside
* transactions.
*/
$config.states.init = function init(db, collName, connCache) {
$super.states.init.apply(this, arguments);
this.session = db.getMongo().startSession({causalConsistency: false});
for (let i = this.latchCount; i >= 0; --i) {
const latchCollName = collName + '_' + i;
initDeleteInTransactionStates(db, latchCollName, this.tid);
}
};
$config.transitions = {
init: {
moveChunk: 0.2,
refineCollectionShardKey: 0.2,
exactIdDelete: 0.25,
multiDelete: 0.25,
flushRouterConfig: 0.1
},
moveChunk: {
moveChunk: 0.18,
refineCollectionShardKey: 0.18,
exactIdDelete: 0.18,
multiDelete: 0.18,
verifyDocuments: 0.18,
flushRouterConfig: 0.1
},
refineCollectionShardKey: {
moveChunk: 0.2,
refineCollectionShardKey: 0.1,
exactIdDelete: 0.2,
multiDelete: 0.2,
verifyDocuments: 0.2,
flushRouterConfig: 0.1
},
exactIdDelete: {
moveChunk: 0.18,
refineCollectionShardKey: 0.18,
exactIdDelete: 0.18,
multiDelete: 0.18,
verifyDocuments: 0.18,
flushRouterConfig: 0.1
},
multiDelete: {
moveChunk: 0.18,
refineCollectionShardKey: 0.18,
exactIdDelete: 0.18,
multiDelete: 0.18,
verifyDocuments: 0.18,
flushRouterConfig: 0.1
},
verifyDocuments: {
moveChunk: 0.2,
refineCollectionShardKey: 0.2,
exactIdDelete: 0.2,
multiDelete: 0.2,
flushRouterConfig: 0.1
},
flushRouterConfig: {
moveChunk: 0.2,
refineCollectionShardKey: 0.2,
exactIdDelete: 0.2,
multiDelete: 0.2,
verifyDocuments: 0.2
},
};
return $config;
});
|
