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
|
/**
* Tests that CRUD operations do not throw lock timeouts outside of transactions.
*
* @tags: [
* assumes_against_mongod_not_mongos,
* assumes_read_concern_unchanged,
* assumes_write_concern_unchanged,
* uses_parallel_shell,
* no_selinux,
* ]
*/
(function() {
"use strict";
load("jstests/libs/curop_helpers.js");
load('jstests/libs/parallel_shell_helpers.js');
const coll = db[jsTestName()];
coll.drop();
const doc = {
_id: 1
};
assert.commandWorked(coll.insert(doc));
// Figure out if lock-free reads is supported so we know the expected behavior later.
// Lock-free reads are only supported in server versions 4.9+
const maxWireVersion = assert.commandWorked(db.runCommand({isMaster: 1})).maxWireVersion;
const isLockFreeReadsEnabled = maxWireVersion >= 12 /* WIRE_VERSION_49 */;
const failpoint = 'hangAfterDatabaseLock';
assert.commandWorked(db.adminCommand({configureFailPoint: failpoint, mode: "alwaysOn"}));
jsTestLog("Starting collMod that will block");
const awaitBlockingDDL =
startParallelShell(funWithArgs(function(collName) {
assert.commandWorked(db.runCommand({collMod: collName}));
}, coll.getName()), db.getMongo().port);
jsTestLog("Waiting for collMod to acquire a database lock");
waitForCurOpByFailPointNoNS(db, failpoint);
// Each of the following operations should time out trying to acquire the collection lock, which the
// collMod is holding in mode X.
jsTestLog("Testing CRUD op timeouts");
const failureTimeoutMS = 1 * 1000;
assert.commandFailedWithCode(
db.runCommand({insert: coll.getName(), documents: [{_id: 2}], maxTimeMS: failureTimeoutMS}),
ErrorCodes.MaxTimeMSExpired);
// Reads are not blocked by MODE_X Collection locks with Lock Free Reads.
const findResult = db.runCommand({find: coll.getName(), maxTimeMS: failureTimeoutMS});
if (isLockFreeReadsEnabled)
assert.commandWorked(findResult);
else
assert.commandFailedWithCode(findResult, ErrorCodes.MaxTimeMSExpired);
assert.commandFailedWithCode(db.runCommand({
update: coll.getName(),
updates: [{q: doc, u: {$set: {b: 1}}}],
maxTimeMS: failureTimeoutMS
}),
ErrorCodes.MaxTimeMSExpired);
assert.commandFailedWithCode(
db.runCommand(
{delete: coll.getName(), deletes: [{q: doc, limit: 1}], maxTimeMS: failureTimeoutMS}),
ErrorCodes.MaxTimeMSExpired);
assert.commandFailedWithCode(db.runCommand({
findAndModify: coll.getName(),
query: doc,
update: {$set: {b: 2}},
maxTimeMS: failureTimeoutMS
}),
ErrorCodes.MaxTimeMSExpired);
assert.commandFailedWithCode(
db.runCommand(
{findAndModify: coll.getName(), query: doc, remove: true, maxTimeMS: failureTimeoutMS}),
ErrorCodes.MaxTimeMSExpired);
jsTestLog("Waiting for threads to join");
assert.commandWorked(db.adminCommand({configureFailPoint: failpoint, mode: "off"}));
awaitBlockingDDL();
assert.sameMembers(coll.find().toArray(), [doc]);
})();
|
