michael/scrypted
1
0
Fork 0
mirror of https://github.com/koush/scrypted.git synced 2026-09-19 10:10:39 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

server: watch for worker errors

Browse Source
This commit is contained in:
Koushik Dutta
2022-02-11 12:33:08 -08:00
parent 7b85a5c0ed
commit ae57dea333
3 changed files with 21 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/plugin/runtime/node-fork-worker.ts
View File

@@ -35,10 +35,17 @@ export class NodeForkWorker extends ChildProcessWorker {
}
send(message: RpcMessage, reject?: (e: Error) => void): void {
this.worker.send(message, undefined, e => {
if (e && reject)
reject(e);
});
try {
if (!this.worker)
throw new Error('worked has been killed');
this.worker.send(message, undefined, e => {
if (e && reject)
reject(e);
});
}
catch (e) {
reject?.(e);
}
}
get pid() {

2
server/src/plugin/runtime/node-thread-worker.ts
View File

@@ -60,6 +60,8 @@ export class NodeThreadWorker extends EventEmitter implements RuntimeWorker {
send(message: RpcMessage, reject?: (e: Error) => void): void {
try {
if (!this.worker)
throw new Error('worked has been killed');
this.worker.postMessage(v8.serialize(message));
}
catch (e) {

9
server/src/plugin/runtime/python-worker.ts
View File

@@ -55,6 +55,13 @@ export class PythonRuntimeWorker extends ChildProcessWorker {
}
send(message: RpcMessage, reject?: (e: Error) => void): void {
(this.worker.stdio[3] as Writable).write(JSON.stringify(message) + '\n', e => e && reject?.(e));
try {
if (!this.worker)
throw new Error('worked has been killed');
(this.worker.stdio[3] as Writable).write(JSON.stringify(message) + '\n', e => e && reject?.(e));
}
catch (e) {
reject?.(e);
}
}
}