repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
chore: v2.5.2
[poolifier.git]
/
src
/
worker
/
abstract-worker.ts
diff --git
a/src/worker/abstract-worker.ts
b/src/worker/abstract-worker.ts
index 176a5893caeeec7cb9d82095840b97498b3822b0..8e55b30152fc60fb47a403ad31c44e7fc32457dd 100644
(file)
--- a/
src/worker/abstract-worker.ts
+++ b/
src/worker/abstract-worker.ts
@@
-212,13
+212,17
@@
export abstract class AbstractWorker<
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
- id: message.id,
runTime,
runTime,
- waitTime
+ waitTime,
+ id: message.id
})
} catch (e) {
const err = this.handleError(e as Error)
})
} catch (e) {
const err = this.handleError(e as Error)
- this.sendToMainWorker({ error: err, id: message.id })
+ this.sendToMainWorker({
+ error: err,
+ errorData: message.data,
+ id: message.id
+ })
} finally {
!this.isMain && (this.lastTaskTimestamp = performance.now())
}
} finally {
!this.isMain && (this.lastTaskTimestamp = performance.now())
}
@@
-241,15
+245,19
@@
export abstract class AbstractWorker<
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
const runTime = performance.now() - startTimestamp
this.sendToMainWorker({
data: res,
- id: message.id,
runTime,
runTime,
- waitTime
+ waitTime,
+ id: message.id
})
return null
})
.catch(e => {
const err = this.handleError(e as Error)
})
return null
})
.catch(e => {
const err = this.handleError(e as Error)
- this.sendToMainWorker({ error: err, id: message.id })
+ this.sendToMainWorker({
+ error: err,
+ errorData: message.data,
+ id: message.id
+ })
})
.finally(() => {
!this.isMain && (this.lastTaskTimestamp = performance.now())
})
.finally(() => {
!this.isMain && (this.lastTaskTimestamp = performance.now())
@@
-266,7
+274,7
@@
export abstract class AbstractWorker<
name = name ?? DEFAULT_FUNCTION_NAME
const fn = this.taskFunctions.get(name)
if (fn == null) {
name = name ?? DEFAULT_FUNCTION_NAME
const fn = this.taskFunctions.get(name)
if (fn == null) {
- throw new Error(`Task function
"${name}"
not found`)
+ throw new Error(`Task function
'${name}'
not found`)
}
return fn
}
}
return fn
}