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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
/*
* Tests basic support for internal sessions.
*
* @tags: [requires_fcv_51, featureFlagInternalTransactions]
*/
(function() {
'use strict';
TestData.disableImplicitSessions = true;
const st = new ShardingTest({
shards: 1,
mongosOptions: {setParameter: {maxSessions: 1}},
shardOptions: {setParameter: {maxSessions: 1}}
});
const shard0Primary = st.rs0.getPrimary();
const kDbName = "testDb";
const kCollName = "testColl";
const testDB = st.s.getDB(kDbName);
const kConfigTxnNs = "config.transactions";
const kConfigSessionNs = "config.system.sessions";
(() => {
// Verify that internal sessions are only supported in transactions.
const sessionUUID = UUID();
jsTest.log("Test running an internal session with lsid containing txnNumber and " +
"txnUUID outside transaction");
const lsid1 = {id: sessionUUID, txnNumber: NumberLong(35), txnUUID: UUID()};
assert.commandFailedWithCode(testDB.runCommand({
insert: kCollName,
documents: [{x: 1}],
lsid: lsid1,
}),
ErrorCodes.InvalidOptions);
assert.commandFailedWithCode(testDB.runCommand({
insert: kCollName,
documents: [{x: 1}],
lsid: lsid1,
txnNumber: NumberLong(0),
}),
ErrorCodes.InvalidOptions);
jsTest.log(
"Test running an internal session with with lsid containing txnUUID outside transaction");
const lsid2 = {id: sessionUUID, txnUUID: UUID()};
assert.commandFailedWithCode(testDB.runCommand({
insert: kCollName,
documents: [{x: 2}],
lsid: lsid1,
}),
ErrorCodes.InvalidOptions);
assert.commandFailedWithCode(testDB.runCommand({
insert: kCollName,
documents: [{x: 2}],
lsid: lsid2,
txnNumber: NumberLong(35),
}),
ErrorCodes.InvalidOptions);
assert.eq(0, shard0Primary.getCollection(kConfigTxnNs).count({"_id.id": sessionUUID}));
assert.commandWorked(shard0Primary.adminCommand({refreshLogicalSessionCacheNow: 1}));
assert.eq(0, shard0Primary.getCollection(kConfigSessionNs).count({"_id.id": sessionUUID}));
})();
(() => {
jsTest.log(
"Test that the only supported child lsid formats are txnNumber+txnUUID, and txnUUID");
const sessionUUID = UUID();
assert.commandFailedWithCode(testDB.runCommand({
insert: kCollName,
documents: [{x: 1}],
lsid: {id: sessionUUID, txnNumber: NumberLong(35)},
txnNumber: NumberLong(0),
startTransaction: true,
autocommit: false
}),
ErrorCodes.InvalidOptions);
assert.eq(0, shard0Primary.getCollection(kConfigTxnNs).count({"_id.id": sessionUUID}));
assert.commandWorked(shard0Primary.adminCommand({refreshLogicalSessionCacheNow: 1}));
assert.eq(0, shard0Primary.getCollection(kConfigSessionNs).count({"_id.id": sessionUUID}));
})();
(() => {
// Verify that parent and child sessions are tracked using different config.transactions
// documents but are tracked as one logical session (i.e. using the same config.system.sessions
// document).
const sessionUUID = UUID();
const parentLsid = {id: sessionUUID};
assert.commandWorked(testDB.runCommand(
{insert: kCollName, documents: [{x: 0}], lsid: parentLsid, txnNumber: NumberLong(0)}));
const parentSessionDoc =
shard0Primary.getCollection(kConfigTxnNs).findOne({"_id.id": sessionUUID});
assert.neq(parentSessionDoc, null);
assert(!parentSessionDoc.hasOwnProperty("parentLsid"));
const minLastUse = new Date();
sleep(1000);
// Starting an unrelated session should fail since the cache size is 1.
assert.commandFailedWithCode(
testDB.runCommand(
{insert: kCollName, documents: [{x: 0}], lsid: {id: UUID()}, txnNumber: NumberLong(0)}),
ErrorCodes.TooManyLogicalSessions);
// Starting child sessions should succeed since parent and child sessions are tracked as one
// logical session.
jsTest.log("Test running an internal transaction with lsid containing txnNumber and txnUUID");
const childLsid1 = {id: sessionUUID, txnNumber: NumberLong(35), txnUUID: UUID()};
const txnNumber1 = NumberLong(0);
assert.commandWorked(testDB.runCommand({
insert: kCollName,
documents: [{x: 1}],
lsid: childLsid1,
txnNumber: txnNumber1,
startTransaction: true,
autocommit: false
}));
assert.commandWorked(testDB.adminCommand(
{commitTransaction: 1, lsid: childLsid1, txnNumber: txnNumber1, autocommit: false}));
const childSessionDoc1 = shard0Primary.getCollection(kConfigTxnNs).findOne({
"_id.id": sessionUUID,
"_id.txnNumber": childLsid1.txnNumber,
"_id.txnUUID": childLsid1.txnUUID
});
assert.neq(childSessionDoc1, null);
assert.eq(childSessionDoc1.parentLsid,
{id: childSessionDoc1._id.id, uid: childSessionDoc1._id.uid});
jsTest.log("Test running an internal transaction with lsid containing txnUUID");
const childLsid2 = {id: sessionUUID, txnUUID: UUID()};
const txnNumber2 = NumberLong(35);
assert.commandWorked(testDB.runCommand({
insert: kCollName,
documents: [{x: 2}],
lsid: childLsid2,
txnNumber: txnNumber2,
startTransaction: true,
autocommit: false
}));
assert.commandWorked(testDB.adminCommand(
{commitTransaction: 1, lsid: childLsid2, txnNumber: txnNumber2, autocommit: false}));
const childSessionDoc2 = shard0Primary.getCollection(kConfigTxnNs).findOne({
"_id.id": sessionUUID,
"_id.txnUUID": childLsid2.txnUUID
});
assert.neq(childSessionDoc2, null);
assert(!childSessionDoc2.hasOwnProperty("parentLsid"));
assert.eq(3, shard0Primary.getCollection(kConfigTxnNs).count({"_id.id": sessionUUID}));
assert.commandWorked(shard0Primary.adminCommand({refreshLogicalSessionCacheNow: 1}));
const sessionDocs =
shard0Primary.getCollection(kConfigSessionNs).find({"_id.id": sessionUUID}).toArray();
assert.eq(sessionDocs.length, 1);
assert(!sessionDocs[0]._id.hasOwnProperty("txnTxnNumber"), tojson(sessionDocs[0]));
assert(!sessionDocs[0]._id.hasOwnProperty("txnUUID"), tojson(sessionDocs[0]));
assert.gte(sessionDocs[0].lastUse, minLastUse, tojson(sessionDocs[0]));
})();
st.stop();
})();
|
