mirror of https://github.com/mongodb/mongo
24 lines
769 B
JavaScript
24 lines
769 B
JavaScript
import {workerThread} from "jstests/concurrency/fsm_libs/worker_thread.js";
|
|
|
|
async function shouldForwardErrorsFromAsyncRunCallback(conn) {
|
|
const args = {
|
|
host: conn.host,
|
|
dbName: 'test',
|
|
tid: 'thread0',
|
|
clusterOptions: {sharded: false, replication: false},
|
|
latch: new CountDownLatch(1),
|
|
errorLatch: new CountDownLatch(1)
|
|
};
|
|
|
|
const res = await workerThread.main([], args, async function() {
|
|
throw new Error('Thrown intentionally');
|
|
});
|
|
assert.eq(res.err,
|
|
'Error: Thrown intentionally',
|
|
'should forward errors thrown in async run callback');
|
|
}
|
|
|
|
const conn = MongoRunner.runMongod();
|
|
await shouldForwardErrorsFromAsyncRunCallback(conn);
|
|
MongoRunner.stopMongod(conn);
|