(function() {
|
"use strict";
|
|
load("jstests/libs/parallelTester.js");
|
|
const rst = new ReplSetTest({nodes: 1});
|
rst.startSet();
|
rst.initiate();
|
|
const primary = rst.getPrimary();
|
const db = primary.getDB("test");
|
|
function doInsertWithSession(host, lsid, txnNumber) {
|
try {
|
const conn = new Mongo(host);
|
const db = conn.getDB("test");
|
assert.commandWorked(db.runCommand({
|
insert: "mycoll",
|
documents: [{_id: txnNumber}],
|
lsid: {id: eval(lsid)},
|
txnNumber: NumberLong(txnNumber),
|
}));
|
return {ok: 1};
|
} catch (e) {
|
return {ok: 0, error: e.toString(), stack: e.stack};
|
}
|
}
|
|
let thread1;
|
let thread2;
|
|
assert.commandWorked(db.fsyncLock());
|
try {
|
// JavaScript objects backed by C++ objects (e.g. BSON values) do not serialize correctly
|
// when passed through the ScopedThread constructor. To work around this behavior, we
|
// instead pass a stringified form of the JavaScript object through the ScopedThread
|
// constructor and use eval() to rehydrate it.
|
const lsid = UUID();
|
thread1 = new ScopedThread(doInsertWithSession, primary.host, tojson(lsid), 0);
|
thread1.start();
|
|
assert.soon(
|
() => {
|
const ops = db.currentOp({"command.insert": "mycoll", waitingForLock: true});
|
return ops.inprog.length === 1;
|
},
|
() => {
|
return "insert operation was never found to be waiting for a lock: " +
|
tojson(db.currentOp());
|
});
|
|
thread2 = new ScopedThread(doInsertWithSession, primary.host, tojson(lsid), 1);
|
thread2.start();
|
|
// XXX: Wait a little bit for thread2 to have sent its insert command to the server or we
|
// otherwise won't trigger the bug.
|
sleep(5000);
|
} finally {
|
// We run the fsyncUnlock command in a finally block to avoid leaving the server fsyncLock'd
|
// if the test were to fail.
|
assert.commandWorked(db.fsyncUnlock());
|
}
|
|
thread1.join();
|
thread2.join();
|
|
assert.commandWorked(thread1.returnData());
|
assert.commandWorked(thread2.returnData());
|
|
rst.stopSet();
|
})();
|