aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

Merge pull request #799 from shocknet/fix-subp-err

Browse source 
fix send error
This commit is contained in:
Justin (shocknet) 2025-05-07 12:25:57 -04:00 • committed by GitHub
commit 8094abf879
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 13 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
src/services/storage/db/storageProcessor.ts
View file

@ -494,9 +494,13 @@ class StorageProcessor {
private sendResponse(response: OperationResponse<any>) { private sendResponse(response: OperationResponse<any>) {
try { try {
if (process.send) { 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) { } catch (error) {
console.error("failed to send response to main process from storage processor, killing sub process") console.error("failed to send response to main process from storage processor, killing sub process")

9
src/services/storage/tlv/tlvFilesStorageProcessor.ts
View file

@ -106,7 +106,7 @@ class TlvFilesStorageProcessor {
}); });
process.on('error', (error: Error) => { 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 => { this.wrtc = new webRTC(t => {
@ -358,7 +358,12 @@ class TlvFilesStorageProcessor {
private sendResponse<T>(response: TlvOperationResponse<T>) { private sendResponse<T>(response: TlvOperationResponse<T>) {
try { try {
if (process.send) { 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) { } catch (error) {
console.error("failed to send response to main process from tlv files storage processor, killing sub process") console.error("failed to send response to main process from tlv files storage processor, killing sub process")