Skip to content

Commit

Permalink
fix: report launcher process error when exit event is not emitted (ka…
Browse files Browse the repository at this point in the history
…rma-runner#3647)

Co-authored-by: Chris Bottin <cbottin@smartcommunications.com>
  • Loading branch information
chrisbottin and chrisbottin authored Feb 3, 2021
1 parent 3cb26e3 commit 7ab86be
Show file tree
Hide file tree
Showing 2 changed files with 51 additions and 18 deletions.
5 changes: 5 additions & 0 deletions lib/launchers/process.js
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,7 @@ function ProcessLauncher (spawn, tempDir, timer, processKillTimeout) {
} else {
errorOutput += err.toString()
}
self._onProcessExit(-1, null, errorOutput)
})

self._process.stderr.on('data', function (errBuff) {
Expand All @@ -101,6 +102,10 @@ function ProcessLauncher (spawn, tempDir, timer, processKillTimeout) {
}

this._onProcessExit = function (code, signal, errorOutput) {
if (!self._process) {
// Both exit and error events trigger _onProcessExit(), but we only need one cleanup.
return
}
log.debug(`Process ${self.name} exited with code ${code} and signal ${signal}`)

let error = null
Expand Down
64 changes: 46 additions & 18 deletions test/unit/launchers/process.spec.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,18 +7,25 @@ const CaptureTimeoutLauncher = require('../../../lib/launchers/capture_timeout')
const ProcessLauncher = require('../../../lib/launchers/process')
const EventEmitter = require('../../../lib/events').EventEmitter
const createMockTimer = require('../mocks/timer')
const logger = require('../../../lib/logger')

describe('launchers/process.js', () => {
let emitter
let mockSpawn
let mockTempDir
let launcher
let logErrorSpy
let logDebugSpy

const BROWSER_PATH = path.normalize('/usr/bin/browser')

beforeEach(() => {
emitter = new EventEmitter()
launcher = new BaseLauncher('fake-id', emitter)
launcher.name = 'fake-name'
launcher.ENV_CMD = 'fake-ENV-CMD'
logErrorSpy = sinon.spy(logger.create('launcher'), 'error')
logDebugSpy = sinon.spy(logger.create('launcher'), 'debug')

mockSpawn = sinon.spy(function (cmd, args) {
const process = new EventEmitter()
Expand Down Expand Up @@ -74,7 +81,7 @@ describe('launchers/process.js', () => {
})

describe('with RetryLauncher', () => {
it('should handle spawn ENOENT error and not even retry', (done) => {
function assertSpawnError ({ errorCode, emitExit, expectedError }, done) {
ProcessLauncher.call(launcher, mockSpawn, mockTempDir)
RetryLauncher.call(launcher, 2)
launcher._getCommand = () => BROWSER_PATH
Expand All @@ -83,35 +90,56 @@ describe('launchers/process.js', () => {
emitter.on('browser_process_failure', failureSpy)

launcher.start('http://host:9876/')
mockSpawn._processes[0].emit('error', { code: 'ENOENT' })
mockSpawn._processes[0].emit('exit', 1)
mockSpawn._processes[0].emit('error', { code: errorCode })
if (emitExit) {
mockSpawn._processes[0].emit('exit', 1)
}
mockTempDir.remove.callArg(1)

_.defer(() => {
expect(launcher.state).to.equal(launcher.STATE_FINISHED)
expect(failureSpy).to.have.been.called
expect(logDebugSpy).to.have.been.callCount(5)
expect(logDebugSpy.getCall(0)).to.have.been.calledWithExactly('null -> BEING_CAPTURED')
expect(logDebugSpy.getCall(1)).to.have.been.calledWithExactly(`${BROWSER_PATH} http://host:9876/?id=fake-id`)
expect(logDebugSpy.getCall(2)).to.have.been.calledWithExactly('Process fake-name exited with code -1 and signal null')
expect(logDebugSpy.getCall(3)).to.have.been.calledWithExactly('fake-name failed (cannot start). Not restarting.')
expect(logDebugSpy.getCall(4)).to.have.been.calledWithExactly('BEING_CAPTURED -> FINISHED')
expect(logErrorSpy).to.have.been.calledWith(expectedError)
done()
})
}

it('should handle spawn ENOENT error and not even retry', (done) => {
assertSpawnError({
errorCode: 'ENOENT',
emitExit: true,
expectedError: `Cannot start fake-name\n\tCan not find the binary ${BROWSER_PATH}\n\tPlease set env variable fake-ENV-CMD`
}, done)
})

it('should handle spawn EACCES error and not even retry', (done) => {
ProcessLauncher.call(launcher, mockSpawn, mockTempDir)
RetryLauncher.call(launcher, 2)
launcher._getCommand = () => BROWSER_PATH

const failureSpy = sinon.spy()
emitter.on('browser_process_failure', failureSpy)
assertSpawnError({
errorCode: 'EACCES',
emitExit: true,
expectedError: `Cannot start fake-name\n\tPermission denied accessing the binary ${BROWSER_PATH}\n\tMaybe it's a directory?`
}, done)
})

launcher.start('http://host:9876/')
mockSpawn._processes[0].emit('error', { code: 'EACCES' })
mockSpawn._processes[0].emit('exit', 1)
mockTempDir.remove.callArg(1)
it('should handle spawn ENOENT error and report the error when exit event is not emitted', (done) => {
assertSpawnError({
errorCode: 'ENOENT',
emitExit: false,
expectedError: `Cannot start fake-name\n\tCan not find the binary ${BROWSER_PATH}\n\tPlease set env variable fake-ENV-CMD`
}, done)
})

_.defer(() => {
expect(launcher.state).to.equal(launcher.STATE_FINISHED)
expect(failureSpy).to.have.been.called
done()
})
it('should handle spawn EACCES error and report the error when exit event is not emitted', (done) => {
assertSpawnError({
errorCode: 'EACCES',
emitExit: false,
expectedError: `Cannot start fake-name\n\tPermission denied accessing the binary ${BROWSER_PATH}\n\tMaybe it's a directory?`
}, done)
})
})

Expand Down

0 comments on commit 7ab86be

Please sign in to comment.