legop3/MultiRoombaRover
1
0
Fork 0
mirror of https://github.com/legop3/MultiRoombaRover.git synced 2026-09-16 01:21:20 -04:00
Code Issues Actions Packages Projects Releases Wiki Activity

error handler

Browse Source
This commit is contained in:
legop3
2026-03-17 16:35:53 -04:00
parent 9f1efc6b91
commit c44632ed4d
1 changed files with 15 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
server/src/services/audioForwardService.js
+15 -1
View File
@@ -231,9 +231,23 @@ function buildClipWriterArgs(filePath) {
function attachWriterPipe(worker, proc) { function attachWriterPipe(worker, proc) {
const writer = fs.createWriteStream(worker.fifoPath, { flags: 'w' }); const writer = fs.createWriteStream(worker.fifoPath, { flags: 'w' });
writer.on('error', (err) => {
const code = err?.code || 'unknown';
// Broken pipe is expected when FIFO reader (publisher) restarts/exits.
if (code !== 'EPIPE') {
logger.warn('writer pipe error', { roverId: worker?.roverId, code, message: err?.message || String(err) });
}
});
proc.stdout.on('error', (err) => {
logger.warn('writer stdout error', {
roverId: worker?.roverId,
code: err?.code || 'unknown',
message: err?.message || String(err),
});
});
proc.stdout.pipe(writer); proc.stdout.pipe(writer);
proc.on('exit', () => { proc.on('exit', () => {
writer.end(); writer.destroy();
}); });
} }