diff --git a/src/services/storage/db/storageProcessor.ts b/src/services/storage/db/storageProcessor.ts index 91455178..20c2cc07 100644 --- a/src/services/storage/db/storageProcessor.ts +++ b/src/services/storage/db/storageProcessor.ts @@ -494,9 +494,13 @@ class StorageProcessor { private sendResponse(response: OperationResponse) { try { - if (process.send) { - process.send(response); + process.send(response, undefined, undefined, err => { + if (err) { + console.error("failed to send response to main process from storage processor, killing sub process") + process.exit(1) + } + }); } } catch (error) { console.error("failed to send response to main process from storage processor, killing sub process") diff --git a/src/services/storage/tlv/tlvFilesStorageProcessor.ts b/src/services/storage/tlv/tlvFilesStorageProcessor.ts index caf9c14c..1beeeddc 100644 --- a/src/services/storage/tlv/tlvFilesStorageProcessor.ts +++ b/src/services/storage/tlv/tlvFilesStorageProcessor.ts @@ -106,7 +106,7 @@ class TlvFilesStorageProcessor { }); process.on('error', (error: Error) => { - console.error('Error in storage processor:', error); + console.error('Error in tlv files storage processor:', error); }); this.wrtc = new webRTC(t => { @@ -358,7 +358,12 @@ class TlvFilesStorageProcessor { private sendResponse(response: TlvOperationResponse) { try { if (process.send) { - process.send(response); + process.send(response, undefined, undefined, err => { + if (err) { + console.error("failed to send response to main process from tlv files storage processor, killing sub process") + process.exit(1) + } + }); } } catch (error) { console.error("failed to send response to main process from tlv files storage processor, killing sub process")