b700bdbb8bbcff9ff441960e5940c2d42c4c635a
1 import { dirname
, extname
, join
} from
'node:path'
2 import { fileURLToPath
} from
'node:url'
3 import { FixedClusterPool
, availableParallelism
} from
'poolifier'
4 import type { ClusterWorkerData
, ClusterWorkerResponse
} from
'./types.js'
6 const fastifyWorkerFile
= join(
7 dirname(fileURLToPath(import.meta
.url
)),
8 `fastify-worker${extname(fileURLToPath(import.meta.url))}`
11 const requestHandlerWorkerFile
= join(
12 dirname(fileURLToPath(import.meta
.url
)),
13 `request-handler-worker${extname(fileURLToPath(import.meta.url))}`
16 const pool
= new FixedClusterPool
<ClusterWorkerData
, ClusterWorkerResponse
>(
17 Math.round(availableParallelism() / 2),
20 onlineHandler
: () => {
24 workerFile
: requestHandlerWorkerFile
,
26 Math.round(availableParallelism() / 4) < 1
28 : Math.round(availableParallelism() / 4),
29 enableTasksQueue
: true,
33 errorHandler
: (e
: Error) => {
34 console
.error('Thread worker error', e
)
38 if (response
.status) {
40 // eslint-disable-next-line @typescript-eslint/restrict-template-expressions
41 `Fastify is listening in cluster worker on port ${response.port}`
47 console
.error('Fastify failed to start in cluster worker:', error
)
50 errorHandler
: (e
: Error) => {
51 console
.error('Cluster worker error:', e
)