Function assertCrossThreadCallbackAbort

test/ffi/test-ffi-calls.js:352–381

()

}

function assertCrossThreadCallbackAbort() {
  const workerSource = `
const { workerData } = require('node:worker_threads');
const ffi = require('node:ffi');
const { fixtureSymbols, libraryPath } = require(${JSON.stringify(require.resolve('./ffi-test-common'))});
const { functions } = ffi.dlopen(libraryPath, fixtureSymbols);
functions.call_int_callback(workerData, 21);
`;
  const { stderr, status, signal } = spawnSync(process.execPath, [
    '--experimental-ffi',
    '-e',
    `'use strict';
const { Worker } = require('node:worker_threads');
const ffi = require('node:ffi');
const { fixtureSymbols, libraryPath } = require(${JSON.stringify(require.resolve('./ffi-test-common'))});
const { lib } = ffi.dlopen(libraryPath, fixtureSymbols);
const callback = lib.registerCallback(
  { arguments: ['i32'], return: 'i32' },
  (value) => value * 2,
);
new Worker(${JSON.stringify(workerSource)}, { eval: true, workerData: callback });`,
  ], {
    encoding: 'utf8',
  });

  assert.ok(common.nodeProcessAborted(status, signal),
            `status: ${status}, signal: ${signal}
stderr: ${stderr}`);
  assert.match(stderr, /Callbacks can only be invoked on the system thread they were created on/);
}

test('ffi aborts on invalid callback return values', () => {
  assertInvalidCallbackReturnAborts('1.5');