albert/mrfrys-node-server
1
0
Fork 0
mirror of https://gitlab.com/MrFry/mrfrys-node-server synced 2025-04-01 20:24:18 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

worker start msg counts fix

Browse source
This commit is contained in:
mrfry 2022-12-13 17:37:43 +01:00
parent 16cd4d9d4b
commit 537f4c413e
1 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/utils/classes.ts
View file

@ -693,7 +693,10 @@ function handleWorkerData() {
}: { workerIndex: number; initData: Array<QuestionDb> } = workerData }: { workerIndex: number; initData: Array<QuestionDb> } = workerData
let qdbs: Array<QuestionDb> = initData let qdbs: Array<QuestionDb> = initData
const subjCount = initData.length const qdbCount = initData.length
const subjCount = initData.reduce((sCount, qdb) => {
return sCount + qdb.data.length
}, 0)
const questionCount = initData.reduce((qCount, qdb) => { const questionCount = initData.reduce((qCount, qdb) => {
return ( return (
qCount + qCount +
@ -704,7 +707,7 @@ function handleWorkerData() {
}, 0) }, 0)
logger.Log( logger.Log(
`[THREAD #${workerIndex}]: Worker ${workerIndex} reporting for duty! subjects: ${subjCount}, questions: ${questionCount}` `[THREAD #${workerIndex}]: Worker ${workerIndex} reporting for duty! qdbs: ${qdbCount}, subjects: ${subjCount}, questions: ${questionCount}`
) )
parentPort.on('message', async (msg /*: TaskObject */) => { parentPort.on('message', async (msg /*: TaskObject */) => {