10334604127

Committed 10 Aug 2024 09:28PM UTC coverage: 91.126%. Remained the same

Build # 10334604127

Build Type

Pull #3

github

Committed by

web-flow

Commit Message

Merge b1af0b225 into 47f59470b

Pull Request Pull Request #3: docs: fix typos

Run Details

311 of 350 branches covered (88.86%)

Branch coverage included in aggregate %.

53 of 55 new or added lines in 18 files covered. (96.36%)

18 existing lines in 3 files now uncovered.

1486 of 1622 relevant lines covered (91.62%)

758.43 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

82.76

/test/integration/errors/thread-exit-hangs.test.js

import test from 'node:test'
import cp from 'node:child_process'
import { join } from 'node:path'

import { main } from '../../../index.js'

test('#main() force kills non-exiting threads', async t => {
  await t.test('test duration elapses', async t => {
    await t.test('rejects', t => {
      return t.assert.rejects(async () => {
        return main({
          task: join(import.meta.dirname, './tasks/blocks-exit.js'),
          parameters:  {
            CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500
          }
        })
      })
    })
    
    await t.test('SIGKILLS remaining threads', async t => {
      t.before(() => cp.fork = t.mock.fn(cp.fork))

      await main({
        task: join(import.meta.dirname, './tasks/blocks-exit.js'),
        parameters:  {
          CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500
        }
      }).catch(() => { })

      t.assert.strictEqual(cp.fork.mock.calls.map(c => c.result)
        .map(t => t.signalCode === 'SIGKILL').length, 4)
    })
  })
  
  // too flaky
  t.todo('error thrown in a thread', async t => {
    await t.test('SIGKILLS the remaining threads and rejects', t => {
      return t.assert.rejects(async () => {
        return main({
          task: join(import.meta.dirname, './tasks/exits-1-and-block-exit.js'),
          parameters:  {
            CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500
          }
        })
      }, { message: 'process:disconnect timeout. Exited with:SIGKILL' })
    })
  })
})

1	import test from 'node:test'	1✔
2	import cp from 'node:child_process'	1✔
3	import { join } from 'node:path'	1✔
4		1✔
5	import { main } from '../../../index.js'	1✔
6		1✔
7	test('#main() force kills non-exiting threads', async t => {	1✔
8	await t.test('test duration elapses', async t => {	1✔
9	await t.test('rejects', t => {	1✔
10	return t.assert.rejects(async () => {	1✔
11	return main({	1✔
12	task: join(import.meta.dirname, './tasks/blocks-exit.js'),	1✔
13	parameters: {	1✔
14	CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500	1✔
15	}	1✔
16	})	1✔
17	})	1✔
18	})	1✔
19		1✔
20	await t.test('SIGKILLS remaining threads', async t => {	1✔
21	t.before(() => cp.fork = t.mock.fn(cp.fork))	1✔
22		1✔
23	await main({	1✔
24	task: join(import.meta.dirname, './tasks/blocks-exit.js'),	1✔
25	parameters: {	1✔
26	CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500	1✔
27	}	1✔
28	}).catch(() => { })	1✔
29		1✔
30	t.assert.strictEqual(cp.fork.mock.calls.map(c => c.result)	1✔
31	.map(t => t.signalCode === 'SIGKILL').length, 4)	1✔
32	})	1✔
33	})	1✔
34		1✔
35	// too flaky	1✔
36	t.todo('error thrown in a thread', async t => {	1✔
37	await t.test('SIGKILLS the remaining threads and rejects', t => {	×
UNCOV 38	return t.assert.rejects(async () => {	×
NEW 39	return main({	×
40	task: join(import.meta.dirname, './tasks/exits-1-and-block-exit.js'),	×
41	parameters: {	×
42	CYCLES_PER_SECOND: 50, CONCURRENCY: 4, DURATION_MS: 500	×
43	}	×
44	})	×
45	}, { message: 'process:disconnect timeout. Exited with:SIGKILL' })	×
UNCOV 46	})	×
47	})	1✔
48	})	1✔

nicholaswmin / dyno / 10334604127

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous