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
|
// Test TransientTransactionError error label for commands in transactions with write concern.
// @tags: [uses_transactions]
(function() {
"use strict";
load("jstests/libs/check_log.js");
load("jstests/libs/write_concern_util.js");
load("jstests/replsets/rslib.js");
const dbName = "test";
const collName = "transient_txn_error_labels_with_write_concern";
// We are testing coordinateCommitTransaction, which requires the nodes to be started with
// --shardsvr.
const st = new ShardingTest(
{config: 1, mongos: 1, shards: {rs0: {nodes: [{}, {rsConfig: {priority: 0}}]}}});
const rst = st.rs0;
const primary = rst.getPrimary();
const secondary = rst.getSecondary();
assert.eq(primary, rst.nodes[0]);
const testDB = primary.getDB(dbName);
const sessionOptions = {causalConsistency: false};
const writeConcernMajority = {w: "majority", wtimeout: 500};
assert.commandWorked(testDB.createCollection(collName, {writeConcern: {w: "majority"}}));
jsTest.log("Write concern errors should not have error labels");
// Start a new session on the primary.
let session = primary.startSession(sessionOptions);
let sessionDb = session.getDatabase(dbName);
let sessionColl = sessionDb.getCollection(collName);
stopServerReplication(rst.getSecondaries());
session.startTransaction({writeConcern: writeConcernMajority});
assert.commandWorked(sessionColl.insert({_id: "write-with-write-concern"}));
let res = session.commitTransaction_forTesting();
checkWriteConcernTimedOut(res);
assert(!res.hasOwnProperty("code"));
assert(!res.hasOwnProperty("errorLabels"));
restartServerReplication(rst.getSecondaries());
function runNoSuchTransactionTests(cmd, cmdName) {
jsTest.log("Running NoSuchTransaction tests for " + cmdName);
assert.commandWorked(primary.adminCommand({clearLog: "global"}));
jsTest.log(cmdName + " should wait for write concern even if it returns NoSuchTransaction");
rst.awaitReplication();
stopServerReplication(rst.getSecondaries());
// Use a txnNumber that is one higher than the server has tracked.
res = sessionDb.adminCommand(Object.assign(Object.assign({}, cmd), {
txnNumber: NumberLong(session.getTxnNumber_forTesting() + 1),
autocommit: false,
writeConcern: writeConcernMajority
}));
checkWriteConcernTimedOut(res);
assert.commandFailedWithCode(res, ErrorCodes.NoSuchTransaction);
jsTest.log("NoSuchTransaction with write concern error is not transient");
assert(!res.hasOwnProperty("errorLabels"));
jsTest.log("NoSuchTransaction without write concern error is transient");
restartServerReplication(rst.getSecondaries());
// Use a txnNumber that is one higher than the server has tracked.
res = sessionDb.adminCommand(Object.assign(Object.assign({}, cmd), {
txnNumber: NumberLong(session.getTxnNumber_forTesting() + 1),
autocommit: false,
writeConcern: {w: "majority"} // Wait with a long timeout.
}));
assert.commandFailedWithCode(res, ErrorCodes.NoSuchTransaction);
assert(!res.hasOwnProperty("writeConcernError"), res);
assert.eq(res["errorLabels"], ["TransientTransactionError"], res);
jsTest.log(
"If the noop write for NoSuchTransaction cannot occur, the error is not transient");
assert.commandWorked(testDB.getSiblingDB("local").createCollection("todrop"));
assert.commandWorked(testDB.adminCommand(
{configureFailPoint: "hangDuringDropCollection", mode: "alwaysOn"}));
// Create a pending drop on a collection in the local database. This will hold an X lock on
// the local database.
let awaitDrop = startParallelShell(() => assert(db.getSiblingDB("local")["todrop"].drop()),
rst.ports[0]);
checkLog.contains(testDB.getMongo(), "hangDuringDropCollection fail point enabled");
// The server will attempt to perform a noop write, since the command returns
// NoSuchTransaction. The noop write will time out acquiring a lock on the local database.
// This should not be a TransientTransactionError, since the server has not successfully
// replicated a write to confirm that it is primary.
// Use a txnNumber that is one higher than the server has tracked.
res = sessionDb.adminCommand(Object.assign(Object.assign({}, cmd), {
txnNumber: NumberLong(session.getTxnNumber_forTesting() + 1),
autocommit: false,
writeConcern: writeConcernMajority,
maxTimeMS: 1000
}));
assert.commandFailedWithCode(res, ErrorCodes.MaxTimeMSExpired);
assert(!res.hasOwnProperty("errorLabels"));
assert.commandWorked(
testDB.adminCommand({configureFailPoint: "hangDuringDropCollection", mode: "off"}));
awaitDrop();
rst.awaitReplication();
}
runNoSuchTransactionTests({commitTransaction: 1}, "commitTransaction");
runNoSuchTransactionTests({coordinateCommitTransaction: 1, participants: []},
"coordinateCommitTransaction");
session.endSession();
st.stop();
}());
|
