python buildscripts/resmoke.py --suites=no_server already_checked_out_session.js already_checked_out_session.js ( 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(); })();