Revert advanced IPC

* Revert "Don't use global setImmediate"

This reverts commit ea66e64.

* Revert "Use advanced serialization (when available) for worker communication"

This reverts commit 0f879f4.

Author: novemberborn

lib/cli.js

@@ -430,7 +430,7 @@ exports.run = async () => { // eslint-disable-line complexity
 		reporter.startRun(plan);
 
 		if (process.env.AVA_EMIT_RUN_STATUS_OVER_IPC === 'I\'ll find a payphone baby / Take some time to talk to you') {
-			if (process.versions.node >= '12.17.0') {
+			if (process.versions.node >= '12.16.0') {
 				plan.status.on('stateChange', evt => {
 					process.send(evt);
 				});

lib/fork.js

@@ -3,7 +3,6 @@ const childProcess = require('child_process');
 const path = require('path');
 const fs = require('fs');
 const Emittery = require('emittery');
-const {controlFlow} = require('./ipc-flow-control');
 
 if (fs.realpathSync(__filename) !== __filename) {
 	console.warn('WARNING: `npm link ava` and the `--preserve-symlink` flag are incompatible. We have detected that AVA is linked via `npm link`, and that you are using either an early version of Node 6, or the `--preserve-symlink` flag. This breaks AVA. You should upgrade to Node 6.2.0+, avoid the `--preserve-symlink` flag, or avoid using `npm link ava`.');
@@ -15,12 +14,6 @@ const AVA_PATH = path.resolve(__dirname, '..');
 
 const workerPath = require.resolve('./worker/subprocess');
 
-const useAdvanced = process.versions.node >= '12.17.0';
-// FIXME: Fix this in api.js or cli.js.
-const serializeOptions = useAdvanced ?
-	options => JSON.parse(JSON.stringify(options)) : // Use JSON serialization to remove non-clonable values.
-	options => options;
-
 module.exports = (file, options, execArgv = process.execArgv) => {
 	let finished = false;
 
@@ -41,8 +34,7 @@ module.exports = (file, options, execArgv = process.execArgv) => {
 		cwd: options.projectDir,
 		silent: true,
 		env: {NODE_ENV: 'test', ...process.env, ...options.environmentVariables, AVA_PATH},
-		execArgv,
-		serialization: useAdvanced ? 'advanced' : 'json'
+		execArgv
 	});
 
 	subprocess.stdout.on('data', chunk => {
@@ -53,12 +45,12 @@ module.exports = (file, options, execArgv = process.execArgv) => {
 		emitStateChange({type: 'worker-stderr', chunk});
 	});
 
-	const bufferedSend = controlFlow(subprocess);
-
 	let forcedExit = false;
 	const send = evt => {
-		if (!finished && !forcedExit) {
-			bufferedSend({ava: evt});
+		if (subprocess.connected && !finished && !forcedExit) {
+			subprocess.send({ava: evt}, () => {
+				// Disregard errors.
+			});
 		}
 	};
 
@@ -74,7 +66,7 @@ module.exports = (file, options, execArgv = process.execArgv) => {
 			}
 
 			if (message.ava.type === 'ready-for-options') {
-				send({type: 'options', options: serializeOptions(options)});
+				send({type: 'options', options});
 				return;
 			}
 

lib/ipc-flow-control.js

@@ -1,6 +1,5 @@
 'use strict';
 const Emittery = require('emittery');
-const {controlFlow} = require('../ipc-flow-control');
 
 const emitter = new Emittery();
 process.on('message', message => {
@@ -26,9 +25,10 @@ process.on('message', message => {
 exports.options = emitter.once('options');
 exports.peerFailed = emitter.once('peerFailed');
 
-const bufferedSend = controlFlow(process);
 function send(evt) {
-	bufferedSend({ava: evt});
+	if (process.connected) {
+		process.send({ava: evt});
+	}
 }
 
 exports.send = send;

lib/worker/ipc.js

@@ -1,7 +1,7 @@
 const test = require('../../../..');
 
 test('passes', t => {
-	setImmediate(() => {
+	setTimeout(() => {
 		throw new Error('Can’t catch me');
 	});
 	t.pass();

test-tap/fixture/report/regular/uncaught-exception.js

@@ -515,13 +515,13 @@
 
   uncaught-exception.js:5
 
-   4:   setImmediate(() => {                
+   4:   setTimeout(() => {                  
    5:     throw new Error('Can’t catch me');
    6:   });                                 
 
   Error: Can’t catch me
 
-  › Immediate.setImmediate (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
+  › Timeout.setTimeout (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
 
 
 

test-tap/reporters/mini.regular.v10.log

@@ -497,14 +497,15 @@
 
   uncaught-exception.js:5
 
-   4:   setImmediate(() => {                
+   4:   setTimeout(() => {                  
    5:     throw new Error('Can’t catch me');
    6:   });                                 
 
   Error: Can’t catch me
 
-  › Immediate.<anonymous> (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
-  › processImmediate (internal/timers.js:456:21)
+  › Timeout._onTimeout (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
+  › listOnTimeout (internal/timers.js:549:17)
+  › processTimers (internal/timers.js:492:7)
 
 
 

test-tap/reporters/mini.regular.v12.log

@@ -497,14 +497,15 @@
 
   uncaught-exception.js:5
 
-   4:   setImmediate(() => {                
+   4:   setTimeout(() => {                  
    5:     throw new Error('Can’t catch me');
    6:   });                                 
 
   Error: Can’t catch me
 
-  › Immediate.<anonymous> (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
-  › processImmediate (internal/timers.js:458:21)
+  › Timeout._onTimeout (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
+  › listOnTimeout (internal/timers.js:551:17)
+  › processTimers (internal/timers.js:494:7)
 
 
 

test-tap/reporters/mini.regular.v14.log

@@ -323,9 +323,7 @@ not ok 25 - Error: Can’t catch me
   ---
     name: Error
     message: Can’t catch me
-    at: >-
-      Immediate.setImmediate
-      (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
+    at: 'Timeout.setTimeout (test-tap/fixture/report/regular/uncaught-exception.js:5:9)'
   ...
 ---tty-stream-chunk-separator
 # uncaught-exception.js exited with a non-zero exit code: 1

test-tap/reporters/tap.regular.v10.log

@@ -296,11 +296,10 @@ not ok 25 - Error: Can’t catch me
   ---
     name: Error
     message: Can’t catch me
-    at: >-
-      Immediate.<anonymous>
-      (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
-
-      processImmediate (internal/timers.js:456:21)
+    at: |-
+      Timeout._onTimeout (test-tap/fixture/report/regular/uncaught-exception.js:5:9)
+      listOnTimeout (internal/timers.js:549:17)
+      processTimers (internal/timers.js:492:7)
   ...
 ---tty-stream-chunk-separator
 # uncaught-exception.js exited with a non-zero exit code: 1