1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
|
'use strict'
const { unlinkSync, readFileSync } = require('fs')
const { createServer } = require('https')
const os = require('os')
const path = require('path')
const cluster = require('cluster')
const key = readFileSync(path.join(__dirname, '..', 'test', 'fixtures', 'key.pem'), 'utf8')
const cert = readFileSync(path.join(__dirname, '..', 'test', 'fixtures', 'cert.pem'), 'utf8')
const socketPath = path.join(os.tmpdir(), 'undici.sock')
const port = process.env.PORT || socketPath
const timeout = parseInt(process.env.TIMEOUT, 10) || 1
const workers = parseInt(process.env.WORKERS) || os.cpus().length
if (cluster.isPrimary) {
try {
unlinkSync(socketPath)
} catch (_) {
// Do nothing if the socket does not exist
}
for (let i = 0; i < workers; i++) {
cluster.fork()
}
} else {
const buf = Buffer.alloc(64 * 1024, '_')
const server = createServer({
key,
cert,
keepAliveTimeout: 600e3
}, (req, res) => {
setTimeout(() => {
res.end(buf)
}, timeout)
})
server.listen(port)
}
|
