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
|
// Test that ongoing operations in a transaction are interrupted when the transaction expires.
// @tags: [uses_transactions]
(function() {
"use strict";
load('jstests/libs/parallelTester.js');
load("jstests/libs/check_log.js");
const dbName = "test";
const collName = "kill_op_on_txn_expiry";
const testDB = db.getSiblingDB(dbName);
const testColl = testDB[collName];
testDB.runCommand({drop: collName, writeConcern: {w: "majority"}});
assert.commandWorked(testDB.createCollection(testColl.getName(), {writeConcern: {w: "majority"}}));
const sessionOptions = {
causalConsistency: false
};
const session = db.getMongo().startSession(sessionOptions);
const sessionDb = session.getDatabase(dbName);
const sessionColl = sessionDb[collName];
// Need the original 'transactionLifetimeLimitSeconds' value so that we can reset it back at the
// end of the test.
const res =
assert.commandWorked(db.adminCommand({getParameter: 1, transactionLifetimeLimitSeconds: 1}));
const originalTransactionLifetimeLimitSeconds = res.transactionLifetimeLimitSeconds;
// Decrease transactionLifetimeLimitSeconds so it expires faster
jsTest.log("Decrease transactionLifetimeLimitSeconds from " +
originalTransactionLifetimeLimitSeconds + " to 30 seconds.");
assert.commandWorked(db.adminCommand({setParameter: 1, transactionLifetimeLimitSeconds: 30}));
try {
jsTestLog("Starting transaction");
let txnNumber = 0;
assert.commandWorked(testColl.runCommand({
insert: collName,
documents: [{_id: 0}],
txnNumber: NumberLong(txnNumber),
startTransaction: true,
autocommit: false,
lsid: session.getSessionId(),
}));
jsTestLog("Enabling fail point to block batch inserts");
assert.commandWorked(
testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "alwaysOn"}));
// Clear ramlog so checkLog can't find log messages from previous times this fail point was
// enabled.
assert.commandWorked(testDB.adminCommand({clearLog: 'global'}));
jsTestLog("Starting insert operation in parallel thread");
let workerThread = new ScopedThread((sessionId, txnNumber, dbName, collName) => {
// Deserialize the session ID from its string representation.
sessionId = eval("(" + sessionId + ")");
let coll = db.getSiblingDB(dbName).getCollection(collName);
assert.commandFailedWithCode(coll.runCommand({
insert: collName,
documents: [{_id: 1}],
txnNumber: NumberLong(txnNumber),
autocommit: false,
lsid: sessionId
}),
ErrorCodes.ExceededTimeLimit);
}, tojson(session.getSessionId()), txnNumber, dbName, collName);
workerThread.start();
jsTestLog("Wait for insert to be blocked");
checkLog.contains(db.getMongo(), "hangDuringBatchInsert fail point enabled");
jsTestLog("Wait for the transaction to expire");
checkLog.contains(db.getMongo(), "Aborting transaction with txnNumber " + txnNumber);
jsTestLog("Disabling fail point to enable insert to proceed and detect that the session " +
"has been killed");
assert.commandWorked(
testDB.adminCommand({configureFailPoint: "hangDuringBatchInsert", mode: "off"}));
workerThread.join();
assert(!workerThread.hasFailed());
} finally {
// Must ensure that the transactionLifetimeLimitSeconds is reset so that it does not impact
// other tests in the suite.
assert.commandWorked(db.adminCommand({
setParameter: 1,
transactionLifetimeLimitSeconds: originalTransactionLifetimeLimitSeconds
}));
}
session.endSession();
}());
|
