22 lines
743 B
JavaScript
22 lines
743 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);
|