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
|
'use strict';
load('jstests/concurrency/fsm_libs/extend_workload.js'); // for extendWorkload
load('jstests/concurrency/fsm_workloads/secondary_reads.js'); // for $config
/**
* secondary_reads_with_catalog_changes.js
*
* One thread (tid 0) is dedicated to writing documents with field 'x' in ascending order into the
* collection. This thread is also responsible for ensuring the required index on 'x' exists.
*
* Other threads do one of the following operations each iteration.
* 1) Retrieve first 50 documents in descending order with local readConcern from a secondary node.
* 2) Retrieve first 50 documents in descending order with available readConcern from a secondary
* node.
* 3) Retrieve first 50 documents in descending order with majority readConcern from a secondary
* node.
* 4) Drop the index on 'x'.
* 5) Drop the collection.
*
* Note that index/collection drop could interrupt the reads, so we need to retry if the read is
* interrupted.
*
* @tags: [
* creates_background_indexes,
* requires_replication,
* uses_write_concern,
* incompatible_with_lockfreereads,
* ]
*/
var $config = extendWorkload($config, function($config, $super) {
$config.data.buildIndex = function buildIndex(db, spec) {
// Index must be built eventually.
assertWhenOwnColl.soon(() => {
const res = db[this.collName].createIndex(spec);
if (res.ok === 1) {
assertWhenOwnColl.commandWorked(res);
return true;
}
if (TestData.runInsideTransaction) {
assertWhenOwnColl.commandFailedWithCode(res, [
ErrorCodes.IndexBuildAborted,
ErrorCodes.IndexBuildAlreadyInProgress,
ErrorCodes.NoMatchingDocument,
]);
} else {
assertWhenOwnColl.commandFailedWithCode(res, [
ErrorCodes.IndexBuildAborted,
ErrorCodes.NoMatchingDocument,
]);
}
return false;
});
};
$config.data.assertSecondaryReadOk = function(res) {
assertAlways.commandFailedWithCode(
res,
[
// The query was interrupted due to an index or collection drop
ErrorCodes.QueryPlanKilled,
// The required, hinted index does not exist
ErrorCodes.BadValue
],
'unexpected error code: ' + res.code + ': ' + res.message);
};
$config.states.dropIndex = function dropIndex(db, collName) {
if (this.isWriterThread(this.tid)) {
this.insertDocumentsAndBuildIndex(db);
} else {
const res = db[this.collName].dropIndex({x: 1});
if (res.ok === 1) {
assertWhenOwnColl.commandWorked(res);
} else {
assertWhenOwnColl.commandFailedWithCode(res, [
ErrorCodes.IndexNotFound,
ErrorCodes.NamespaceNotFound,
ErrorCodes.BackgroundOperationInProgressForNamespace
]);
}
}
};
$config.states.dropCollection = function dropCollection(db, collName) {
if (this.isWriterThread(this.tid)) {
this.insertDocumentsAndBuildIndex(db);
} else {
const res = db.runCommand({drop: this.collName});
if (res.ok === 1) {
assertWhenOwnColl.commandWorked(res);
} else {
assertWhenOwnColl.commandFailedWithCode(res, [
ErrorCodes.NamespaceNotFound,
ErrorCodes.BackgroundOperationInProgressForNamespace
]);
}
this.nDocumentsInTotal = 0;
}
};
$config.transitions = {
readFromSecondaries: {readFromSecondaries: 0.9, dropIndex: 0.05, dropCollection: 0.05},
dropIndex: {readFromSecondaries: 1},
dropCollection: {readFromSecondaries: 1}
};
return $config;
});
|
