results.cluster_exitCode = worker.process.exitCode;
results.cluster_signalCode = worker.process.signalCode;
results.cluster_emitExit += 1;
- assert.ok(results.cluster_emitDisconnect,
- "cluster: 'exit' event before 'disconnect' event");
});
// Check worker events and properties
results.worker_emitDisconnect += 1;
results.worker_suicideMode = worker.suicide;
results.worker_state = worker.state;
+ if (results.worker_emitExit > 0) {
+ process.nextTick(function() { finish_test(); });
+ }
});
// Check that the worker died
results.worker_signalCode = signalCode;
results.worker_emitExit += 1;
results.worker_died = !alive(worker.process.pid);
- assert.ok(results.worker_emitDisconnect,
- "worker: 'exit' event before 'disconnect' event");
-
- process.nextTick(function() { finish_test(); });
+ if (results.worker_emitDisconnect > 0) {
+ process.nextTick(function() { finish_test(); });
+ }
});
var finish_test = function() {