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
|
'use strict';
/**
* findAndModify_update_queue.js
*
* A large number of documents are inserted during the workload setup. Each thread repeated updates
* a document from the collection using the findAndModify command, and stores the _id field of that
* document in another database. At the end of the workload, the contents of the other database are
* checked for whether one thread updated the same document as another thread.
*
* This workload was designed to reproduce an issue similar to SERVER-18304 for update operations
* using the findAndModify command where the old version of the document is returned.
*/
load('jstests/concurrency/fsm_libs/extend_workload.js'); // for extendWorkload
load('jstests/concurrency/fsm_workloads/findAndModify_remove_queue.js'); // for $config
// For isMongod.
load('jstests/concurrency/fsm_workload_helpers/server_types.js');
var $config = extendWorkload($config, function($config, $super) {
// Use the workload name as the database name, since the workload name is assumed to be
// unique.
$config.data.uniqueDBName = 'findAndModify_update_queue';
$config.data.newDocForInsert = function newDocForInsert(i) {
return {_id: i, rand: Random.rand(), counter: 0};
};
$config.data.getIndexSpecs = function getIndexSpecs() {
return [{counter: 1, rand: -1}];
};
$config.data.opName = 'updated';
var states = (function() {
function update(db, collName) {
// Update the counter field to avoid matching the same document again.
var res = db.runCommand({
findAndModify: db[collName].getName(),
query: {counter: 0},
sort: {rand: -1},
update: {$inc: {counter: 1}},
new: false
});
assertAlways.commandWorked(res);
var doc = res.value;
if (isMongod(db)) {
// Storage engines should automatically retry the operation, and thus should never
// return null.
assertWhenOwnColl.neq(
doc, null, 'findAndModify should have found and updated a matching document');
}
if (doc !== null) {
this.saveDocId(db, collName, doc._id);
}
}
return {update: update};
})();
var transitions = {update: {update: 1}};
$config.startState = 'update';
$config.states = states;
$config.transitions = transitions;
return $config;
});
|
